Skip to main content

Crate buffer

Crate buffer 

Source

Structs§

BatchDescriptor
Lightweight pointer to one manifest entry. Carries everything a caller needs to fetch the corresponding data batch from object storage without re-reading the manifest.
ConsumedBatch
A batch of entries read from object storage by the Consumer.
Consumer
Reads batches of ingested entries from object storage via a queue consumer.
ConsumerConfig
Configuration for a Consumer.
ConsumerFetchHandle
Cloneable, concurrency-safe handle for fetching data batches from object storage given a BatchDescriptor.
DurabilityWatcher
ManifestEntry
A single entry in the manifest.
ManifestView
Read-only view of a parsed buffer queue manifest.
Metadata
Per-range metadata attached to a batch by the buffer.
Producer
ProducerConfig
Configuration for a Producer.
WriteHandle

Enums§

CompressionType
Compression algorithm applied to the record block of a data batch.
Error

Functions§

parse_manifest
Parse a manifest from its binary representation.

Type Aliases§

Result