Package ai.pipestream.connector.intake.v1

Class MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub>

ai.pipestream.connector.intake.v1.MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub

All Implemented Interfaces:

io.quarkus.grpc.MutinyStub

Enclosing class:

MutinyConnectorAdminServiceGrpc

public static final class MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub
extends io.grpc.stub.AbstractStub<MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub>
implements io.quarkus.grpc.MutinyStub

  Administrative operations for connector lifecycle management.
 
  Handles registration, configuration updates, and metadata queries for connectors.
 

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 MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
io.smallrye.mutiny.Uni<DeleteConnectorResponse>	deleteConnector(DeleteConnectorRequest request)	Delete a connector (soft delete)
io.smallrye.mutiny.Uni<GetConnectorResponse>	getConnector(GetConnectorRequest request)	Register a new crawl session (Async/Background only)
io.smallrye.mutiny.Uni<GetCrawlHistoryResponse>	getCrawlHistory(GetCrawlHistoryRequest request)	Get crawl history for a connector
io.smallrye.mutiny.Uni<ListConnectorsResponse>	listConnectors(ListConnectorsRequest request)	Heartbeat to keep session alive
io.smallrye.mutiny.Uni<RegisterConnectorResponse>	registerConnector(RegisterConnectorRequest request)	1.
io.smallrye.mutiny.Uni<RotateApiKeyResponse>	rotateApiKey(RotateApiKeyRequest request)	Generate new API key for a connector
io.smallrye.mutiny.Uni<SetConnectorStatusResponse>	setConnectorStatus(SetConnectorStatusRequest request)	Enable/disable a connector
io.smallrye.mutiny.Uni<UpdateConnectorResponse>	updateConnector(UpdateConnectorRequest 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 MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub>

registerConnector

public io.smallrye.mutiny.Uni<RegisterConnectorResponse> registerConnector(RegisterConnectorRequest 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.
 

updateConnector

public io.smallrye.mutiny.Uni<UpdateConnectorResponse> updateConnector(UpdateConnectorRequest 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.
 

getConnector

public io.smallrye.mutiny.Uni<GetConnectorResponse> getConnector(GetConnectorRequest 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)
 

listConnectors

public io.smallrye.mutiny.Uni<ListConnectorsResponse> listConnectors(ListConnectorsRequest request)

  Heartbeat to keep session alive
 

setConnectorStatus

public io.smallrye.mutiny.Uni<SetConnectorStatusResponse> setConnectorStatus(SetConnectorStatusRequest request)

  Enable/disable a connector
 

deleteConnector

public io.smallrye.mutiny.Uni<DeleteConnectorResponse> deleteConnector(DeleteConnectorRequest request)

  Delete a connector (soft delete)
 

rotateApiKey

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

  Generate new API key for a connector
 

getCrawlHistory

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

  Get crawl history for a connector