List of all items

Structs

• SignalCleanupGuard
• accum::GCounterUpdate
• accum::Max
• accum::Min
• accum::PNCounterUpdate
• accum::ReducerFactory
• accum::ReducerSpec
• accum::StreamingReducerOpts
• accum::WatermarkUpdate
• actor::ActorError
• actor::ActorGuard
• actor::ActorHandle
• actor::AnyActorGuard
• actor::AnyActorHandle
• actor::HandlerInfo
• actor::remote::Remote
• actor::remote::SpawnableActor
• actor_local::ActorLocal
• actor_local::ActorLocalStorage
• actor_local::OccupiedEntry
• actor_local::VacantEntry
• addr::ActorAddr
• addr::PortAddr
• addr::ProcAddr
• channel::ChannelRx
• channel::ChannelTx
• channel::CompletionReceipt
• channel::CompletionSink
• channel::MuxServer
• channel::MuxShutdown
• channel::SendError
• channel::TcpModeIter
• channel::TlsAddr
• channel::TlsModeIter
• channel::duplex::DuplexClient
• channel::duplex::DuplexRx
• channel::duplex::DuplexServer
• channel::duplex::DuplexTx
• client::Client
• client::ClientActor
• config::PemBundle
• gateway::AttachedProcGuard
• gateway::Gateway
• gateway::GatewayServeHandle
• gateway::PeerAttachError
• gateway::PeerAttachGuard
• id::ActorId
• id::Label
• id::PortId
• id::ProcId
• introspect::ActorAttrsView
• introspect::FailureAttrs
• introspect::IntrospectResult
• introspect::RecordedEvent
• mailbox::BoxedMailboxSender
• mailbox::DeliveryFailure
• mailbox::DeliveryFailureReport
• mailbox::DialMailboxRouter
• mailbox::ExpiredDelivery
• mailbox::FallbackMailboxRouter
• mailbox::InvalidReference
• mailbox::Mailbox
• mailbox::MailboxClient
• mailbox::MailboxError
• mailbox::MailboxMuxer
• mailbox::MailboxRouter
• mailbox::MailboxSenderError
• mailbox::MailboxServerHandle
• mailbox::MessageEnvelope
• mailbox::MessageMetadata
• mailbox::OncePortHandle
• mailbox::OncePortReceiver
• mailbox::PanickingMailboxSender
• mailbox::PortGone
• mailbox::PortHandle
• mailbox::PortReceiver
• mailbox::PortSink
• mailbox::TransportFailure
• mailbox::UndeliverableMailboxSender
• mailbox::UnroutableMailboxSender
• mailbox::WeakMailboxRouter
• ordering::OrderingSessionSnapshot
• ordering::OrderingSnapshot
• ordering::Sequencer
• proc::ActorInstance
• proc::ActorWorkReceiver
• proc::Builder
• proc::Context
• proc::GlobalGateway
• proc::HandlerPorts
• proc::Instance
• proc::InstanceCell
• proc::InstanceReceivers
• proc::PrivateGateway
• proc::Proc
• proc::SharedGateway
• proc::WeakInstanceCell
• proc::WeakProc
• proc::WorkCell
• ref_::ActorRef
• ref_::OncePortRef
• ref_::PortRef
• remote::Remote
• subject::Subject
• supervision::ActorSupervisionEvent
• sync::flag::Flag
• sync::flag::Guard
• sync::monitor::Group
• sync::monitor::Handle
• sync::mvar::MVar
• testing::pingpong::PingPongActor
• testing::pingpong::PingPongMessage
• testing::proc_supervison::ProcSupervisionCoordinator
• testing::proc_supervison::ReportedEvent
• time::Alarm
• time::AlarmSleeper
• value_mesh::ValueMesh
• value_mesh::ValueOverlay
• value_mesh::ValueOverlayReducer

Enums

