Package ai.pipestream.connector.intake.v1

Class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

java.lang.Object

ai.pipestream.connector.intake.v1.MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

ConnectorAdminServiceBean

Enclosing class:

MutinyConnectorAdminServiceGrpc

public abstract static class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase
extends Object
implements io.grpc.BindableService

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

Constructor Summary

Constructors

Constructor	Description
ConnectorAdminServiceImplBase()

Method Summary

Modifier and Type	Method	Description
final io.grpc.ServerServiceDefinition	bindService()
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)
MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase	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

ConnectorAdminServiceImplBase

public ConnectorAdminServiceImplBase()

Method Details

withCompression

public MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase withCompression(String compression)

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

Parameters:

compression - the compression, e.g gzip

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
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService