Package ai.pipestream.connector.intake.pipedoc
package ai.pipestream.connector.intake.pipedoc
-
ClassesClassDescriptionHandles the gRPC blob upload path: persist the doc to repository (durable, blobs are large so we don't route them through Redis), then hand off a reference-only request to the engine.Handles the unary
UploadBlobRPC.Fire-and-forget durable copy to the repository service for any document whose datasource is configured withpersist_pipedoc=true.Handles the unaryUploadPipeDocRPC.