Package ai.pipestream.connector.intake.v1

Interface ConnectorAdminServiceGrpc.AsyncService

All Known Implementing Classes:

ConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

Enclosing class:

ConnectorAdminServiceGrpc

public static interface ConnectorAdminServiceGrpc.AsyncService

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

Method Summary

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

Method Details

registerConnector

default void registerConnector(RegisterConnectorRequest request,
 io.grpc.stub.StreamObserver<RegisterConnectorResponse> responseObserver)

 Register a new connector
 

updateConnector

default void updateConnector(UpdateConnectorRequest request,
 io.grpc.stub.StreamObserver<UpdateConnectorResponse> responseObserver)

 Update connector configuration
 

getConnector

default void getConnector(GetConnectorRequest request,
 io.grpc.stub.StreamObserver<GetConnectorResponse> responseObserver)

 Get connector details
 

validateApiKey

default void validateApiKey(ValidateApiKeyRequest request,
 io.grpc.stub.StreamObserver<ValidateApiKeyResponse> responseObserver)

 Validate API key for a connector
 

listConnectors

default void listConnectors(ListConnectorsRequest request,
 io.grpc.stub.StreamObserver<ListConnectorsResponse> responseObserver)

 List all connectors for an account
 

setConnectorStatus

default void setConnectorStatus(SetConnectorStatusRequest request,
 io.grpc.stub.StreamObserver<SetConnectorStatusResponse> responseObserver)

 Enable/disable a connector
 

deleteConnector

default void deleteConnector(DeleteConnectorRequest request,
 io.grpc.stub.StreamObserver<DeleteConnectorResponse> responseObserver)

 Delete a connector (soft delete)
 

rotateApiKey

default void rotateApiKey(RotateApiKeyRequest request,
 io.grpc.stub.StreamObserver<RotateApiKeyResponse> responseObserver)

 Generate new API key for a connector
 

getCrawlHistory

default void getCrawlHistory(GetCrawlHistoryRequest request,
 io.grpc.stub.StreamObserver<GetCrawlHistoryResponse> responseObserver)

 Get crawl history for a connector