List of all items
Structs
- operator::state::reaper::DrainOutcome
- operator::state::reaper::GroupDrain
- operator::state::reaper::Queued
- operator::state::reaper::StoreReaper
- operator::state::reclaim::ReclaimOutcome
- operator::state::seal::gate::EvictionGate
- operator::state::seal::gate::SealGate
- operator::state::seal::ledger::FiredAt
- operator::state::seal::ledger::SealLedger
- operator::state::seal::ledger::SealLedgerState
- operator::state::seal::rule::AdmissibleSpan
- operator::state::seal::rule::EvictionInstant
- operator::state::seal::rule::EvictionRule
- operator::state::seal::rule::SealInstant
- operator::state::seal::rule::SealRule
- operator::state::seal::rule::SealedThrough
- operator::state::seal::sweep::SealSweep
- timer::Timer
- timer::TimerDue
- window::accumulator::invertible::keyed::KeyedInvertibleAccumulator
- window::accumulator::invertible::last_value::LastValue
- window::accumulator::invertible::moments::Moments
- window::accumulator::invertible::multiset::Multiset
- window::accumulator::invertible::ordf64::OrdF64
- window::accumulator::invertible::retained_map::RetainedAccumulator
- window::accumulator::invertible::retained_map::RetainedMap
- window::accumulator::sealing::base::SealingBase
- window::accumulator::sealing::endpoint::SealingEndpoint
- window::accumulator::sealing::fold::SealingFold
- window::accumulator::sealing::max::SealingMax
- window::accumulator::sealing::min::SealingMin
- window::accumulator::sealing::tail::SealingTail
- window::accumulator::sealing::tail::TailAccumulator
- window::coord::EventCoord
- window::coord::OrdinalCoord
- window::coord::RowSpan
- window::engine::BufferKey
- window::engine::EmitKey
- window::engine::GroupMeta
- window::engine::MetaKey
- window::engine::RunningKey
- window::engine::WindowResult
- window::engine::WindowStateKey
- window::engine::config::TumblingCarryConfig
- window::engine::config::TumblingCarryConfigBuilder
- window::engine::config::WindowEngineConfig
- window::engine::config::WindowEngineConfigBuilder
- window::engine::rolling::RollingEngine
- window::engine::rolling::RollingIndexEntry
- window::engine::rolling::RollingResult
- window::engine::rolling_incremental::RollingIncrementalEngine
- window::engine::rolling_top_k::RollingTopKEngine
- window::engine::tumbling::ExpiredWindow
- window::engine::tumbling::TumblingEngine
- window::engine::tumbling::TumblingIndexEntry
- window::engine::tumbling_carry::CarryMeta
- window::engine::tumbling_carry::TumblingCarryEngine
- window::engine::tumbling_carry::WindowEntry
- window::kind::rolling::RollingOverRows
- window::kind::rolling::RollingOverTime
- window::kind::session::SessionKind
- window::kind::session::SessionTracker
- window::kind::sliding::SlidingOverRows
- window::kind::sliding::SlidingOverTime
- window::kind::tumbling::TumblingOverRows
- window::meta::CountKey
- window::meta::CountState
- window::meta::EngineMeta
- window::meta::EngineMetaKey
- window::meta::RollingMeta
- window::meta::RollingMetaKey
- window::meta::RowIndexKey
- window::meta::RowIndexState
- window::meta::SealLedgerKey
- window::meta::SessionKey
- window::meta::SessionState
- window::meta::WindowMeta
- window::mint::Mint
- window::span::WindowSpan
Enums
- window::engine::AccumulatorEvent
- window::engine::EmitKind
- window::engine::ExpiryAnchor
- window::engine::KeyspaceFamily
- window::engine::rolling::RollingEviction
- window::engine::rolling::RollingExpiry
- window::engine::rolling_top_k::TopKEmit
- window::kind::session::SessionAssignment
Traits
- operator::state::reaper::IdentityReclaim
- operator::state::reaper::Reaper
- operator::state::seal::coord::Coord
- operator::state::seal::coord::IsZero
- operator::state::seal::domain::SealDomain
- window::accumulator::WindowAccumulator
- window::accumulator::sealing::fold::SealFold
- window::coord::TimeStamped
- window::span::Slot
- window::span::WindowAnchor
Functions
- factory::coord::event_coord_at_millis
- operator::max_input_time
- operator::scale_from_millis
- operator::state::reaper::drain
- operator::state::reaper::drain_group
- operator::state::reaper::enqueue
- operator::state::reaper::queue_key
- operator::state::reaper::queued
- operator::state::reaper::reap_group
- operator::state::seal::gate::rearm_seal
- operator::state::seal::ledger::seal_ledger_key
- operator::state::seal::rule::is_sealed
- operator::state::seal::rule::seal_horizon
- operator::state_access::get
- operator::state_access::get_classified
- operator::state_access::get_or_default
- operator::state_access::mint_row_numbers
- operator::state_access::modify
- operator::state_access::put
- operator::state_access::remove
- operator::state_access::set
- operator::state_access::update
- window::engine::meta_key_for
- window::kind::ordinal_window_span
Type Aliases
- window::engine::rolling::RollingBuckets
- window::engine::rolling::RollingBuffer
- window::engine::rolling_top_k::RollingTopKBuffer
- window::engine::rolling_top_k::RollingTopKEmit
- window::engine::tumbling::TumblingBuckets
- window::span::SlotCoord
- window::span::SlotSpan