List of all items

Structs

• alloc::AllocationStats
• alloc::HotPathGuard
• alloc::ObjectPool
• alloc::RingBuffer
• alloc::ScratchBuffer
• budget::BudgetAlert
• budget::BudgetMetrics
• budget::BudgetMetricsSnapshot
• budget::BudgetMonitor
• budget::TaskBudget
• budget::TaskStats
• budget::ViolationWindow
• dag::builder::DagBuilder
• dag::builder::FanOutBuilder
• dag::changelog::DagChangelogPropagator
• dag::checkpoint::BarrierAligner
• dag::checkpoint::CheckpointBarrier
• dag::checkpoint::DagCheckpointConfig
• dag::checkpoint::DagCheckpointCoordinator
• dag::executor::DagExecutor
• dag::executor::DagExecutorMetrics
• dag::multicast::MulticastBuffer
• dag::recovery::DagCheckpointSnapshot
• dag::recovery::DagRecoveryManager
• dag::recovery::RecoveredDagState
• dag::recovery::SerializableOperatorState
• dag::routing::RoutingEntry
• dag::routing::RoutingTable
• dag::topology::DagEdge
• dag::topology::DagNode
• dag::topology::EdgeId
• dag::topology::NodeId
• dag::topology::SharedStageMetadata
• dag::topology::StatePartitionId
• dag::topology::StreamingDag
• dag::watermark::DagWatermarkCheckpoint
• dag::watermark::DagWatermarkTracker
• detect::CpuFeatures
• detect::IoUringCapabilities
• detect::KernelVersion
• detect::MemoryInfo
• detect::RecommendedConfig
• detect::StorageInfo
• detect::SystemCapabilities
• detect::XdpCapabilities
• io_uring::IoUringConfig
• io_uring::IoUringConfigBuilder
• mv::MaterializedView
• mv::MvPipelineCheckpoint
• mv::MvPipelineExecutor
• mv::MvRegistry
• mv::PassThroughOperator
• mv::PipelineMetrics
• mv::watermark::CascadingWatermarkTracker
• mv::watermark::WatermarkTrackerCheckpoint
• numa::NumaAllocator
• numa::NumaTopology
• operator::Event
• operator::OperatorContext
• operator::OperatorState
• operator::Timer
• operator::asof_join::AsofJoinConfig
• operator::asof_join::AsofJoinConfigBuilder
• operator::asof_join::AsofJoinMetrics
• operator::asof_join::AsofJoinOperator
• operator::asof_join::AsofRow
• operator::asof_join::KeyState
• operator::changelog::ArchivedRetractableAvgAccumulator
• operator::changelog::ArchivedRetractableCountAccumulator
• operator::changelog::ArchivedRetractableSumAccumulator
• operator::changelog::CdcEnvelope
• operator::changelog::CdcSource
• operator::changelog::ChangelogBuffer
• operator::changelog::ChangelogRef
• operator::changelog::LateDataRetractionGenerator
• operator::changelog::RetractableAvgAccumulator
• operator::changelog::RetractableAvgAccumulatorResolver
• operator::changelog::RetractableCountAccumulator
• operator::changelog::RetractableCountAccumulatorResolver
• operator::changelog::RetractableFirstValueAccumulator
• operator::changelog::RetractableFirstValueF64Accumulator
• operator::changelog::RetractableLastValueAccumulator
• operator::changelog::RetractableLastValueF64Accumulator
• operator::changelog::RetractableMaxAccumulator
• operator::changelog::RetractableMinAccumulator
• operator::changelog::RetractableSumAccumulator
• operator::changelog::RetractableSumAccumulatorResolver
• operator::lag_lead::LagLeadConfig
• operator::lag_lead::LagLeadFunctionSpec
• operator::lag_lead::LagLeadMetrics
• operator::lag_lead::LagLeadOperator
• operator::lookup_join::ArchivedCacheEntry
• operator::lookup_join::CacheEntry
• operator::lookup_join::CacheEntryResolver
• operator::lookup_join::LookupJoinConfig
• operator::lookup_join::LookupJoinConfigBuilder
• operator::lookup_join::LookupJoinMetrics
• operator::lookup_join::LookupJoinOperator
• operator::partitioned_topk::PartitionColumn
• operator::partitioned_topk::PartitionedTopKOperator
• operator::session_window::ArchivedSessionState
• operator::session_window::SessionMetrics
• operator::session_window::SessionState
• operator::session_window::SessionStateResolver
• operator::session_window::SessionWindowOperator
• operator::sliding_window::SlidingWindowAssigner
• operator::sliding_window::SlidingWindowOperator
• operator::stream_join::ArchivedJoinRow
• operator::stream_join::JoinMetrics
• operator::stream_join::JoinRow
• operator::stream_join::JoinRowResolver
• operator::stream_join::KeyMetadata
• operator::stream_join::SideStats
• operator::stream_join::StreamJoinConfig
• operator::stream_join::StreamJoinConfigBuilder
• operator::stream_join::StreamJoinOperator
• operator::temporal_join::ArchivedJoinedEventRecord
• operator::temporal_join::ArchivedTableRow
• operator::temporal_join::JoinedEventRecord
• operator::temporal_join::JoinedEventRecordResolver
• operator::temporal_join::TableRow
• operator::temporal_join::TableRowResolver
• operator::temporal_join::TemporalJoinConfig
• operator::temporal_join::TemporalJoinConfigBuilder
• operator::temporal_join::TemporalJoinMetrics
• operator::temporal_join::TemporalJoinOperator
• operator::temporal_join::VersionedKeyState
• operator::topk::StreamingTopKOperator
• operator::topk::TopKSortColumn
• operator::watermark_sort::WatermarkBoundedSortOperator
• operator::window::ArchivedAvgAccumulator
• operator::window::ArchivedCountAccumulator
• operator::window::ArchivedFirstValueAccumulator
• operator::window::ArchivedFirstValueF64Accumulator
• operator::window::ArchivedLastValueAccumulator
• operator::window::ArchivedLastValueF64Accumulator
• operator::window::ArchivedMaxAccumulator
• operator::window::ArchivedMinAccumulator
• operator::window::ArchivedSumAccumulator
• operator::window::ArchivedWindowId
• operator::window::AvgAccumulator
• operator::window::AvgAccumulatorResolver
• operator::window::AvgAggregator
• operator::window::AvgF64Factory
• operator::window::AvgF64IndexedAccumulator
• operator::window::ChangelogRecord
• operator::window::CompositeAccumulator
• operator::window::CompositeAggregator
• operator::window::CountAccumulator
• operator::window::CountAccumulatorResolver
• operator::window::CountAggregator
• operator::window::CountDynAccumulator
• operator::window::CountDynFactory
• operator::window::FirstValueAccumulator
• operator::window::FirstValueAccumulatorResolver
• operator::window::FirstValueAggregator
• operator::window::FirstValueF64Accumulator
• operator::window::FirstValueF64AccumulatorResolver
• operator::window::FirstValueF64Aggregator
• operator::window::FirstValueF64DynAccumulator
• operator::window::FirstValueF64DynFactory
• operator::window::LastValueAccumulator
• operator::window::LastValueAccumulatorResolver
• operator::window::LastValueAggregator
• operator::window::LastValueF64Accumulator
• operator::window::LastValueF64AccumulatorResolver
• operator::window::LastValueF64Aggregator
• operator::window::LastValueF64DynAccumulator
• operator::window::LastValueF64DynFactory
• operator::window::LateDataConfig
• operator::window::LateDataMetrics
• operator::window::MaxAccumulator
• operator::window::MaxAccumulatorResolver
• operator::window::MaxAggregator
• operator::window::MaxF64Factory
• operator::window::MaxF64IndexedAccumulator
• operator::window::MinAccumulator
• operator::window::MinAccumulatorResolver
• operator::window::MinAggregator
• operator::window::MinF64Factory
• operator::window::MinF64IndexedAccumulator
• operator::window::SumAccumulator
• operator::window::SumAccumulatorResolver
• operator::window::SumAggregator
• operator::window::SumF64Accumulator
• operator::window::SumF64Aggregator
• operator::window::SumF64Factory
• operator::window::SumF64IndexedAccumulator
• operator::window::TumblingWindowAssigner
• operator::window::TumblingWindowOperator
• operator::window::WindowId
• operator::window::WindowIdResolver
• operator::window_sort::WindowLocalSortOperator
• reactor::BufferingSink
• reactor::Reactor
• reactor::ReactorConfig
• reactor::StdoutSink
• sink::AdapterConfig
• sink::AdapterStats
• sink::ExactlyOnceSinkAdapter
• sink::IdempotentSink
• sink::InMemoryDedup
• sink::ParticipantState
• sink::RecordId
• sink::SinkCapabilities
• sink::SinkCheckpoint
• sink::SinkCheckpointManager
• sink::TransactionCoordinator
• sink::TransactionId
• sink::TransactionLog
• sink::TransactionLogEntry
• sink::TransactionRecord
• sink::TransactionState
• sink::TransactionalSink
• sink::TransactionalSinkConfig
• sink::TransactionalSinkStats
• sink::TwoPhaseConfig
• sink::TwoPhaseCoordinator
• state::ArchivedStateSnapshot
• state::InMemoryStore
• state::MmapStateStore
• state::StateSnapshot
• state::StateSnapshotResolver
• streaming::broadcast::BroadcastChannel
• streaming::broadcast::BroadcastConfig
• streaming::broadcast::BroadcastConfigBuilder
• streaming::broadcast::SubscriberInfo
• streaming::channel::Consumer
• streaming::channel::Producer
• streaming::checkpoint::StreamChangelogBuffer
• streaming::checkpoint::StreamChangelogEntry
• streaming::checkpoint::StreamCheckpoint
• streaming::checkpoint::StreamCheckpointConfig
• streaming::checkpoint::StreamCheckpointManager
• streaming::config::ChannelConfig
• streaming::config::ChannelConfigBuilder
• streaming::config::ChannelStats
• streaming::config::SinkConfig
• streaming::config::SourceConfig
• streaming::error::TryPushError
• streaming::ring_buffer::RingBuffer
• streaming::sink::Sink
• streaming::source::Source
• streaming::subscription::Subscription
• subscription::BackpressureController
• subscription::BatchConfig
• subscription::CallbackSubscriptionHandle
• subscription::ChangeEventBatch
• subscription::ChangeEventResultStream
• subscription::ChangeEventStream
• subscription::DemandBackpressure
• subscription::DemandHandle
• subscription::DispatcherConfig
• subscription::DispatcherMetrics
• subscription::NotificationBatcher
• subscription::NotificationHub
• subscription::NotificationRef
• subscription::NotificationRing
• subscription::NotificationSlot
• subscription::PushSubscription
• subscription::StringInternTable
• subscription::SubscriptionConfig
• subscription::SubscriptionDispatcher
• subscription::SubscriptionEntry
• subscription::SubscriptionFilter
• subscription::SubscriptionId
• subscription::SubscriptionMetrics
• subscription::SubscriptionRegistry
• time::AlignmentGroupConfig
• time::AlignmentGroupCoordinator
• time::AlignmentGroupId
• time::AlignmentGroupMetrics
• time::AlignmentSourceState
• time::AscendingTimestampsGenerator
• time::BoundedOutOfOrdernessGenerator
• time::CoreWatermarkState
• time::EventTimeExtractor
• time::GlobalWatermarkCollector
• time::KeyWatermarkState
• time::KeyedWatermarkConfig
• time::KeyedWatermarkMetrics
• time::KeyedWatermarkTracker
• time::KeyedWatermarkTrackerWithLateHandling
• time::MeteredGenerator
• time::PartitionId
• time::PartitionWatermarkState
• time::PartitionedWatermarkMetrics
• time::PartitionedWatermarkTracker
• time::PeriodicGenerator
• time::PunctuatedGenerator
• time::SourceProvidedGenerator
• time::TimerRegistration
• time::TimerService
• time::Watermark
• time::WatermarkAlignmentGroup
• time::WatermarkMetrics
• time::WatermarkTracker
• tpc::BackpressureConfig
• tpc::BackpressureConfigBuilder
• tpc::CachePadded
• tpc::CoreConfig
• tpc::CoreHandle
• tpc::CreditChannel
• tpc::CreditGate
• tpc::CreditMetrics
• tpc::CreditMetricsSnapshot
• tpc::CreditReceiver
• tpc::CreditSender
• tpc::KeyRouter
• tpc::OutputBuffer
• tpc::SpscQueue
• tpc::ThreadPerCoreRuntime
• tpc::TpcConfig
• tpc::TpcConfigBuilder
• xdp::LaminarHeader
• xdp::XdpConfig
• xdp::XdpLoader
• xdp::XdpStats

