Package ai.pipestream.connector.intake.v1

Class DataSourceAdminServiceGrpc.DataSourceAdminServiceFutureStub

java.lang.Object

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

io.grpc.stub.AbstractFutureStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceFutureStub>

ai.pipestream.connector.intake.v1.DataSourceAdminServiceGrpc.DataSourceAdminServiceFutureStub

Enclosing class:

DataSourceAdminServiceGrpc

public static final class DataSourceAdminServiceGrpc.DataSourceAdminServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceFutureStub>

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

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

Specified by:

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

createDataSource

public com.google.common.util.concurrent.ListenableFuture<CreateDataSourceResponse> createDataSource(CreateDataSourceRequest request)

 Create a new datasource for an account
 

updateDataSource

public com.google.common.util.concurrent.ListenableFuture<UpdateDataSourceResponse> updateDataSource(UpdateDataSourceRequest request)

 Update datasource configuration
 

getDataSource

public com.google.common.util.concurrent.ListenableFuture<GetDataSourceResponse> getDataSource(GetDataSourceRequest request)

 Get datasource details
 

validateApiKey

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

 Validate API key for a datasource
 

listDataSources

public com.google.common.util.concurrent.ListenableFuture<ListDataSourcesResponse> listDataSources(ListDataSourcesRequest request)

 List all datasources for an account
 

setDataSourceStatus

public com.google.common.util.concurrent.ListenableFuture<SetDataSourceStatusResponse> setDataSourceStatus(SetDataSourceStatusRequest request)

 Enable/disable a datasource
 

deleteDataSource

public com.google.common.util.concurrent.ListenableFuture<DeleteDataSourceResponse> deleteDataSource(DeleteDataSourceRequest request)

 Delete a datasource (soft delete)
 

rotateApiKey

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

 Generate new API key for a datasource
 

getCrawlHistory

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

 Get crawl history for a datasource
 

listConnectorTypes

public com.google.common.util.concurrent.ListenableFuture<ListConnectorTypesResponse> listConnectorTypes(ListConnectorTypesRequest request)

 List available connector types (pre-seeded templates)
 

getConnectorType

public com.google.common.util.concurrent.ListenableFuture<GetConnectorTypeResponse> getConnectorType(GetConnectorTypeRequest request)

 Get connector type details