Package ai.pipestream.connector.intake.v1

Class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

java.lang.Object

ai.pipestream.connector.intake.v1.MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

DataSourceAdminServiceBean

Enclosing class:

MutinyDataSourceAdminServiceGrpc

public abstract static class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase
extends Object
implements io.grpc.BindableService

  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.
 

Constructor Summary

Constructors

Constructor	Description
DataSourceAdminServiceImplBase()

Method Summary

Modifier and Type	Method	Description
final io.grpc.ServerServiceDefinition	bindService()
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)
MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase	withCompression(String compression)	Set whether the server will try to use a compressed response.

Methods inherited from class java.lang.Object

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

Constructor Details

DataSourceAdminServiceImplBase

public DataSourceAdminServiceImplBase()

Method Details

withCompression

public MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase withCompression(String compression)

Set whether the server will try to use a compressed response.

Parameters:

compression - the compression, e.g gzip

createDataSource

public 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

public 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

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

  Register a new crawl session (Async/Background only)
 

validateApiKey

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

  End a crawl session (for cleanup, orphan detection)
 

listDataSources

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

  Heartbeat to keep session alive
 

setDataSourceStatus

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

  Enable/disable a datasource
 

deleteDataSource

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

  Delete a datasource (soft delete)
 

rotateApiKey

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

  Generate new API key for a datasource
 

getCrawlHistory

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

  Get crawl history for a datasource
 

listConnectorTypes

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

  List available connector types (pre-seeded templates)
 

getConnectorType

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

  Get connector type details
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService