List of all items

Structs

• config::ExecutorConfig
• config::GraphConfig
• config::GraphPlan
• config::GraphPlanDiagnostic
• config::GraphPlanEdge
• config::GraphPlanNode
• config::InputPolicyConfig
• config::InputQueueLimitConfig
• config::InputQueuesConfig
• config::NodeConfig
• config::PortSpec
• config::RouteConfig
• config::RouteRule
• config::SubgraphConfig
• context::Context
• context::Options
• executor::DelegatingExecutor
• executor::ThreadPool
• ffi::GraphSlot
• ffi::InputHandle
• ffi::KernelRunnerHandle
• ffi::LMFlowBuffer
• ffi::LMFlowContext
• ffi::LMFlowContract
• ffi::LMFlowGraph
• ffi::LMFlowInput
• ffi::LMFlowInputQueueStats
• ffi::LMFlowKernelRunner
• ffi::LMFlowKernelVTable
• ffi::LMFlowNodeStats
• ffi::LMFlowPacket
• ffi::LMFlowPoller
• graph::Graph
• graph::GraphInner
• graph::Input
• graph::InputQueueStatsSnapshot
• graph::NodeStatsSnapshot
• graph::Poller
• graph::PollerBackpressureStatsSnapshot
• graph::PollerOptions
• graph::WatermarkBackpressureStatsSnapshot
• kernel::Contract
• kernel::KernelInstance
• kernel::KernelReg
• kernel::KernelVTable
• kernel::PortTable
• kernel_api::KernelContract
• kernel_api::KernelCtx
• kernel_runner::KernelRunner
• metadata::MetadataCondition
• metadata::TimestampComparison
• packet::BufferData
• packet::Foreign
• packet::Packet
• packet::TypeDescriptor
• runtime::CStrArena
• runtime::GraphShared
• timestamp::Timestamp
• trace::TraceEvent
• trace::TraceRing

Enums

• config::RouteMode
• config::StatsLevel
• executor::Executor
• graph::DotView
• graph::OutputEvent
• graph::PollerOverflow
• graph::State
• kernel::KernelLanguage
• metadata::ComparisonOp
• metadata::MetadataPredicate
• metadata::MetadataValue
• packet::Builtin
• packet::Payload
• status::Error
• trace::TracePhase

Traits

• kernel_api::Kernel
• packet::InteropType

Functions

