All Classes and Interfaces
Class
Description
Utilities for API key generation and hashing.
Administrative operations for connector lifecycle management.
Administrative operations for connector lifecycle management.
A stub to allow clients to do limited synchronous rpc calls to service ConnectorAdminService.
A stub to allow clients to do synchronous rpc calls to service ConnectorAdminService.
A stub to allow clients to do ListenableFuture-style rpc calls to service ConnectorAdminService.
Base class for the server implementation of the service ConnectorAdminService.
A stub to allow clients to do asynchronous rpc calls to service ConnectorAdminService.
Connector configuration returned after authentication.
Connector configuration returned after authentication.
High-throughput document ingestion service for all connector types.
High-throughput document ingestion service for all connector types.
A stub to allow clients to do limited synchronous rpc calls to service ConnectorIntakeService.
A stub to allow clients to do synchronous rpc calls to service ConnectorIntakeService.
A stub to allow clients to do ListenableFuture-style rpc calls to service ConnectorIntakeService.
Base class for the server implementation of the service ConnectorIntakeService.
A stub to allow clients to do asynchronous rpc calls to service ConnectorIntakeService.
Utility class for parsing and serializing connector metadata JSON.
Complete connector registration information.
Complete connector registration information.
Service for validating connector API keys and fetching connector configuration.
Control commands sent from server to crawler.
Document tracking entity for orphan detection.
Composite primary key for CrawlDocument.
Repository for crawl document tracking operations.
Metadata describing a crawl session.
Metadata describing a crawl session.
Crawl session entity tracking document ingestion sessions.
Repository for crawl session operations.
Summary of a completed crawl session.
Summary of a completed crawl session.
Summary statistics for a completed crawl.
Summary statistics for a completed crawl.
Request to delete a connector.
Request to delete a connector.
Response from connector deletion.
Response from connector deletion.
Simplified Document Processor.
Chunked document upload service for large files.
Chunked document upload service for large files.
A stub to allow clients to do limited synchronous rpc calls to service DocumentUploadService.
A stub to allow clients to do synchronous rpc calls to service DocumentUploadService.
A stub to allow clients to do ListenableFuture-style rpc calls to service DocumentUploadService.
Base class for the server implementation of the service DocumentUploadService.
A stub to allow clients to do asynchronous rpc calls to service DocumentUploadService.
Request to end an active crawl session.
Request to end an active crawl session.
Response from ending a crawl session.
Response from ending a crawl session.
Request to get connector details.
Request to get connector details.
Response containing connector details.
Response containing connector details.
Request to get crawl history for a connector.
Request to get crawl history for a connector.
Response containing crawl history.
Response containing crawl history.
Request to get current upload progress snapshot
Request to get current upload progress snapshot
Response with current upload progress
Response with current upload progress
Request to maintain an active crawl session.
Request to maintain an active crawl session.
Response from heartbeat with optional control commands.
Response from heartbeat with optional control commands.
Request to list connectors.
Request to list connectors.
Response containing connector list.
Response containing connector list.
Administrative operations for connector lifecycle management.
Administrative operations for connector lifecycle management.
High-throughput document ingestion service for all connector types.
High-throughput document ingestion service for all connector types.
Chunked document upload service for large files.
Chunked document upload service for large files.
Request to register a new connector.
Request to register a new connector.
Response from connector registration.
Response from connector registration.
Client for repository-service integration.
Request to rotate connector API key.
Request to rotate connector API key.
Response from API key rotation.
Response from API key rotation.
Service for managing crawl session lifecycle.
Request to enable or disable a connector.
Request to enable or disable a connector.
Response from status change.
Response from status change.
Request to start a new crawl session.
Request to start a new crawl session.
Response from starting a crawl session.
Response from starting a crawl session.
Request to stream real-time upload progress updates
Request to stream real-time upload progress updates
Streaming response with real-time upload progress updates
Streaming response with real-time upload progress updates
Request to update connector configuration.
Request to update connector configuration.
Response from connector update.
Response from connector update.
Request to upload raw file content with minimal metadata.
Request to upload raw file content with minimal metadata.
Protobuf type
ai.pipestream.connector.intake.v1.UploadBlobResponseProtobuf type
ai.pipestream.connector.intake.v1.UploadBlobResponse
Upload a single chunk of a file
Auth: connector-id and api-key sent in gRPC metadata headers
Upload a single chunk of a file
Auth: connector-id and api-key sent in gRPC metadata headers
Response from uploading a single chunk
Response from uploading a single chunk
Request to upload a fully-formed PipeDoc.
Request to upload a fully-formed PipeDoc.
Response from document upload operations.
Response from document upload operations.
Final result of a completed upload
Final result of a completed upload
Request to validate an API key.
Request to validate an API key.
Response from API key validation.
Response from API key validation.