Enums

• Error
• budget::YieldReason
• dag::checkpoint::AlignmentResult
• dag::checkpoint::BarrierType
• dag::error::DagError
• dag::topology::DagChannelType
• dag::topology::DagNodeType
• dag::topology::PartitioningStrategy
• detect::PerformanceTier
• detect::Platform
• detect::SimdLevel
• detect::StorageType
• io_uring::IoUringError
• io_uring::RingMode
• mv::MvError
• mv::MvState
• numa::NumaError
• numa::NumaPlacement
• operator::OperatorError
• operator::Output
• operator::asof_join::AsofDirection
• operator::asof_join::AsofJoinType
• operator::lookup_join::LookupJoinType
• operator::lookup_join::SyncLookupResult
• operator::stream_join::JoinRowEncoding
• operator::stream_join::JoinSide
• operator::stream_join::JoinType
• operator::temporal_join::TableChange
• operator::temporal_join::TableCharacteristics
• operator::temporal_join::TemporalJoinSemantics
• operator::temporal_join::TemporalJoinType
• operator::topk::TopKEmitStrategy
• operator::window::ArchivedCdcOperation
• operator::window::CdcOperation
• operator::window::CdcOperationResolver
• operator::window::EmitStrategy
• operator::window::ScalarResult
• reactor::ReactorError
• reactor::SinkError
• sink::CoordinatorDecision
• sink::ParticipantVote
• sink::SinkError
• sink::SinkOffset
• sink::SinkState
• sink::TwoPhaseResult
• state::StateError
• streaming::broadcast::BroadcastError
• streaming::broadcast::SlowSubscriberPolicy
• streaming::channel::ChannelMode
• streaming::checkpoint::CheckpointError
• streaming::checkpoint::OverflowPolicy
• streaming::checkpoint::StreamChangeOp
• streaming::checkpoint::WalMode
• streaming::config::BackpressureStrategy
• streaming::config::WaitStrategy
• streaming::error::RecvError
• streaming::error::StreamingError
• streaming::sink::SinkMode
• streaming::subscription::SubscriptionMessage
• subscription::BackpressureStrategy
• subscription::ChangeEvent
• subscription::EventType
• subscription::FilterCompileError
• subscription::PushSubscriptionError
• subscription::Ring0Predicate
• subscription::Ring1Predicate
• subscription::ScalarValue
• subscription::SubscriptionState
• time::AlignmentAction
• time::AlignmentError
• time::EnforcementMode
• time::EventTimeError
• time::ExtractionMode
• time::KeyEvictionPolicy
• time::KeyedWatermarkError
• time::TimeError
• time::TimestampField
• time::TimestampFormat
• time::WatermarkError
• tpc::CoreMessage
• tpc::CreditAcquireResult
• tpc::KeySpec
• tpc::OverflowStrategy
• tpc::RouterError
• tpc::TpcError
• xdp::XdpAction
• xdp::XdpAttachMode
• xdp::XdpError