• config::parse_port_spec
• ffi::borrow_packet
• ffi::lmflow_abi_version
• ffi::lmflow_contract_input_id
• ffi::lmflow_contract_input_index
• ffi::lmflow_contract_input_name
• ffi::lmflow_contract_input_set_any
• ffi::lmflow_contract_input_set_type
• ffi::lmflow_contract_num_inputs
• ffi::lmflow_contract_num_outputs
• ffi::lmflow_contract_output_id
• ffi::lmflow_contract_output_index
• ffi::lmflow_contract_output_name
• ffi::lmflow_contract_output_set_any
• ffi::lmflow_contract_output_set_type
• ffi::lmflow_contract_require_side_packet
• ffi::lmflow_contract_set_error
• ffi::lmflow_ctx_close_reason
• ffi::lmflow_ctx_counter_add
• ffi::lmflow_ctx_emit
• ffi::lmflow_ctx_forward
• ffi::lmflow_ctx_has_option
• ffi::lmflow_ctx_has_side_packet
• ffi::lmflow_ctx_input
• ffi::lmflow_ctx_input_at
• ffi::lmflow_ctx_input_count
• ffi::lmflow_ctx_input_id
• ffi::lmflow_ctx_input_index
• ffi::lmflow_ctx_input_is_done
• ffi::lmflow_ctx_input_is_empty
• ffi::lmflow_ctx_input_name
• ffi::lmflow_ctx_input_payload
• ffi::lmflow_ctx_input_timestamp
• ffi::lmflow_ctx_kernel_name
• ffi::lmflow_ctx_log
• ffi::lmflow_ctx_node_name
• ffi::lmflow_ctx_num_inputs
• ffi::lmflow_ctx_num_outputs
• ffi::lmflow_ctx_option_bool
• ffi::lmflow_ctx_option_count
• ffi::lmflow_ctx_option_f64
• ffi::lmflow_ctx_option_f64_array
• ffi::lmflow_ctx_option_i64
• ffi::lmflow_ctx_option_i64_array
• ffi::lmflow_ctx_option_str
• ffi::lmflow_ctx_option_str_array
• ffi::lmflow_ctx_options_json
• ffi::lmflow_ctx_output_id
• ffi::lmflow_ctx_output_index
• ffi::lmflow_ctx_output_name
• ffi::lmflow_ctx_require_option_bool
• ffi::lmflow_ctx_require_option_f64
• ffi::lmflow_ctx_require_option_i64
• ffi::lmflow_ctx_require_option_str
• ffi::lmflow_ctx_set_error
• ffi::lmflow_ctx_set_next_ts_bound
• ffi::lmflow_ctx_side_packet
• ffi::lmflow_ctx_source_done
• ffi::lmflow_ctx_source_yield
• ffi::lmflow_ctx_take_input
• ffi::lmflow_dtype_size
• ffi::lmflow_graph_add_packet
• ffi::lmflow_graph_add_poller
• ffi::lmflow_graph_add_poller_bounded
• ffi::lmflow_graph_add_poller_ex
• ffi::lmflow_graph_cancel
• ffi::lmflow_graph_close_all_inputs
• ffi::lmflow_graph_close_input
• ffi::lmflow_graph_counter_count
• ffi::lmflow_graph_counter_name
• ffi::lmflow_graph_counter_value
• ffi::lmflow_graph_dropped_count
• ffi::lmflow_graph_dump
• ffi::lmflow_graph_free
• ffi::lmflow_graph_init_from_yaml
• ffi::lmflow_graph_init_from_yaml_file
• ffi::lmflow_graph_input
• ffi::lmflow_graph_input_port_name
• ffi::lmflow_graph_input_queue_stats
• ffi::lmflow_graph_last_error
• ffi::lmflow_graph_new
• ffi::lmflow_graph_node_input_port_name
• ffi::lmflow_graph_node_name
• ffi::lmflow_graph_node_num_input_ports
• ffi::lmflow_graph_node_stats
• ffi::lmflow_graph_num_input_ports
• ffi::lmflow_graph_num_nodes
• ffi::lmflow_graph_num_output_ports
• ffi::lmflow_graph_observe
• ffi::lmflow_graph_observe_ex
• ffi::lmflow_graph_output_port_name
• ffi::lmflow_graph_pause
• ffi::lmflow_graph_pump_step
• ffi::lmflow_graph_pump_steps
• ffi::lmflow_graph_queue_depth
• ffi::lmflow_graph_reset
• ffi::lmflow_graph_resume
• ffi::lmflow_graph_set_side_packet
• ffi::lmflow_graph_set_wakeup_callback
• ffi::lmflow_graph_start
• ffi::lmflow_graph_state
• ffi::lmflow_graph_to_chrome_trace
• ffi::lmflow_graph_to_dot_view
• ffi::lmflow_graph_total_queued
• ffi::lmflow_graph_total_queued_bytes
• ffi::lmflow_graph_wait_done
• ffi::lmflow_graph_wait_done_timeout
• ffi::lmflow_graph_wait_until_idle
• ffi::lmflow_graph_wait_until_idle_timeout
• ffi::lmflow_input_close
• ffi::lmflow_input_free
• ffi::lmflow_input_send
• ffi::lmflow_input_try_send
• ffi::lmflow_kernel_runner_add_input
• ffi::lmflow_kernel_runner_close
• ffi::lmflow_kernel_runner_free
• ffi::lmflow_kernel_runner_new
• ffi::lmflow_kernel_runner_process
• ffi::lmflow_kernel_runner_set_options_json
• ffi::lmflow_kernel_runner_set_side_packet
• ffi::lmflow_kernel_runner_start
• ffi::lmflow_kernel_runner_try_next
• ffi::lmflow_last_error
• ffi::lmflow_packet_adopt_buffer
• ffi::lmflow_packet_as_bool
• ffi::lmflow_packet_as_buffer
• ffi::lmflow_packet_as_bytes
• ffi::lmflow_packet_as_f64
• ffi::lmflow_packet_as_i64
• ffi::lmflow_packet_as_str
• ffi::lmflow_packet_clone
• ffi::lmflow_packet_debug_string
• ffi::lmflow_packet_drop
• ffi::lmflow_packet_from_bool
• ffi::lmflow_packet_from_buffer
• ffi::lmflow_packet_from_bytes
• ffi::lmflow_packet_from_f64
• ffi::lmflow_packet_from_i64
• ffi::lmflow_packet_from_str
• ffi::lmflow_packet_has_metadata
• ffi::lmflow_packet_make_mutable_buffer
• ffi::lmflow_packet_make_mutable_bytes
• ffi::lmflow_packet_metadata_bool
• ffi::lmflow_packet_metadata_count
• ffi::lmflow_packet_metadata_f64
• ffi::lmflow_packet_metadata_i64
• ffi::lmflow_packet_metadata_key_at
• ffi::lmflow_packet_metadata_str
• ffi::lmflow_packet_new_buffer
• ffi::lmflow_packet_new_buffer_uninit
• ffi::lmflow_packet_remove_metadata
• ffi::lmflow_packet_set_metadata_bool
• ffi::lmflow_packet_set_metadata_f64
• ffi::lmflow_packet_set_metadata_i64
• ffi::lmflow_packet_set_metadata_str
• ffi::lmflow_poller_dropped_count
• ffi::lmflow_poller_free
• ffi::lmflow_poller_next_status
• ffi::lmflow_poller_next_timeout
• ffi::lmflow_poller_try_next_status
• ffi::lmflow_register_kernel
• ffi::lmflow_register_kernel_with_language
• ffi::lmflow_register_type_descriptor
• ffi::lmflow_set_log_callback
• ffi::lmflow_type_align
• ffi::lmflow_type_id
• ffi::lmflow_type_name
• ffi::lmflow_type_size
• ffi::own_packet
• ffi::take_packet
• kernel::lookup
• kernel::register
• kernel::register_with_language
• kernel::registered_names
• kernel_api::register_kernel
• packet::dtype_size
• packet::fnv1a_type_id
• packet::register_type_descriptor
• packet::type_descriptor
• packet::type_name
• runtime::last_error::get
• runtime::last_error::set
• runtime::last_error::take
• runtime::log
• runtime::log_enabled
• runtime::log_info
• runtime::log_warn
• runtime::set_log_callback
• status::invalid_arg
• status::not_found
• status::unsupported
• trace::to_chrome_trace_json

