A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
Loading...
Searching...
No Matches
a11::stores::ChunkStoreWrite Struct Reference

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.
 

Detailed Description

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.

Member Data Documentation

◆ admitted

a11::Task a11::stores::ChunkStoreWrite::admitted

Resolves once the chunk is admitted into the bounded queue (backpressure).

◆ confirmation

a11::Future<std::uint32_t> a11::stores::ChunkStoreWrite::confirmation

Resolves with the assigned sequence once the backing store accepts it.


The documentation for this struct was generated from the following file: