Package ai.pipestream.connector.intake.v1

Class ConnectorAdminServiceClient

java.lang.Object

ai.pipestream.connector.intake.v1.ConnectorAdminServiceClient

All Implemented Interfaces:

ConnectorAdminService, io.quarkus.grpc.MutinyClient<MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub>, io.quarkus.grpc.MutinyService

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/connector_intake_service.proto")
public class ConnectorAdminServiceClient
extends Object
implements ConnectorAdminService, io.quarkus.grpc.MutinyClient<MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub>

Constructor Summary

Constructors

Constructor	Description
ConnectorAdminServiceClient(String name, io.grpc.Channel channel, BiFunction<String,MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub,MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub> stubConfigurator)

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
MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub	getStub()
io.smallrye.mutiny.Uni<ListConnectorsResponse>	listConnectors(ListConnectorsRequest request)	Heartbeat to keep session alive
ConnectorAdminServiceClient	newInstanceWithStub(MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub stub)
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 java.lang.Object

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

Constructor Details

ConnectorAdminServiceClient

public ConnectorAdminServiceClient(String name,
 io.grpc.Channel channel,
 BiFunction<String,MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub,MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub> stubConfigurator)

Method Details

newInstanceWithStub

public ConnectorAdminServiceClient newInstanceWithStub(MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub stub)

Specified by:

newInstanceWithStub in interface io.quarkus.grpc.MutinyClient<MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub>

getStub

public MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub getStub()

Specified by:

getStub in interface io.quarkus.grpc.MutinyClient<MutinyConnectorAdminServiceGrpc.MutinyConnectorAdminServiceStub>

registerConnector

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

Description copied from interface: ConnectorAdminService

  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.
 

Specified by:

registerConnector in interface ConnectorAdminService

updateConnector

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

Description copied from interface: ConnectorAdminService

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

Specified by:

updateConnector in interface ConnectorAdminService

getConnector

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

Description copied from interface: ConnectorAdminService

  Register a new crawl session (Async/Background only)
 

Specified by:

getConnector in interface ConnectorAdminService

validateApiKey

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

Description copied from interface: ConnectorAdminService

  End a crawl session (for cleanup, orphan detection)
 

Specified by:

validateApiKey in interface ConnectorAdminService

listConnectors

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

Description copied from interface: ConnectorAdminService

  Heartbeat to keep session alive
 

Specified by:

listConnectors in interface ConnectorAdminService

setConnectorStatus

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

Description copied from interface: ConnectorAdminService

  Enable/disable a connector
 

Specified by:

setConnectorStatus in interface ConnectorAdminService

deleteConnector

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

Description copied from interface: ConnectorAdminService

  Delete a connector (soft delete)
 

Specified by:

deleteConnector in interface ConnectorAdminService

rotateApiKey

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

Description copied from interface: ConnectorAdminService

  Generate new API key for a connector
 

Specified by:

rotateApiKey in interface ConnectorAdminService

getCrawlHistory

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

Description copied from interface: ConnectorAdminService

  Get crawl history for a connector
 

Specified by:

getCrawlHistory in interface ConnectorAdminService