Package ai.pipestream.connector.intake.v1

Class MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub>

ai.pipestream.connector.intake.v1.MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub

All Implemented Interfaces:

io.quarkus.grpc.MutinyStub

Enclosing class:

MutinyDataSourceAdminServiceGrpc

public static final class MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub
extends io.grpc.stub.AbstractStub<MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub>
implements io.quarkus.grpc.MutinyStub

  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 MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
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 io.grpc.stub.AbstractStub

getCallOptions, getChannel, newStub, newStub, 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 MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<MutinyDataSourceAdminServiceGrpc.MutinyDataSourceAdminServiceStub>

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