• SignalDisposition
• accum::ReducerMode
• actor::ActorErrorKind
• actor::ActorStatus
• actor::ActorStoppingReason
• actor::Signal
• actor::StopMode
• actor_local::Entry
• addr::Addr
• addr::AddrParseError
• addr::Location
• channel::BindSpec
• channel::ChannelAddr
• channel::ChannelError
• channel::ChannelTransport
• channel::CloseReason
• channel::SendErrorReason
• channel::ServerError
• channel::TcpMode
• channel::TlsMode
• channel::TxStatus
• config::Pem
• endpoint::EndpointLocation
• id::Id
• id::IdParseError
• id::LabelError
• id::Uid
• id::UidParseError
• introspect::AttrsViewError
• introspect::IntrospectMessage
• introspect::IntrospectRef
• introspect::IntrospectRefParseError
• introspect::IntrospectView
• mailbox::DeliveryFailureKind
• mailbox::InvalidReferenceReason
• mailbox::MailboxErrorKind
• mailbox::MailboxSenderErrorKind
• mailbox::MailboxServerError
• mailbox::PortLocation
• mailbox::TransportFailureReason
• mailbox::Undeliverable
• mailbox::UndeliverableMessageError
• mailbox::UndeliverableReason
• mailbox::mailbox_admin_message::MailboxAdminMessage
• metrics::ChannelErrorType
• ordering::SeqInfo
• port::ControlPort
• port::ControlPortParseError
• port::Port
• port::PortParseError
• proc::StatusMessage
• runtime_identity::RuntimeKind
• sync::monitor::Status
• value_mesh::BuildError
• value_mesh::ValueMeshError

Traits

• accum::Accumulator
• accum::CommReducer
• accum::ErasedCommReducer
• actor::Actor
• actor::Binds
• actor::Handler
• actor::Referable
• actor::RemoteHandles
• actor::RemoteSpawn
• channel::Rx
• channel::Tx
• context::Actor
• context::Mailbox
• endpoint::Endpoint
• endpoint::RemoteEndpoint
• mailbox::BoxableMailboxSender
• mailbox::IntoBoxedMailboxSender
• mailbox::MailboxSender
• mailbox::MailboxServer
• mailbox::Message
• mailbox::PortSender
• mailbox::RemoteMessage
• mailbox::mailbox_admin_message::MailboxAdminMessageClient
• mailbox::mailbox_admin_message::MailboxAdminMessageHandler
• remote::Accepts
• subject::AsSubject

Macros

• assert_behaves
• assert_cancel_safe
• assert_cancel_safe_async
• behavior
• declare_static_counter
• declare_static_gauge
• declare_static_histogram
• declare_static_timer
• key_value
• kv_pairs
• register_spawnable
• uid

Attribute Macros

• export
• handle
• instrument
• instrument_infallible
• observe_async
• observe_result
• spawnable

Derive Macros

• HandleClient
• Handler
• RefClient

Functions

• accum::join_semilattice
• accum::sum
• accum::unit
• actor::handle_delivery_failure_event
• actor::handle_expired_delivery
• actor::handle_invalid_reference
• actor::handle_stop
• actor::handle_undeliverable_message
• channel::dial
• channel::duplex::dial
• channel::duplex::serve
• channel::reserve_local_addr
• channel::serve
• channel::serve_local
• channel::serve_mux
• channel::serve_with_listener
• channel::try_tls_acceptor
• channel::try_tls_connector
• channel::try_tls_pem_bundle
• channel::unordered::dial
• channel::unordered::serve
• channel::unordered::serve_with_listener
• client
• initialize
• initialize_with_current_runtime
• initialize_with_log_prefix
• introspect::format_timestamp
• introspect::live_actor_payload
• mailbox::custom_monitored_return_handle
• mailbox::headers::log_message_latency_if_sampling
• mailbox::headers::set_rust_message_type
• mailbox::headers::set_send_timestamp
• mailbox::monitored_return_handle
• mailbox::open_once_port
• mailbox::open_port
• panic_handler::set_panic_hook
• query_signal_disposition
• register_signal_cleanup
• register_signal_cleanup_scoped
• runtime_identity::build_data_plane_runtime
• runtime_identity::current_runtime_kind
• runtime_identity::shutdown_data_plane_runtimes
• runtime_identity::tag_current_thread
• serve
• sigpipe_disposition
• spawn
• spawn_with_label
• spawn_with_uid
• sync::flag::guarded
• sync::monitor::group
• testing::cancel_safe::assert_cancel_safe
• testing::cancel_safe::assert_cancel_safe_async
• testing::ids::test_actor_id
• testing::ids::test_port_id
• testing::ids::test_proc_id
• testing::ids::test_proc_id_with_addr
• testing::process_assertion::assert_termination
• unregister_signal_cleanup
• value_mesh::rle::merge_value_runs
• value_mesh::rle::rle_from_dense
• value_mesh::rle::rle_from_value_runs