Type Aliases

• graph::EdgeId
• graph::NodeId
• metadata::Metadata
• status::Result

Constants

• executor::DEFAULT_EXECUTOR_NAME
• ffi::ABI_VERSION
• ffi::BUF_FLAG_READONLY
• ffi::DEVICE_CPU
• ffi::INVALID_ID
• ffi::LMFLOW_DOT_COMPACT
• ffi::LMFLOW_DOT_DIAGNOSTICS
• ffi::LMFLOW_DOT_TOPOLOGY
• ffi::LMFLOW_POLLER_BLOCK
• ffi::LMFLOW_POLLER_DROP_NEWEST
• ffi::LMFLOW_POLLER_DROP_OLDEST
• ffi::LMFLOW_POLLER_LATEST
• packet::MAX_DIMS
• packet::dtype::F16
• packet::dtype::F32
• packet::dtype::F64
• packet::dtype::I16
• packet::dtype::I32
• packet::dtype::I64
• packet::dtype::I8
• packet::dtype::U16
• packet::dtype::U8
• packet::type_id::BOOL
• packet::type_id::BUFFER
• packet::type_id::BYTES
• packet::type_id::F64
• packet::type_id::HOST_OBJECT
• packet::type_id::I64
• packet::type_id::NONE
• packet::type_id::STR
• runtime::CLOSE_CANCELLED
• runtime::CLOSE_ERROR
• runtime::CLOSE_NORMAL
• runtime::LOG_DEBUG
• runtime::LOG_ERROR
• runtime::LOG_INFO
• runtime::LOG_WARN
• status::code::ABI
• status::code::CANCELLED
• status::code::CLOSED
• status::code::INVALID_ARG
• status::code::KERNEL
• status::code::NOT_FOUND
• status::code::OK
• status::code::PANIC
• status::code::STATE
• status::code::TIMEOUT
• status::code::UNSUPPORTED
• status::code::WOULD_BLOCK