Crate rstreams

Modules

actor

Execute streams in asynchronous Tokio tasks.

error

join

Merge streams into one based on timeframes.

store

Key-Value store

table

Changelog stream

window

Divide stream into time based segments.

Structs

ParsedMessage

Traits

Dated

Functions

erase_stream_type

from_bytes

to_bytes

within_window