Package ai.pipestream.connector.intake.v1

Class DataSourceAdminServiceGrpc.DataSourceAdminServiceBlockingStub

java.lang.Object

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

io.grpc.stub.AbstractBlockingStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceBlockingStub>

ai.pipestream.connector.intake.v1.DataSourceAdminServiceGrpc.DataSourceAdminServiceBlockingStub

Enclosing class:

DataSourceAdminServiceGrpc

public static final class DataSourceAdminServiceGrpc.DataSourceAdminServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<DataSourceAdminServiceGrpc.DataSourceAdminServiceBlockingStub>

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

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

Specified by:

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

createDataSource

public CreateDataSourceResponse createDataSource(CreateDataSourceRequest request)

 Create a new datasource for an account
 

updateDataSource

public UpdateDataSourceResponse updateDataSource(UpdateDataSourceRequest request)

 Update datasource configuration
 

getDataSource

public GetDataSourceResponse getDataSource(GetDataSourceRequest request)

 Get datasource details
 

validateApiKey

public ValidateApiKeyResponse validateApiKey(ValidateApiKeyRequest request)

 Validate API key for a datasource
 

listDataSources

public ListDataSourcesResponse listDataSources(ListDataSourcesRequest request)

 List all datasources for an account
 

setDataSourceStatus

public SetDataSourceStatusResponse setDataSourceStatus(SetDataSourceStatusRequest request)

 Enable/disable a datasource
 

deleteDataSource

public DeleteDataSourceResponse deleteDataSource(DeleteDataSourceRequest request)

 Delete a datasource (soft delete)
 

rotateApiKey

public RotateApiKeyResponse rotateApiKey(RotateApiKeyRequest request)

 Generate new API key for a datasource
 

getCrawlHistory

public GetCrawlHistoryResponse getCrawlHistory(GetCrawlHistoryRequest request)

 Get crawl history for a datasource
 

listConnectorTypes

public ListConnectorTypesResponse listConnectorTypes(ListConnectorTypesRequest request)

 List available connector types (pre-seeded templates)
 

getConnectorType

public GetConnectorTypeResponse getConnectorType(GetConnectorTypeRequest request)

 Get connector type details