Package ai.pipeline.connector.intake.service

Class ConnectorIntakeServiceImpl

java.lang.Object

ai.pipestream.connector.intake.v1.MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl

All Implemented Interfaces:

io.grpc.BindableService

@Singleton
public class ConnectorIntakeServiceImpl
extends MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

gRPC service implementation handling connector ingestion endpoints.

Responsibilities:

• Validates connector identity and API key via ConnectorValidationService.
• Streams documents and blobs to repository-service using a dynamically provisioned NodeUploadService stub.
• Manages crawl session lifecycle (start, heartbeat, end).

This class is stateful only with respect to a lazily-initialized repository upload stub; all other operations are request-scoped and reactive.

Constructor Summary

Constructors

Constructor	Description
ConnectorIntakeServiceImpl()	Default constructor for CDI / gRPC.

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<EndCrawlSessionResponse>	endCrawlSession(EndCrawlSessionRequest request)	End a crawl session (for cleanup, orphan detection)
io.smallrye.mutiny.Uni<HeartbeatResponse>	heartbeat(HeartbeatRequest request)	Heartbeat to keep session alive
io.smallrye.mutiny.Uni<StartCrawlSessionResponse>	startCrawlSession(StartCrawlSessionRequest request)	Register a new crawl session (Async/Background only)
io.smallrye.mutiny.Uni<UploadBlobResponse>	uploadBlob(UploadBlobRequest request)	2.
io.smallrye.mutiny.Uni<UploadPipeDocResponse>	uploadPipeDoc(UploadPipeDocRequest request)	1.

Methods inherited from class ai.pipestream.connector.intake.v1.MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

bindService, withCompression

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectorIntakeServiceImpl

public ConnectorIntakeServiceImpl()

Default constructor for CDI / gRPC. No custom initialization required.

Method Details

uploadPipeDoc

public io.smallrye.mutiny.Uni<UploadPipeDocResponse> uploadPipeDoc(UploadPipeDocRequest request)

Description copied from class: MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

  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:

uploadPipeDoc in class MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

uploadBlob

public io.smallrye.mutiny.Uni<UploadBlobResponse> uploadBlob(UploadBlobRequest request)

Description copied from class: MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

  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:

uploadBlob in class MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

startCrawlSession

public io.smallrye.mutiny.Uni<StartCrawlSessionResponse> startCrawlSession(StartCrawlSessionRequest request)

Description copied from class: MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

  Register a new crawl session (Async/Background only)
 

Overrides:

startCrawlSession in class MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

endCrawlSession

public io.smallrye.mutiny.Uni<EndCrawlSessionResponse> endCrawlSession(EndCrawlSessionRequest request)

Description copied from class: MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

  End a crawl session (for cleanup, orphan detection)
 

Overrides:

endCrawlSession in class MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

heartbeat

public io.smallrye.mutiny.Uni<HeartbeatResponse> heartbeat(HeartbeatRequest request)

Description copied from class: MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

  Heartbeat to keep session alive
 

Overrides:

heartbeat in class MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase