Package ai.pipestream.connector.intake.v1

Interface DataSourceAdminServiceGrpc.AsyncService

All Known Implementing Classes:

DataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

Enclosing class:

DataSourceAdminServiceGrpc

public static interface DataSourceAdminServiceGrpc.AsyncService

 Administrative operations for datasource lifecycle management.
 A DataSource represents an account's binding to a connector type with its own API key.
 Connector types are pre-seeded templates (e.g., "s3", "file-crawler").
 DataSource = Account + Connector Type + API Key + Configuration.
 

Method Summary

Modifier and Type	Method	Description
default void	createDataSource(CreateDataSourceRequest request, io.grpc.stub.StreamObserver<CreateDataSourceResponse> responseObserver)	Create a new datasource for an account
default void	deleteDataSource(DeleteDataSourceRequest request, io.grpc.stub.StreamObserver<DeleteDataSourceResponse> responseObserver)	Delete a datasource (soft delete)
default void	getConnectorType(GetConnectorTypeRequest request, io.grpc.stub.StreamObserver<GetConnectorTypeResponse> responseObserver)	Get connector type details
default void	getCrawlHistory(GetCrawlHistoryRequest request, io.grpc.stub.StreamObserver<GetCrawlHistoryResponse> responseObserver)	Get crawl history for a datasource
default void	getDataSource(GetDataSourceRequest request, io.grpc.stub.StreamObserver<GetDataSourceResponse> responseObserver)	Get datasource details
default void	listConnectorTypes(ListConnectorTypesRequest request, io.grpc.stub.StreamObserver<ListConnectorTypesResponse> responseObserver)	List available connector types (pre-seeded templates)
default void	listDataSources(ListDataSourcesRequest request, io.grpc.stub.StreamObserver<ListDataSourcesResponse> responseObserver)	List all datasources for an account
default void	rotateApiKey(RotateApiKeyRequest request, io.grpc.stub.StreamObserver<RotateApiKeyResponse> responseObserver)	Generate new API key for a datasource
default void	setDataSourceStatus(SetDataSourceStatusRequest request, io.grpc.stub.StreamObserver<SetDataSourceStatusResponse> responseObserver)	Enable/disable a datasource
default void	updateDataSource(UpdateDataSourceRequest request, io.grpc.stub.StreamObserver<UpdateDataSourceResponse> responseObserver)	Update datasource configuration
default void	validateApiKey(ValidateApiKeyRequest request, io.grpc.stub.StreamObserver<ValidateApiKeyResponse> responseObserver)	Validate API key for a datasource

Method Details

createDataSource

default void createDataSource(CreateDataSourceRequest request,
 io.grpc.stub.StreamObserver<CreateDataSourceResponse> responseObserver)

 Create a new datasource for an account
 

updateDataSource

default void updateDataSource(UpdateDataSourceRequest request,
 io.grpc.stub.StreamObserver<UpdateDataSourceResponse> responseObserver)

 Update datasource configuration
 

getDataSource

default void getDataSource(GetDataSourceRequest request,
 io.grpc.stub.StreamObserver<GetDataSourceResponse> responseObserver)

 Get datasource details
 

validateApiKey

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

 Validate API key for a datasource
 

listDataSources

default void listDataSources(ListDataSourcesRequest request,
 io.grpc.stub.StreamObserver<ListDataSourcesResponse> responseObserver)

 List all datasources for an account
 

setDataSourceStatus

default void setDataSourceStatus(SetDataSourceStatusRequest request,
 io.grpc.stub.StreamObserver<SetDataSourceStatusResponse> responseObserver)

 Enable/disable a datasource
 

deleteDataSource

default void deleteDataSource(DeleteDataSourceRequest request,
 io.grpc.stub.StreamObserver<DeleteDataSourceResponse> responseObserver)

 Delete a datasource (soft delete)
 

rotateApiKey

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

 Generate new API key for a datasource
 

getCrawlHistory

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

 Get crawl history for a datasource
 

listConnectorTypes

default void listConnectorTypes(ListConnectorTypesRequest request,
 io.grpc.stub.StreamObserver<ListConnectorTypesResponse> responseObserver)

 List available connector types (pre-seeded templates)
 

getConnectorType

default void getConnectorType(GetConnectorTypeRequest request,
 io.grpc.stub.StreamObserver<GetConnectorTypeResponse> responseObserver)

 Get connector type details