|
A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
|
Files | |
| chunk_store.h | |
| A11's pluggable storage interface for streamed node data: an ordered, appendable log of fragments keyed by sequence number and arrival order. | |
| chunk_store_reader.cc | |
| chunk_store_reader.h | |
| A read cursor over a ChunkStore that pulls fragments out in order (or by arrival), buffering ahead per its options. | |
| chunk_store_writer.cc | |
| chunk_store_writer.h | |
| A write cursor over a ChunkStore that admits chunks into the store in sequence, applying backpressure and optionally mirroring to wire streams. | |
| local_chunk_store.cc | |
| local_chunk_store.h | |
| The default in-memory ChunkStore implementation, whose state and synchronization live in C++. | |
| redis_chunk_store.cc | |
| redis_chunk_store.h | |
| A Redis Streams implementation of the ChunkStore contract. | |
| redis_chunk_store_script.h | |