Package ai.pipestream.connector.intake.v1

Class DataSourceAdminServiceClient

java.lang.Object

ai.pipestream.connector.intake.v1.DataSourceAdminServiceClient

All Implemented Interfaces:

DataSourceAdminService, io.quarkus.grpc.MutinyClient<MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub>, io.quarkus.grpc.MutinyService

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/connector_intake_service.proto")
public class DataSourceAdminServiceClient
extends Object
implements DataSourceAdminService, io.quarkus.grpc.MutinyClient<MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub>

Constructor Summary

Constructors

Constructor	Description
DataSourceAdminServiceClient(String name, io.grpc.Channel channel, BiFunction<String,MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub,MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub> stubConfigurator)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<CreateDataSourceResponse>	createDataSource(CreateDataSourceRequest request)	1.
io.smallrye.mutiny.Uni<DeleteDataSourceResponse>	deleteDataSource(DeleteDataSourceRequest request)	Delete a datasource (soft delete)
io.smallrye.mutiny.Uni<GetConnectorTypeResponse>	getConnectorType(GetConnectorTypeRequest request)	Get connector type details
io.smallrye.mutiny.Uni<GetCrawlHistoryResponse>	getCrawlHistory(GetCrawlHistoryRequest request)	Get crawl history for a datasource
io.smallrye.mutiny.Uni<GetDataSourceResponse>	getDataSource(GetDataSourceRequest request)	Register a new crawl session (Async/Background only)
MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub	getStub()
io.smallrye.mutiny.Uni<ListConnectorTypesResponse>	listConnectorTypes(ListConnectorTypesRequest request)	List available connector types (pre-seeded templates)
io.smallrye.mutiny.Uni<ListDataSourcesResponse>	listDataSources(ListDataSourcesRequest request)	Heartbeat to keep session alive
DataSourceAdminServiceClient	newInstanceWithStub(MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub stub)
io.smallrye.mutiny.Uni<RotateApiKeyResponse>	rotateApiKey(RotateApiKeyRequest request)	Generate new API key for a datasource
io.smallrye.mutiny.Uni<SetDataSourceStatusResponse>	setDataSourceStatus(SetDataSourceStatusRequest request)	Enable/disable a datasource
io.smallrye.mutiny.Uni<UpdateDataSourceResponse>	updateDataSource(UpdateDataSourceRequest request)	2.
io.smallrye.mutiny.Uni<ValidateApiKeyResponse>	validateApiKey(ValidateApiKeyRequest request)	End a crawl session (for cleanup, orphan detection)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DataSourceAdminServiceClient

public DataSourceAdminServiceClient(String name,
 io.grpc.Channel channel,
 BiFunction<String,MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub,MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub> stubConfigurator)

Method Details

newInstanceWithStub

public DataSourceAdminServiceClient newInstanceWithStub(MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub stub)

Specified by:

newInstanceWithStub in interface io.quarkus.grpc.MutinyClient<MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub>

getStub

public MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub getStub()

Specified by:

getStub in interface io.quarkus.grpc.MutinyClient<MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub>

createDataSource

public io.smallrye.mutiny.Uni<CreateDataSourceResponse> createDataSource(CreateDataSourceRequest request)

Description copied from interface: DataSourceAdminService

  1. The "Power User" path: Client sends a full PipeDoc
  Best for internal services, advanced connectors, or "Box.com" style integrations
  where the client already knows the structure.
 

Specified by:

createDataSource in interface DataSourceAdminService

updateDataSource

public io.smallrye.mutiny.Uni<UpdateDataSourceResponse> updateDataSource(UpdateDataSourceRequest request)

Description copied from interface: DataSourceAdminService

  2. The "Simple" path: Client sends raw bytes (Blob) + minimal metadata
  Best for "I just have a file" scenarios. Intake constructs the PipeDoc wrapper.
 

Specified by:

updateDataSource in interface DataSourceAdminService

getDataSource

public io.smallrye.mutiny.Uni<GetDataSourceResponse> getDataSource(GetDataSourceRequest request)

Description copied from interface: DataSourceAdminService

  Register a new crawl session (Async/Background only)
 

Specified by:

getDataSource in interface DataSourceAdminService

validateApiKey

public io.smallrye.mutiny.Uni<ValidateApiKeyResponse> validateApiKey(ValidateApiKeyRequest request)

Description copied from interface: DataSourceAdminService

  End a crawl session (for cleanup, orphan detection)
 

Specified by:

validateApiKey in interface DataSourceAdminService

listDataSources

public io.smallrye.mutiny.Uni<ListDataSourcesResponse> listDataSources(ListDataSourcesRequest request)

Description copied from interface: DataSourceAdminService

  Heartbeat to keep session alive
 

Specified by:

listDataSources in interface DataSourceAdminService

setDataSourceStatus

public io.smallrye.mutiny.Uni<SetDataSourceStatusResponse> setDataSourceStatus(SetDataSourceStatusRequest request)

Description copied from interface: DataSourceAdminService

  Enable/disable a datasource
 

Specified by:

setDataSourceStatus in interface DataSourceAdminService

deleteDataSource

public io.smallrye.mutiny.Uni<DeleteDataSourceResponse> deleteDataSource(DeleteDataSourceRequest request)

Description copied from interface: DataSourceAdminService

  Delete a datasource (soft delete)
 

Specified by:

deleteDataSource in interface DataSourceAdminService

rotateApiKey

public io.smallrye.mutiny.Uni<RotateApiKeyResponse> rotateApiKey(RotateApiKeyRequest request)

Description copied from interface: DataSourceAdminService

  Generate new API key for a datasource
 

Specified by:

rotateApiKey in interface DataSourceAdminService

getCrawlHistory

public io.smallrye.mutiny.Uni<GetCrawlHistoryResponse> getCrawlHistory(GetCrawlHistoryRequest request)

Description copied from interface: DataSourceAdminService

  Get crawl history for a datasource
 

Specified by:

getCrawlHistory in interface DataSourceAdminService

listConnectorTypes

public io.smallrye.mutiny.Uni<ListConnectorTypesResponse> listConnectorTypes(ListConnectorTypesRequest request)

Description copied from interface: DataSourceAdminService

  List available connector types (pre-seeded templates)
 

Specified by:

listConnectorTypes in interface DataSourceAdminService

getConnectorType

public io.smallrye.mutiny.Uni<GetConnectorTypeResponse> getConnectorType(GetConnectorTypeRequest request)

Description copied from interface: DataSourceAdminService

  Get connector type details
 

Specified by:

getConnectorType in interface DataSourceAdminService