Package ai.pipestream.connector.intake.v1

Class ConnectorAdminServiceBean

java.lang.Object

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

ai.pipestream.connector.intake.v1.ConnectorAdminServiceBean

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 ConnectorAdminServiceBean
extends MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase
implements io.grpc.BindableService, io.quarkus.grpc.MutinyBean

Method Summary

Modifier and Type	Method	Description
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 ai.pipestream.connector.intake.v1.MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

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

registerConnector

public io.smallrye.mutiny.Uni<RegisterConnectorResponse> registerConnector(RegisterConnectorRequest request)

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  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:

registerConnector in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

updateConnector

public io.smallrye.mutiny.Uni<UpdateConnectorResponse> updateConnector(UpdateConnectorRequest request)

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  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:

updateConnector in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

getConnector

public io.smallrye.mutiny.Uni<GetConnectorResponse> getConnector(GetConnectorRequest request)

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  Register a new crawl session (Async/Background only)
 

Overrides:

getConnector in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

validateApiKey

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

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  End a crawl session (for cleanup, orphan detection)
 

Overrides:

validateApiKey in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

listConnectors

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

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  Heartbeat to keep session alive
 

Overrides:

listConnectors in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

setConnectorStatus

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

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  Enable/disable a connector
 

Overrides:

setConnectorStatus in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

deleteConnector

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

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  Delete a connector (soft delete)
 

Overrides:

deleteConnector in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

rotateApiKey

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

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  Generate new API key for a connector
 

Overrides:

rotateApiKey in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

getCrawlHistory

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

Description copied from class: MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase

  Get crawl history for a connector
 

Overrides:

getCrawlHistory in class MutinyConnectorAdminServiceGrpc.ConnectorAdminServiceImplBase