Package ai.pipestream.connector.intake.v1

Class ConnectorAdminServiceGrpc.ConnectorAdminServiceFutureStub

java.lang.Object

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

io.grpc.stub.AbstractFutureStub<ConnectorAdminServiceGrpc.ConnectorAdminServiceFutureStub>

ai.pipestream.connector.intake.v1.ConnectorAdminServiceGrpc.ConnectorAdminServiceFutureStub

Enclosing class:

ConnectorAdminServiceGrpc

public static final class ConnectorAdminServiceGrpc.ConnectorAdminServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<ConnectorAdminServiceGrpc.ConnectorAdminServiceFutureStub>

A stub to allow clients to do ListenableFuture-style 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.ConnectorAdminServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<DeleteConnectorResponse>	deleteConnector(DeleteConnectorRequest request)	Delete a connector (soft delete)
com.google.common.util.concurrent.ListenableFuture<GetConnectorResponse>	getConnector(GetConnectorRequest request)	Get connector details
com.google.common.util.concurrent.ListenableFuture<GetCrawlHistoryResponse>	getCrawlHistory(GetCrawlHistoryRequest request)	Get crawl history for a connector
com.google.common.util.concurrent.ListenableFuture<ListConnectorsResponse>	listConnectors(ListConnectorsRequest request)	List all connectors for an account
com.google.common.util.concurrent.ListenableFuture<RegisterConnectorResponse>	registerConnector(RegisterConnectorRequest request)	Register a new connector
com.google.common.util.concurrent.ListenableFuture<RotateApiKeyResponse>	rotateApiKey(RotateApiKeyRequest request)	Generate new API key for a connector
com.google.common.util.concurrent.ListenableFuture<SetConnectorStatusResponse>	setConnectorStatus(SetConnectorStatusRequest request)	Enable/disable a connector
com.google.common.util.concurrent.ListenableFuture<UpdateConnectorResponse>	updateConnector(UpdateConnectorRequest request)	Update connector configuration
com.google.common.util.concurrent.ListenableFuture<ValidateApiKeyResponse>	validateApiKey(ValidateApiKeyRequest request)	Validate API key for a connector

Methods inherited from class io.grpc.stub.AbstractFutureStub

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.ConnectorAdminServiceFutureStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

registerConnector

public com.google.common.util.concurrent.ListenableFuture<RegisterConnectorResponse> registerConnector(RegisterConnectorRequest request)

 Register a new connector
 

updateConnector

public com.google.common.util.concurrent.ListenableFuture<UpdateConnectorResponse> updateConnector(UpdateConnectorRequest request)

 Update connector configuration
 

getConnector

public com.google.common.util.concurrent.ListenableFuture<GetConnectorResponse> getConnector(GetConnectorRequest request)

 Get connector details
 

validateApiKey

public com.google.common.util.concurrent.ListenableFuture<ValidateApiKeyResponse> validateApiKey(ValidateApiKeyRequest request)

 Validate API key for a connector
 

listConnectors

public com.google.common.util.concurrent.ListenableFuture<ListConnectorsResponse> listConnectors(ListConnectorsRequest request)

 List all connectors for an account
 

setConnectorStatus

public com.google.common.util.concurrent.ListenableFuture<SetConnectorStatusResponse> setConnectorStatus(SetConnectorStatusRequest request)

 Enable/disable a connector
 

deleteConnector

public com.google.common.util.concurrent.ListenableFuture<DeleteConnectorResponse> deleteConnector(DeleteConnectorRequest request)

 Delete a connector (soft delete)
 

rotateApiKey

public com.google.common.util.concurrent.ListenableFuture<RotateApiKeyResponse> rotateApiKey(RotateApiKeyRequest request)

 Generate new API key for a connector
 

getCrawlHistory

public com.google.common.util.concurrent.ListenableFuture<GetCrawlHistoryResponse> getCrawlHistory(GetCrawlHistoryRequest request)

 Get crawl history for a connector