Package ai.pipestream.connector.intake.v1

Class ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub>

io.grpc.stub.AbstractBlockingStub<ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub>

ai.pipestream.connector.intake.v1.ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub

Enclosing class:

ConnectorAdminServiceGrpc

public static final class ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub>

A stub to allow clients to do synchronous rpc calls to service ConnectorAdminService.

 Administrative operations for connector lifecycle management.
 Handles registration, configuration updates, and metadata queries for connectors.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
DeleteConnectorResponse	deleteConnector(DeleteConnectorRequest request)	Delete a connector (soft delete)
GetConnectorResponse	getConnector(GetConnectorRequest request)	Get connector details
GetCrawlHistoryResponse	getCrawlHistory(GetCrawlHistoryRequest request)	Get crawl history for a connector
ListConnectorsResponse	listConnectors(ListConnectorsRequest request)	List all connectors for an account
RegisterConnectorResponse	registerConnector(RegisterConnectorRequest request)	Register a new connector
RotateApiKeyResponse	rotateApiKey(RotateApiKeyRequest request)	Generate new API key for a connector
SetConnectorStatusResponse	setConnectorStatus(SetConnectorStatusRequest request)	Enable/disable a connector
UpdateConnectorResponse	updateConnector(UpdateConnectorRequest request)	Update connector configuration
ValidateApiKeyResponse	validateApiKey(ValidateApiKeyRequest request)	Validate API key for a connector

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

build

protected ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingV2Stub>

registerConnector

public RegisterConnectorResponse registerConnector(RegisterConnectorRequest request)
                                            throws io.grpc.StatusException

 Register a new connector
 

Throws:

io.grpc.StatusException

updateConnector

public UpdateConnectorResponse updateConnector(UpdateConnectorRequest request)
                                        throws io.grpc.StatusException

 Update connector configuration
 

Throws:

io.grpc.StatusException

getConnector

public GetConnectorResponse getConnector(GetConnectorRequest request)
                                  throws io.grpc.StatusException

 Get connector details
 

Throws:

io.grpc.StatusException

validateApiKey

public ValidateApiKeyResponse validateApiKey(ValidateApiKeyRequest request)
                                      throws io.grpc.StatusException

 Validate API key for a connector
 

Throws:

io.grpc.StatusException

listConnectors

public ListConnectorsResponse listConnectors(ListConnectorsRequest request)
                                      throws io.grpc.StatusException

 List all connectors for an account
 

Throws:

io.grpc.StatusException

setConnectorStatus

public SetConnectorStatusResponse setConnectorStatus(SetConnectorStatusRequest request)
                                              throws io.grpc.StatusException

 Enable/disable a connector
 

Throws:

io.grpc.StatusException

deleteConnector

public DeleteConnectorResponse deleteConnector(DeleteConnectorRequest request)
                                        throws io.grpc.StatusException

 Delete a connector (soft delete)
 

Throws:

io.grpc.StatusException

rotateApiKey

public RotateApiKeyResponse rotateApiKey(RotateApiKeyRequest request)
                                  throws io.grpc.StatusException

 Generate new API key for a connector
 

Throws:

io.grpc.StatusException

getCrawlHistory

public GetCrawlHistoryResponse getCrawlHistory(GetCrawlHistoryRequest request)
                                        throws io.grpc.StatusException

 Get crawl history for a connector
 

Throws:

io.grpc.StatusException