A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
Loading...
Searching...
No Matches
stores Directory Reference
Directory dependency graph for stores:

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