List of all items

Structs

• Event
• aggregation::Aggregator
• aggregation::Avg
• aggregation::Count
• aggregation::CountDistinct
• aggregation::Ema
• aggregation::ExprAggregate
• aggregation::First
• aggregation::Last
• aggregation::Max
• aggregation::Median
• aggregation::Min
• aggregation::P50
• aggregation::P95
• aggregation::P99
• aggregation::Percentile
• aggregation::StdDev
• aggregation::Sum
• backpressure::StageBuffer
• backpressure::StageBufferConfig
• backpressure::StageBufferMetrics
• circuit_breaker::CircuitBreaker
• circuit_breaker::CircuitBreakerConfig
• columnar::ColumnarBuffer
• columnar::ColumnarCheckpoint
• context::CheckpointAck
• context::CheckpointBarrier
• context::CheckpointCoordinator
• context::ContextConfig
• context::ContextMap
• context::ContextOrchestrator
• context::ContextRuntime
• context::EventTypeRouter
• converter::csv::CsvConverter
• converter::json::JsonConverter
• engine::Engine
• engine::EngineBuilder
• engine::EngineConfig
• engine::EngineMetrics
• engine::NamedPattern
• engine::ReloadReport
• engine::SinkConnectorAdapter
• engine::SourceBinding
• engine::UserFunction
• engine::compiler::DerivedStreamInfo
• engine::evaluator::EvalContext
• engine::evaluator::RuntimeExprEvaluator
• engine::topology::NodeMetrics
• engine::topology::Topology
• engine::topology::TopologyEdge
• engine::topology::TopologyNode
• engine::topology_builder::TopologyBuilder
• event::Event
• event::HVACStatus
• event::HumidityReading
• event::TemperatureReading
• event_file::EventFile
• event_file::EventFileParser
• event_file::EventFilePlayer
• event_file::StreamingEventReader
• event_file::TimedEvent
• greta::EventGraph
• greta::EventNode
• greta::GretaExecutor
• greta::GretaQuery
• health::ComponentHealth
• health::ConnectorHealthAdapter
• health::EngineHealthReporter
• health::HealthRegistry
• health::SystemHealth
• join::JoinBuffer
• join::JoinBufferStats
• metrics::Metrics
• metrics::MetricsServer
• persistence::Checkpoint
• persistence::CheckpointConfig
• persistence::CheckpointManager
• persistence::DistinctCheckpoint
• persistence::EngineCheckpoint
• persistence::FileStore
• persistence::JoinCheckpoint
• persistence::LimitCheckpoint
• persistence::MemoryStore
• persistence::PartialMatchCheckpoint
• persistence::PartitionedWindowCheckpoint
• persistence::PatternCheckpoint
• persistence::RunCheckpoint
• persistence::SaseCheckpoint
• persistence::SerializableEvent
• persistence::SourceWatermarkCheckpoint
• persistence::StackEntryCheckpoint
• persistence::WatermarkCheckpoint
• persistence::WindowCheckpoint
• scoring::GpuConfig
• scoring::OnnxModel
• sequence::ActiveCorrelation
• sequence::NegationCondition
• sequence::SequenceContext
• sequence::SequenceStep
• sequence::SequenceTracker
• simulator::HVACConfig
• simulator::Simulator
• simulator::SimulatorConfig
• simulator::ZoneConfig
• sink::AsyncFileSink
• sink::ConsoleSink
• sink::FileSink
• sink::HttpRetryConfig
• sink::HttpSink
• sink::HttpSinkWithRetry
• sink::MultiSink
• sink::ResilientSink
• sink::SinkConnectorAdapter
• stream::Stream
• stream::StreamSender
• tenant::Pipeline
• tenant::PipelineSnapshot
• tenant::Tenant
• tenant::TenantId
• tenant::TenantManager
• tenant::TenantQuota
• tenant::TenantSnapshot
• tenant::TenantUsage
• testing::SimulatedScheduler
• testing::TestUniverse
• timer::TimerManager
• udf::Signature
• udf::UdfRegistry
• udf::VariadicSpec
• vpl_test::OutputEvent
• vpl_test::VplTestFixture
• vpl_test::VplTestResult
• watermark::PerSourceWatermarkTracker
• window::CountWindow
• window::DelayBuffer
• window::IncrementalAggregates
• window::IncrementalSlidingWindow
• window::PartitionedDelayBuffer
• window::PartitionedPreviousValueTracker
• window::PartitionedSessionWindow
• window::PartitionedSlidingWindow
• window::PartitionedTumblingWindow
• window::PreviousValueTracker
• window::SessionWindow
• window::SlidingCountWindow
• window::SlidingWindow
• window::TumblingWindow
• worker_pool::PoolBackpressureError
• worker_pool::WorkerPool
• worker_pool::WorkerPoolConfig
• worker_pool::WorkerPoolMetrics
• worker_pool::WorkerStatus
• zdd_unified::aggregator::AggregatorComparison
• zdd_unified::aggregator::ZddAggregationResult
• zdd_unified::aggregator::ZddAggregator
• zdd_unified::aggregator::ZddAggregatorStats
• zdd_unified::aggregator::ZddConfig
• zdd_unified::aggregator::ZddQueryRegistration
• zdd_unified::nfa_zdd::NfaZdd
• zdd_unified::nfa_zdd::NfaZddBuilder
• zdd_unified::nfa_zdd::ZddState
• zdd_unified::nfa_zdd::ZddTransition
• zdd_unified::propagation::QueryAccumulator
• zdd_unified::propagation::ZddPropagator
• zdd_unified::propagation::ZddTraversal