Type Aliases

• Index
• channel::Hostname
• channel::Port
• mailbox::Data

Statics

• config::CHANNEL_NET_RX_BUFFER_FULL_CHECK_INTERVAL
• config::CHANNEL_RECONNECT_TIMEOUT
• config::CHANNEL_TCP_KEEPALIVE_IDLE
• config::CLEANUP_TIMEOUT
• config::CODEC_MAX_FRAME_LENGTH
• config::ENABLE_DEST_ACTOR_REORDERING_BUFFER
• config::FORWARDER_FLUSH_TIMEOUT
• config::HOST_SPAWN_READY_TIMEOUT
• config::MESSAGE_ACK_EVERY_N_MESSAGES
• config::MESSAGE_ACK_TIME_INTERVAL
• config::MESSAGE_DELIVERY_TIMEOUT
• config::MESSAGE_LATENCY_SAMPLING_RATE
• config::MESSAGE_TTL_DEFAULT
• config::PROCESS_EXIT_TIMEOUT
• config::SERVER_HEARTBEAT_INTERVAL
• config::SPLIT_MAX_BUFFER_AGE
• config::SPLIT_MAX_BUFFER_SIZE
• config::STOP_ACTOR_TIMEOUT
• config::TERMINATED_SNAPSHOT_RETENTION
• config::TLS_CA
• config::TLS_CERT
• config::TLS_KEY
• introspect::ACTOR_QUEUE_DEPTH
• introspect::ACTOR_TYPE
• introspect::CHILDREN
• introspect::CREATED_AT
• introspect::ERROR_CODE
• introspect::ERROR_MESSAGE
• introspect::FAILURE_ERROR_MESSAGE
• introspect::FAILURE_IS_PROPAGATED
• introspect::FAILURE_OCCURRED_AT
• introspect::FAILURE_ROOT_CAUSE_ACTOR
• introspect::FAILURE_ROOT_CAUSE_NAME
• introspect::FLIGHT_RECORDER
• introspect::INBOUND_ORDERING
• introspect::INSTANCE_ID
• introspect::IS_SYSTEM
• introspect::LAST_HANDLER
• introspect::MESSAGES_PROCESSED
• introspect::STATUS
• introspect::STATUS_REASON
• introspect::TOTAL_PROCESSING_TIME_US
• mailbox::headers::OPERATION_ADVERB
• mailbox::headers::OPERATION_ENDPOINT
• mailbox::headers::RUST_MESSAGE_TYPE
• mailbox::headers::SENDER_ACTOR_ID
• mailbox::headers::SENDER_ACTOR_ID_HASH
• mailbox::headers::SEND_TIMESTAMP
• mailbox::headers::TELEMETRY_MESSAGE_ID
• mailbox::headers::TELEMETRY_PORT_INDEX
• metrics::ACTOR_MESSAGES_RECEIVED
• metrics::ACTOR_MESSAGES_SENT
• metrics::ACTOR_MESSAGE_HANDLER_DURATION
• metrics::ACTOR_MESSAGE_QUEUE_SIZE
• metrics::ACTOR_MESSAGE_RECEIVE_ERRORS
• metrics::CHANNEL_CONNECTIONS
• metrics::CHANNEL_ERRORS
• metrics::CHANNEL_LATENCY_MICROS
• metrics::CHANNEL_NET_RX_BUFFER_FULL
• metrics::CHANNEL_RECONNECTIONS
• metrics::CHANNEL_THROUGHPUT_BYTES
• metrics::CHANNEL_THROUGHPUT_MESSAGES
• metrics::MAILBOX_POSTS
• metrics::MAILBOX_UNDELIVERABLE_MESSAGES
• metrics::MESSAGE_LATENCY_MICROS
• metrics::PROC_MESH_ACTOR_FAILURES
• metrics::PROC_MESH_ALLOCATION
• metrics::PROC_MESH_PROC_STOPPED
• metrics::REMOTE_MESSAGE_SEND_SIZE
• metrics::SERVER_HEARTBEAT
• ordering::SEQ_INFO

Constants

• actor::remote::USER_PORT_OFFSET
• metrics::SERVER_HEARTBEAT_METRIC_NAME
• proc::LEGACY_LOCAL_PROC_NAME
• proc::LEGACY_SERVICE_PROC_NAME