Package ai.pipestream.connector.intake.v1

Class ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingStub

java.lang.Object

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

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

ai.pipestream.connector.intake.v1.ConnectorAdminServiceGrpc.ConnectorAdminServiceBlockingStub

Enclosing class:

ConnectorAdminServiceGrpc

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

A stub to allow clients to do limited 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.ConnectorAdminServiceBlockingStub	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.ConnectorAdminServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

registerConnector

public RegisterConnectorResponse registerConnector(RegisterConnectorRequest request)

 Register a new connector
 

updateConnector

public UpdateConnectorResponse updateConnector(UpdateConnectorRequest request)

 Update connector configuration
 

getConnector

public GetConnectorResponse getConnector(GetConnectorRequest request)

 Get connector details
 

validateApiKey

public ValidateApiKeyResponse validateApiKey(ValidateApiKeyRequest request)

 Validate API key for a connector
 

listConnectors

public ListConnectorsResponse listConnectors(ListConnectorsRequest request)

 List all connectors for an account
 

setConnectorStatus

public SetConnectorStatusResponse setConnectorStatus(SetConnectorStatusRequest request)

 Enable/disable a connector
 

deleteConnector

public DeleteConnectorResponse deleteConnector(DeleteConnectorRequest request)

 Delete a connector (soft delete)
 

rotateApiKey

public RotateApiKeyResponse rotateApiKey(RotateApiKeyRequest request)

 Generate new API key for a connector
 

getCrawlHistory

public GetCrawlHistoryResponse getCrawlHistory(GetCrawlHistoryRequest request)

 Get crawl history for a connector