Crate re_redap_client 

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.

ConnectionClient

Thin wrapper around GenericConnectionClient<crate::grpc::RedapClientInner> that additionally exposes the underlying layered tower service.

ConnectionRegistry

ConnectionRegistryHandle

Registry of all tokens and connections to the redap servers.

GenericConnectionClient

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.

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.

Enums

ApiErrorKind

ClientCredentialsError

Possible errors when creating a connection.

CredentialSource

Credentials

Constants

FETCH_CHUNKS_DEADLINE

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

Functions

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

Canonical way to ingest segment data from a catalog server, dealing with server-stored blueprints if any.

with_retry

Helper function for executing requests or connection attempts with retries.

Type Aliases

ApiResult

Convenience for Result<T, ApiError>

ChunksWithSegment

Converts a FetchChunksStream stream into a stream of Chunks.

FetchChunksResponseStream

RedapClient

RedapClientInner