Package ai.pipestream.connector.intake.v1

Class DataSourceAdminServiceGrpc.DataSourceAdminServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceStub>

io.grpc.stub.AbstractAsyncStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceStub>

ai.pipestream.connector.intake.v1.DataSourceAdminServiceGrpc.DataSourceAdminServiceStub

Enclosing class:

DataSourceAdminServiceGrpc

public static final class DataSourceAdminServiceGrpc.DataSourceAdminServiceStub
extends io.grpc.stub.AbstractAsyncStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceStub>

A stub to allow clients to do asynchronous rpc calls to service DataSourceAdminService.

 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.
 

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

Methods inherited from class io.grpc.stub.AbstractAsyncStub

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

Specified by:

build in class io.grpc.stub.AbstractStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceStub>

createDataSource

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

 Create a new datasource for an account
 

updateDataSource

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

 Update datasource configuration
 

getDataSource

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

 Get datasource details
 

validateApiKey

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

 Validate API key for a datasource
 

listDataSources

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

 List all datasources for an account
 

setDataSourceStatus

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

 Enable/disable a datasource
 

deleteDataSource

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

 Delete a datasource (soft delete)
 

rotateApiKey

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

 Generate new API key for a datasource
 

getCrawlHistory

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

 Get crawl history for a datasource
 

listConnectorTypes

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

 List available connector types (pre-seeded templates)
 

getConnectorType

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

 Get connector type details