Enums

• SinkError
• aggregation::AggBinOp
• backpressure::BackpressureError
• backpressure::WhenFull
• circuit_breaker::State
• codec::CheckpointFormat
• columnar::Column
• context::ContextMessage
• context::DispatchError
• converter::ConverterError
• engine::error::EngineError
• engine::evaluator::StmtResult
• engine::topology::EdgeType
• engine::topology::NodeType
• greta::GretaAggregate
• health::ComponentType
• health::HealthStatus
• persistence::SerializableValue
• persistence::StoreError
• scoring::GpuProvider
• sink::SinkError
• tenant::PipelineStatus
• tenant::TenantError
• udf::TypeConstraint
• vpl_test::TestValue
• worker_pool::BackpressureStrategy
• worker_pool::WorkerState
• zdd_unified::propagation::PropagationMode

Traits

• Sink
• aggregation::AggregateFunc
• columnar::ColumnarAccess
• converter::Converter
• health::HealthReporter
• persistence::StateStore
• sase_persistence::RunCheckpointExt
• sase_persistence::SaseCheckpointExt
• sink::Sink
• udf::Accumulator
• udf::AggregateUDF
• udf::ScalarUDF

Functions

• codec::deserialize
• codec::serialize
• context::filter_program_for_context
• context::verify_cpu_affinity
• converter::find_converter
• engine::compiler::compile_agg_expr
• engine::compiler::compile_agg_expr_with_udfs
• engine::compiler::compile_sase_pattern_expr
• engine::compiler::compile_to_sase_pattern_with_resolver
• engine::compiler::expr_to_sase_predicate
• engine::compiler::extract_event_types_from_pattern_expr
• engine::evaluator::call_user_function
• engine::evaluator::eval_binary_op
• engine::evaluator::eval_expr_ctx
• engine::evaluator::eval_expr_with_functions
• engine::evaluator::eval_expr_with_udfs
• engine::evaluator::eval_filter_expr
• engine::evaluator::eval_pattern_expr
• engine::evaluator::eval_stmt
• engine::evaluator::eval_stmts
• engine::evaluator::with_emit_collector
• engine::planner::logical_plan
• simulator::create_anomaly_simulator
• simulator::create_default_simulator
• simulator::create_degradation_simulator
• stream::channel
• tenant::hash_api_key
• tenant::shared_tenant_manager
• tenant::shared_tenant_manager_with_store
• timer::spawn_timer
• vpl_test::discover_fixtures
• vpl_test::parse_fixture
• vpl_test::parse_fixture_str
• vpl_test::run_all
• vpl_test::run_fixture

Type Aliases

• SharedEvent
• aggregation::AggResult
• engine::compiler::StreamResolver
• event::FieldKey
• event::FxIndexMap
• event::SharedEvent
• greta::GraphletId
• greta::NodeId
• greta::PatternId
• greta::QueryId
• sequence::SequenceFilter
• tenant::SharedTenantManager
• zdd_unified::nfa_zdd::ZddVar

Statics

• sequence::EMPTY_CONTEXT

Constants

• limits::MAX_ARRAY_ELEMENTS
• limits::MAX_EVENT_PAYLOAD_BYTES
• limits::MAX_FIELDS_PER_EVENT
• limits::MAX_JSON_DEPTH
• limits::MAX_LINE_LENGTH
• limits::MAX_STRING_VALUE_BYTES
• persistence::CHECKPOINT_VERSION