|
A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
|
A write cursor over a ChunkStore that admits chunks into the store in sequence, applying backpressure and optionally mirroring to wire streams. More...
#include <cstddef>#include <cstdint>#include <memory>#include <optional>#include <absl/status/status.h>#include <absl/status/statusor.h>#include "a11/concurrency/future.h"#include "a11/data/types.h"#include "a11/stores/chunk_store.h"Go to the source code of this file.
Classes | |
| struct | a11::stores::ChunkStoreWriterOptions |
| Tunables controlling how a ChunkStoreWriter batches and buffers chunks. More... | |
| struct | a11::stores::ChunkStoreWrite |
| The pair of awaitables returned when enqueuing a chunk, separating queue admission from backing-store confirmation. More... | |
| class | a11::stores::ChunkStoreWriter |
| A buffered, backpressured write cursor over a ChunkStore. More... | |
Namespaces | |
| namespace | a11 |
| namespace | a11::net |
| namespace | a11::stores |
A write cursor over a ChunkStore that admits chunks into the store in sequence, applying backpressure and optionally mirroring to wire streams.