Crate re_redap_client

Expand description

Official gRPC client for the Rerun Data Protocol.

Structs§

ApiError
ApiResponseStream: A stream that optionally carries a server-assigned trace-id from the initial gRPC response metadata.
Connection: Connection capabilities for a redap origin.
ConnectionAnalyticsExporter: Analytics-side capability handed to re_datafusion.
ConnectionRegistry
ConnectionRegistryHandle: Registry of all tokens and connections to the redap servers.
PoolChannel: A pool of HTTP/2 connections to a single origin, dispatching each request to the least-loaded connection.
RedapClient: Expose an ergonomic API over the gRPC redap client.
SegmentChunkProvider: gRPC-backed ChunkProvider: serves the manifest of a single dataset segment and fetches its chunks on demand via FetchChunks.
SegmentDownload: Which parts of a segment to stream from the server.
SegmentQueryParams
SourcedCredentials
StreamingOptions: Options that control how segment data is streamed from the server.
TonicStatusError: Wrapper with a nicer error message
TraceId: Re-export of opentelemetry::TraceId for callers constructing ApiErrors without taking a direct dependency on opentelemetry. A 16-byte value which identifies a given trace.

FETCH_CHUNKS_DEADLINE: Per-call deadline for FetchChunks requests sent via this client.
MAX_DECODING_MESSAGE_SIZE

channel
extract_trace_id: Extract the server’s trace-id from gRPC response metadata, if present.
fetch_chunks_response_to_chunk_and_segment_id
stream_blueprint_and_segment_from_server: Stream a recording segment from a catalog server, including its registered default blueprint.
stream_table_blueprint_segment_from_server: Stream a registered .rbl blueprint segment into an existing log channel.
table_blueprint_log_channel: Create a log channel for streaming a table blueprint from a catalog server.
with_retry: Execute requests or connection attempts with retries, using the existing CONNECTION_RETRY_POLICY (retries any ApiErrorKind::is_retryable error).
with_retry_resource_exhausted: Execute an idempotent, fail-fast read with retries that fire only on ApiErrorKind::ResourcesExhausted, using RESOURCE_EXHAUSTED_RETRY_POLICY.

ApiResult: Convenience for Result<T, ApiError>
BoxedRedapClientStack
ChunksWithSegment: Converts a FetchChunksStream stream into a stream of Chunks.
ConnectionClient: Type alias for the boxed-transport RedapClient used in the viewer.
FetchChunksResponseStream
RedapClientStack