Package ai.pipestream.connector.intake.v1

Class DataSourceAdminServiceGrpc.DataSourceAdminServiceBlockingV2Stub

java.lang.Object

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

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

ai.pipestream.connector.intake.v1.DataSourceAdminServiceGrpc.DataSourceAdminServiceBlockingV2Stub

Enclosing class:

DataSourceAdminServiceGrpc

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

A stub to allow clients to do 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.DataSourceAdminServiceBlockingV2Stub	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.DataSourceAdminServiceBlockingV2Stub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

createDataSource

public CreateDataSourceResponse createDataSource(CreateDataSourceRequest request)
                                          throws io.grpc.StatusException

 Create a new datasource for an account
 

Throws:

io.grpc.StatusException

updateDataSource

public UpdateDataSourceResponse updateDataSource(UpdateDataSourceRequest request)
                                          throws io.grpc.StatusException

 Update datasource configuration
 

Throws:

io.grpc.StatusException

getDataSource

public GetDataSourceResponse getDataSource(GetDataSourceRequest request)
                                    throws io.grpc.StatusException

 Get datasource details
 

Throws:

io.grpc.StatusException

validateApiKey

public ValidateApiKeyResponse validateApiKey(ValidateApiKeyRequest request)
                                      throws io.grpc.StatusException

 Validate API key for a datasource
 

Throws:

io.grpc.StatusException

listDataSources

public ListDataSourcesResponse listDataSources(ListDataSourcesRequest request)
                                        throws io.grpc.StatusException

 List all datasources for an account
 

Throws:

io.grpc.StatusException

setDataSourceStatus

public SetDataSourceStatusResponse setDataSourceStatus(SetDataSourceStatusRequest request)
                                                throws io.grpc.StatusException

 Enable/disable a datasource
 

Throws:

io.grpc.StatusException

deleteDataSource

public DeleteDataSourceResponse deleteDataSource(DeleteDataSourceRequest request)
                                          throws io.grpc.StatusException

 Delete a datasource (soft delete)
 

Throws:

io.grpc.StatusException

rotateApiKey

public RotateApiKeyResponse rotateApiKey(RotateApiKeyRequest request)
                                  throws io.grpc.StatusException

 Generate new API key for a datasource
 

Throws:

io.grpc.StatusException

getCrawlHistory

public GetCrawlHistoryResponse getCrawlHistory(GetCrawlHistoryRequest request)
                                        throws io.grpc.StatusException

 Get crawl history for a datasource
 

Throws:

io.grpc.StatusException

listConnectorTypes

public ListConnectorTypesResponse listConnectorTypes(ListConnectorTypesRequest request)
                                              throws io.grpc.StatusException

 List available connector types (pre-seeded templates)
 

Throws:

io.grpc.StatusException

getConnectorType

public GetConnectorTypeResponse getConnectorType(GetConnectorTypeRequest request)
                                          throws io.grpc.StatusException

 Get connector type details
 

Throws:

io.grpc.StatusException