List of all items

Structs

• compute::BackendCapabilities
• compute::ModelArtifact
• compute::ModelMetadata
• edge::EdgeOccupancy
• edge::NoQueue
• edge::bench::TestSpscRingBuf
• edge::link::EdgeDescriptor
• edge::link::EdgeLink
• edge::spsc_array::StaticRing
• edge::spsc_concurrent::ConcurrentEdge
• edge::spsc_priority2::Priority2
• edge::spsc_raw::SpscAtomicRing
• edge::spsc_vecdeque::HeapRing
• errors::InferenceError
• errors::NodeError
• graph::bench::TestPipeline
• graph::bench::concurrent_graph::TestPipelineStd
• graph::validate::GraphDescBuf
• memory::BufferDescriptor
• memory::PlacementAcceptance
• memory::concurrent_manager::ConcurrentHeaderGuard
• memory::concurrent_manager::ConcurrentMemoryManager
• memory::concurrent_manager::ConcurrentReadGuard
• memory::concurrent_manager::ConcurrentWriteGuard
• memory::heap_manager::HeapMemoryManager
• memory::static_manager::StaticMemoryManager
• message::Message
• message::MessageFlags
• message::MessageHeader
• message::batch::Batch
• message::batch::BatchMessageIter
• message::tensor::Tensor
• node::NodeCapabilities
• node::OutStepContext
• node::StepContext
• node::bench::TestCounterSourceTensor
• node::bench::TestSinkNodeTensor
• node::bench::TestTensorBackend
• node::bench::TestTensorModel
• node::link::NodeDescriptor
• node::link::NodeLink
• node::model::InferenceModel
• node::sink::SinkNode
• node::source::IngressEdgeLink
• node::source::NoProbe
• node::source::SourceIngressEdge
• node::source::SourceNode
• node::source::probe::ConcurrentIngressEdgeLink
• node::source::probe::SourceIngressProbe
• node::source::probe::SourceIngressProbeEdge
• node::source::probe::SourceIngressUpdater
• platform::NoopClock
• platform::Span
• platform::linux::NoStdLinuxMonotonicClock
• platform::linux::StdLinuxMonotonicClock
• policy::BatchingPolicy
• policy::BudgetPolicy
• policy::DeadlinePolicy
• policy::EdgePolicy
• policy::NodePolicy
• policy::QueueCaps
• policy::SlidingWindow
• runtime::RuntimeStopHandle
• runtime::bench::TestNoStdRuntime
• runtime::bench::concurrent_runtime::SimpleBackoffScheduler
• runtime::bench::concurrent_runtime::TestScopedRuntime
• scheduling::NodeSummary
• scheduling::WorkerState
• telemetry::EdgeMetrics
• telemetry::EdgeSnapshotTelemetry
• telemetry::GraphMetrics
• telemetry::NodeMetrics
• telemetry::NodeStepTelemetry
• telemetry::NoopTelemetry
• telemetry::RuntimeTelemetryEvent
• telemetry::TelemetryKey
• telemetry::concurrent::TelemetryCore
• telemetry::concurrent::TelemetryCoreHandle
• telemetry::concurrent::TelemetrySender
• telemetry::event_message::EventMessage
• telemetry::graph_telemetry::GraphTelemetry
• telemetry::sink::FixedBuffer
• telemetry::sink::FmtLineWriter
• telemetry::sink::IoLineWriter
• types::BF16
• types::DeadlineNs
• types::EdgeIndex
• types::F16
• types::MessageToken
• types::NodeIndex
• types::PortId
• types::PortIndex
• types::SequenceNumber
• types::Ticks
• types::TraceId

Enums

• edge::EdgeHandleKind
• edge::EnqueueResult
• errors::GraphError
• errors::InferenceErrorKind
• errors::MemoryError
• errors::NodeErrorKind
• errors::OutputError
• errors::QueueError
• errors::RuntimeError
• errors::RuntimeErrorKind
• errors::RuntimeInvariantError
• errors::SchedulerError
• errors::SensorError
• memory::MemoryClass
• memory::PlacementDecision
• message::batch::BatchView
• node::NodeKind
• node::ProcessResult
• node::StepResult
• policy::AdmissionDecision
• policy::AdmissionPolicy
• policy::OverBudgetAction
• policy::WatermarkState
• policy::WindowKind
• scheduling::Readiness
• scheduling::WorkerDecision
• telemetry::NodeStepError
• telemetry::RuntimeTelemetryEventKind
• telemetry::TelemetryEvent
• telemetry::TelemetryKind
• telemetry::TelemetryNs
• telemetry::sink::TelemetrySinkError
• types::DataType
• types::QoSClass