Traits

• operator::Operator
• operator::changelog::RetractableAccumulator
• operator::window::Accumulator
• operator::window::Aggregator
• operator::window::DynAccumulator
• operator::window::DynAggregatorFactory
• operator::window::ResultToI64
• operator::window::WindowAssigner
• reactor::Sink
• sink::DeduplicationStore
• sink::ExactlyOnceSink
• sink::TwoPhaseCommitSink
• state::StateStore
• state::StateStoreExt
• streaming::source::Record
• subscription::NotificationDataSource
• subscription::SubscriptionCallback
• time::WatermarkGenerator

Macros

• hot_path

Functions

• detect::cache_line_size
• detect::is_smt_enabled
• detect::logical_cpu_count
• detect::physical_cpu_count
• io_uring::advanced_kernel_version
• io_uring::is_available
• io_uring::min_kernel_version
• operator::topk::encode_f64
• operator::topk::encode_i64
• operator::topk::encode_not_null
• operator::topk::encode_null
• operator::topk::encode_utf8
• streaming::channel::channel
• streaming::channel::channel_with_config
• streaming::source::create
• streaming::source::create_with_config
• subscription::compile_filter
• subscription::subscribe_callback
• subscription::subscribe_fn
• subscription::subscribe_stream
• subscription::subscribe_stream_with_errors

Type Aliases

• Result
• dag::checkpoint::CheckpointId
• dag::topology::PartitionFn
• numa::Result
• operator::OutputVec
• operator::TimerKey
• operator::window::WindowIdVec
• time::FiredTimersVec
• time::TimerKey

Constants

• dag::routing::MAX_PORTS
• dag::topology::MAX_FAN_OUT
• streaming::broadcast::DEFAULT_BROADCAST_CAPACITY
• streaming::broadcast::DEFAULT_LAG_WARNING_THRESHOLD
• streaming::broadcast::DEFAULT_MAX_SUBSCRIBERS
• streaming::broadcast::DEFAULT_SLOW_SUBSCRIBER_TIMEOUT
• streaming::config::DEFAULT_BUFFER_SIZE
• streaming::config::MAX_BUFFER_SIZE
• streaming::config::MIN_BUFFER_SIZE