|
A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
|
The pair of awaitables returned when enqueuing a chunk, separating queue admission from backing-store confirmation. More...
#include <cpp/a11/stores/chunk_store_writer.h>
Public Attributes | |
| a11::Task | admitted |
| Resolves once the chunk is admitted into the bounded queue (backpressure). | |
| a11::Future< std::uint32_t > | confirmation |
| Resolves with the assigned sequence once the backing store accepts it. | |
The pair of awaitables returned when enqueuing a chunk, separating queue admission from backing-store confirmation.
The Python API distinguishes admission to the bounded native queue from backing-store confirmation. Native callers that only need confirmation can continue to use ChunkStoreWriter::PutChunk.
| a11::Task a11::stores::ChunkStoreWrite::admitted |
Resolves once the chunk is admitted into the bounded queue (backpressure).
| a11::Future<std::uint32_t> a11::stores::ChunkStoreWrite::confirmation |
Resolves with the assigned sequence once the backing store accepts it.