Traits

• compute::ComputeBackend
• compute::ComputeModel
• edge::Edge
• edge::ScopedEdge
• graph::GraphApi
• graph::GraphEdgeAccess
• graph::GraphNodeAccess
• graph::GraphNodeContextBuilder
• graph::GraphNodeTypes
• graph::ScopedGraphApi
• graph::validate::GraphValidator
• memory::header_store::HeaderStore
• memory::manager::MemoryManager
• memory::manager::ScopedManager
• message::payload::Payload
• node::Node
• node::sink::Sink
• node::source::IngressProbe
• node::source::Source
• platform::Affinity
• platform::PlatformClock
• platform::Timers
• runtime::LimenRuntime
• scheduling::DequeuePolicy
• scheduling::WorkerScheduler
• telemetry::Telemetry
• telemetry::sink::TelemetrySink
• types::DType

Macros

• event_message
• run_edge_contract_tests
• run_node_contract_tests

Functions

• edge::contract_tests::run_admission_drop_newest_between_soft_and_hard
• edge::contract_tests::run_admission_evict_until_below_hard
• edge::contract_tests::run_admission_item_bytes_and_deadline_semantics
• edge::contract_tests::run_admission_policies
• edge::contract_tests::run_all_tests
• edge::contract_tests::run_basic_push_pop
• edge::contract_tests::run_batch_default_one
• edge::contract_tests::run_batch_delta_t
• edge::contract_tests::run_batch_fixed_and_delta
• edge::contract_tests::run_batch_fixed_n
• edge::contract_tests::run_batch_sliding
• edge::contract_tests::run_byte_tracking_roundtrip
• edge::contract_tests::run_evict_until_below_hard_caller_pattern
• edge::contract_tests::run_fifo_order
• edge::contract_tests::run_get_admission_decision_is_pure
• edge::contract_tests::run_occupancy_and_empty
• edge::contract_tests::run_try_peek_at
• edge::contract_tests::run_try_push_never_evicts
• graph::validate::validate_acyclic_alloc
• graph::validate::validate_acyclic_buf
• graph::validate::validate_ports
• memory::decide_placement
• message::tensor::create_test_tensor_filled_with
• message::tensor::create_test_tensor_from_array
• node::contract_tests::run_initialize_start_stop_roundtrip
• node::contract_tests::run_model_batching_tests
• node::contract_tests::run_process_message_enqueues_and_made_progress
• node::contract_tests::run_push_output_drop_oldest_evicts_oldest_once
• node::contract_tests::run_push_output_evict_until_below_hard_no_double_eviction
• node::contract_tests::run_push_output_no_token_leak_on_backpressure
• node::contract_tests::run_sink_specific_tests
• node::contract_tests::run_source_specific_tests
• node::contract_tests::run_step_batch_fixed_n_disjoint
• node::contract_tests::run_step_batch_fixed_n_max_delta_t_tests
• node::contract_tests::run_step_batch_sliding_window
• node::contract_tests::run_step_maps_backpressure_and_errors
• node::contract_tests::run_step_on_empty_returns_noinput
• node::contract_tests::run_step_pops_and_calls_process_message
• node::source::probe::new_probe_edge_pair
• node::source::probe::new_probe_pair
• telemetry::concurrent::new_telemetry_pair
• telemetry::concurrent::spawn_telemetry_core
• telemetry::graph_telemetry::merge_fixed_telemetry
• telemetry::sink::fixed_buffer_line_writer
• telemetry::sink::fmt_event
• telemetry::sink::write_u64

Type Aliases

• graph::EdgeOccupancyBuf
• message::tensor::TestTensor
• node::bench::TestIdentityModelNodeTensor
• node::source::IngressProbeImpl
• telemetry::GraphInstanceId

Constants

• message::tensor::TEST_TENSOR_BYTE_COUNT
• message::tensor::TEST_TENSOR_ELEMENT_COUNT
• message::tensor::TEST_TENSOR_SHAPE
• node::source::EXTERNAL_INGRESS_NODE