All Classes and Interfaces
Class
Description
Utilities for API key generation and hashing.
Connector type definition (template/registry).
Connector type definition (template/registry).
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.
gRPC service implementation handling connector ingestion endpoints.
Utility class for parsing and serializing connector metadata JSON.
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 create a new datasource for an account.
Request to create a new datasource for an account.
Response from datasource creation.
Response from datasource creation.
DataSource represents an account's binding to a connector type.
DataSource represents an account's binding to a connector type.
Administrative operations for datasource lifecycle management.
Administrative operations for datasource lifecycle management.
A stub to allow clients to do limited synchronous rpc calls to service DataSourceAdminService.
A stub to allow clients to do synchronous rpc calls to service DataSourceAdminService.
A stub to allow clients to do ListenableFuture-style rpc calls to service DataSourceAdminService.
Base class for the server implementation of the service DataSourceAdminService.
A stub to allow clients to do asynchronous rpc calls to service DataSourceAdminService.
DataSource configuration returned after authentication.
DataSource configuration returned after authentication.
Request to delete a datasource.
Request to delete a datasource.
Response from datasource deletion.
Response from datasource 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 type details.
Request to get connector type details.
Response containing connector type details.
Response containing connector type details.
Request to get crawl history for a datasource.
Request to get crawl history for a datasource.
Response containing crawl history.
Response containing crawl history.
Request to get datasource details.
Request to get datasource details.
Response containing datasource details.
Response containing datasource details.
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 available connector types.
Request to list available connector types.
Response containing connector type list.
Response containing connector type list.
Request to list datasources.
Request to list datasources.
Response containing datasource list.
Response containing datasource list.
Management type for connectors.
High-throughput document ingestion service for all connector types.
High-throughput document ingestion service for all connector types.
Administrative operations for datasource lifecycle management.
Administrative operations for datasource lifecycle management.
Chunked document upload service for large files.
Chunked document upload service for large files.
Client for repository-service integration.
Request to rotate datasource API key.
Request to rotate datasource API key.
Response from API key rotation.
Response from API key rotation.
Service for managing crawl session lifecycle.
Request to enable or disable a datasource.
Request to enable or disable a datasource.
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 datasource configuration.
Request to update datasource configuration.
Response from datasource update.
Response from datasource 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.