Package ai.pipestream.connector.intake.v1

Interface DataSourceAdminService

All Superinterfaces:

io.quarkus.grpc.MutinyService

All Known Implementing Classes:

DataSourceAdminServiceClient

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/connector_intake_service.proto")
public interface DataSourceAdminService
extends io.quarkus.grpc.MutinyService

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)
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
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)

Method Details

createDataSource

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

  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.
 

updateDataSource

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

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

getDataSource

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

  Register a new crawl session (Async/Background only)
 

validateApiKey

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

  End a crawl session (for cleanup, orphan detection)
 

listDataSources

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

  Heartbeat to keep session alive
 

setDataSourceStatus

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

  Enable/disable a datasource
 

deleteDataSource

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

  Delete a datasource (soft delete)
 

rotateApiKey

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

  Generate new API key for a datasource
 

getCrawlHistory

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

  Get crawl history for a datasource
 

listConnectorTypes

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

  List available connector types (pre-seeded templates)
 

getConnectorType

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

  Get connector type details