List of all items

Structs

• BuildId
• SessionId
• auth::AuthToken
• common::BinaryPin
• common::DaemonId
• common::GitSource
• common::HubProvenance
• common::LogMessage
• common::LogMessageHelper
• common::NodeError
• common::Timestamped
• config::ByteSize
• config::FormattedDuration
• config::Input
• config::LogSubscriptionFilter
• config::NodeRunConfig
• config::UserInputMapping
• coordinator_to_cli::CleanFailure
• coordinator_to_cli::DaemonInfo
• coordinator_to_cli::DataflowIdAndName
• coordinator_to_cli::DataflowList
• coordinator_to_cli::DataflowListEntry
• coordinator_to_cli::DataflowResult
• coordinator_to_cli::NodeInfo
• coordinator_to_cli::NodeMetricsInfo
• coordinator_to_cli::TraceSpan
• coordinator_to_cli::TraceSummary
• coordinator_to_daemon::BuildDataflowNodes
• coordinator_to_daemon::SpawnDataflowNodes
• coordinator_to_daemon::StateCatchUpEntry
• daemon_to_coordinator::DaemonRegisterRequest
• daemon_to_coordinator::DataflowDaemonResult
• daemon_to_coordinator::DataflowStatusEntry
• daemon_to_coordinator::FaultToleranceSnapshot
• daemon_to_coordinator::NetworkMetrics
• daemon_to_coordinator::NodeMetrics
• daemon_to_node::NodeConfig
• daemon_to_node::OutputRouting
• daemon_to_node::RequiredAcker
• daemon_to_node::RuntimeConfig
• descriptor::CustomNode
• descriptor::Debug
• descriptor::Deploy
• descriptor::Descriptor
• descriptor::Node
• descriptor::OperatorConfig
• descriptor::OperatorDefinition
• descriptor::PythonSource
• descriptor::ResolvedNode
• descriptor::Ros2BridgeConfig
• descriptor::Ros2QosConfig
• descriptor::Ros2TopicConfig
• descriptor::RuntimeNode
• descriptor::SingleOperatorDefinition
• descriptor::TypeRuleDef
• id::DataId
• id::InvalidId
• id::NodeId
• id::OperatorId
• integration_testing_format::IntegrationTestInput
• integration_testing_format::TimedIncomingEvent
• metadata::Metadata
• node_to_daemon::NodeRegisterRequest
• ws_protocol::WsEvent
• ws_protocol::WsRequest
• ws_protocol::WsResponse

Enums

• cli_to_coordinator::ControlRequest
• common::DataMessage
• common::LogLevel
• common::LogLevelOrStdout
• common::NodeErrorCause
• common::NodeExitStatus
• config::InputDef
• config::InputMapping
• config::QueuePolicy
• coordinator_to_cli::ControlRequestReply
• coordinator_to_cli::DataflowStatus
• coordinator_to_cli::LogLevel
• coordinator_to_daemon::DaemonCoordinatorEvent
• coordinator_to_daemon::RegisterResult
• coordinator_to_daemon::ResolveMachineReply
• coordinator_to_daemon::StateCatchUpOperation
• daemon_to_coordinator::CoordinatorRequest
• daemon_to_coordinator::DaemonCoordinatorReply
• daemon_to_coordinator::DaemonEvent
• daemon_to_coordinator::LogLevel
• daemon_to_coordinator::NodeStatus
• daemon_to_daemon::InterDaemonEvent
• daemon_to_node::DaemonCommunication
• daemon_to_node::DaemonReply
• daemon_to_node::NodeEvent
• descriptor::CoreNodeKind
• descriptor::DistributeStrategy
• descriptor::EnvValue
• descriptor::GitRepoRev
• descriptor::NodeSource
• descriptor::OperatorSource
• descriptor::OutputFraming
• descriptor::PythonSourceDef
• descriptor::RestartPolicy
• descriptor::RmwZenohCompatibility
• descriptor::Ros2Direction
• descriptor::Ros2Role
• descriptor::Ros2TransportConfig
• integration_testing_format::IncomingEvent
• integration_testing_format::InputData
• integration_testing_format::RecordingStatus
• metadata::Parameter
• node_to_daemon::DaemonRequest
• node_to_daemon::DynamicNodeEvent
• node_to_daemon::LogLevel
• ws_protocol::WsMessage

Functions

• auth::config_token_path
• auth::constant_time_eq
• auth::discover_token
• auth::generate_token
• auth::read_token
• auth::token_path
• auth::write_token
• bulk_bytes::deserialize
• bulk_bytes::option::deserialize
• bulk_bytes::option::serialize
• bulk_bytes::serialize
• bulk_bytes::vec::deserialize
• bulk_bytes::vec::serialize
• cli_to_coordinator::check_cli_version
• config::format_duration
• current_crate_version
• decode
• encode
• encode_presized
• metadata::carries_pattern_correlation
• metadata::debug_frame_wire_size
• metadata::fnv1a
• metadata::get_bool_param
• metadata::get_integer_param
• metadata::get_string_param
• metadata::strip_internal_parameters
• topic_protocol_mismatch_message

Type Aliases

• DataflowId
• common::SharedMemoryId
• metadata::MetadataParameters

Constants

• MAX_MESSAGE_BYTES
• TCP_READ_TIMEOUT
• TOPIC_DATA_PROTOCOL_VERSION
• VERSION
• config::DEFAULT_QUEUE_SIZE
• descriptor::DYNAMIC_SOURCE
• descriptor::RUNTIME_PYTHON
• descriptor::RUNTIME_SHARED_LIBRARY
• descriptor::RUNTIME_WASM
• descriptor::SHELL_SOURCE
• metadata::FIN
• metadata::FLUSH
• metadata::FRAMING
• metadata::FRAMING_ARROW_IPC
• metadata::GOAL_ID
• metadata::GOAL_STATUS
• metadata::GOAL_STATUS_ABORTED
• metadata::GOAL_STATUS_CANCELED
• metadata::GOAL_STATUS_SUCCEEDED
• metadata::OPEN_TELEMETRY_CONTEXT
• metadata::REQUEST_ID
• metadata::SCHEMA_HASH
• metadata::SEGMENT_ID
• metadata::SEQ
• metadata::SESSION_ID
• metadata::STARTUP_ACK_CONSUMER_PARAM
• metadata::STARTUP_ACK_INPUT_PARAM
• metadata::STARTUP_ACK_PARAM
• metadata::STARTUP_MARKER_PARAM
• metadata::WIRE_SIZE