Package ai.pipestream.connector.intake.v1

Class DataSourceAdminServiceBean

java.lang.Object

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

ai.pipestream.connector.intake.v1.DataSourceAdminServiceBean

All Implemented Interfaces:

io.grpc.BindableService, io.quarkus.grpc.MutinyBean

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/connector_intake_service.proto")
public class DataSourceAdminServiceBean
extends MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase
implements io.grpc.BindableService, io.quarkus.grpc.MutinyBean

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)

Methods inherited from class ai.pipestream.connector.intake.v1.MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

bindService, withCompression

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.grpc.BindableService

bindService

Method Details

createDataSource

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  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.
 

Overrides:

createDataSource in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

updateDataSource

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

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

Overrides:

updateDataSource in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

getDataSource

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  Register a new crawl session (Async/Background only)
 

Overrides:

getDataSource in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

validateApiKey

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  End a crawl session (for cleanup, orphan detection)
 

Overrides:

validateApiKey in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

listDataSources

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  Heartbeat to keep session alive
 

Overrides:

listDataSources in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

setDataSourceStatus

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  Enable/disable a datasource
 

Overrides:

setDataSourceStatus in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

deleteDataSource

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  Delete a datasource (soft delete)
 

Overrides:

deleteDataSource in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

rotateApiKey

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  Generate new API key for a datasource
 

Overrides:

rotateApiKey in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

getCrawlHistory

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  Get crawl history for a datasource
 

Overrides:

getCrawlHistory in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

listConnectorTypes

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  List available connector types (pre-seeded templates)
 

Overrides:

listConnectorTypes in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

getConnectorType

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

Description copied from class: MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase

  Get connector type details
 

Overrides:

getConnectorType in class MutinyDataSourceAdminServiceGrpc.DataSourceAdminServiceImplBase