risingwave_stream::common::log_store_impl

Module in_mem

Source

Structs§

BoundedInMemLogStoreFactory
BoundedInMemLogStoreReader
BoundedInMemLogStoreWriter
An in-memory log store that can buffer a bounded amount of stream chunk in memory via bounded mpsc channel.

Enums§

InMemLogStoreItem 🔒
LogReaderEpochProgress 🔒

Constants§

UNINITIALIZED 🔒