List of all items
Structs
- AsyncCallback
- AsyncMap
- AsyncService
- BlockingCallback
- BlockingMap
- BlockingService
- ContinuousService
- CrossflowExecutorApp
- CrossflowPlugin
- buffer::AnyBuffer
- buffer::AnyBufferKey
- buffer::AnyBufferMut
- buffer::AnyBufferView
- buffer::AnyMessageError
- buffer::Buffer
- buffer::BufferAccess
- buffer::BufferAccessMut
- buffer::BufferGateAccess
- buffer::BufferGateAccessMut
- buffer::BufferGateMut
- buffer::BufferGateView
- buffer::BufferIncompatibility
- buffer::BufferKey
- buffer::BufferKeyBuilder
- buffer::BufferKeyTag
- buffer::BufferLocation
- buffer::BufferMut
- buffer::BufferSettings
- buffer::BufferView
- buffer::CloneFromBuffer
- buffer::DrainAnyBuffer
- buffer::DrainJsonBuffer
- buffer::FetchFromBuffer
- buffer::IncompatibleLayout
- buffer::IterJsonBufferView
- buffer::JsonBuffer
- buffer::JsonBufferKey
- buffer::JsonBufferMut
- buffer::JsonBufferView
- buffer::JsonMut
- buffer::MessageTypeHintEvaluation
- builder::Builder
- builder::BuilderScopeContext
- builder::CleanupWorkflowConditions
- callback::AsyncCallbackMarker
- callback::AsyncMapCallbackMarker
- callback::BlockingCallbackMarker
- callback::BlockingMapCallbackMarker
- callback::Callback
- callback::CallbackRequest
- callback::PendingCallbackRequest
- cancel::Broken
- cancel::Cancel
- cancel::Cancellable
- cancel::Cancellation
- cancel::CircularCollect
- cancel::InvalidSpan
- cancel::OperationCancel
- cancel::TriggeredCancellation
- cancel::Unreachability
- chain::Chain
- chain::split::SplitAsList
- chain::split::SplitAsMap
- chain::split::SplitBuilder
- chain::split::SplitDispatcher
- chain::split::SplitOutputs
- channel::Channel
- channel::InnerChannel
- diagram::BufferAccessSchema
- diagram::BufferSchema
- diagram::CommonOperations
- diagram::ConfigExample
- diagram::Diagram
- diagram::DiagramContext
- diagram::DiagramElementRegistry
- diagram::DiagramError
- diagram::DiagramErrorContext
- diagram::DynForkClone
- diagram::DynForkResult
- diagram::DynSplit
- diagram::ExtensionSettings
- diagram::FinishingErrors
- diagram::ForkCloneSchema
- diagram::ForkResultSchema
- diagram::ImplicitDeserialization
- diagram::ImplicitSerialization
- diagram::ImplicitStringify
- diagram::InputExample
- diagram::JoinSchema
- diagram::JsonRegistration
- diagram::ListenSchema
- diagram::MessageOperation
- diagram::MessageRegistration
- diagram::MessageRegistrationBuilder
- diagram::MessageRegistry
- diagram::MissingStream
- diagram::NamedOperationRef
- diagram::NamespaceList
- diagram::NamespacedOperation
- diagram::NodeBuilderOptions
- diagram::NodeRegistration
- diagram::NodeRegistrationBuilder
- diagram::NodeSchema
- diagram::Operations
- diagram::RedirectConnection
- diagram::ScopeSchema
- diagram::SectionBuffer
- diagram::SectionBuilderOptions
- diagram::SectionInput
- diagram::SectionMetadata
- diagram::SectionOutput
- diagram::SectionRegistration
- diagram::SectionSchema
- diagram::SectionSlots
- diagram::SectionTemplate
- diagram::SplitSchema
- diagram::StreamOutRef
- diagram::StreamOutSchema
- diagram::Templates
- diagram::TerminateSchema
- diagram::TraceInfo
- diagram::TraceSettings
- diagram::TransformSchema
- diagram::UnzipSchema
- diagram::grpc::AbortOnDrop
- diagram::grpc::GrpcConfig
- diagram::grpc::GrpcStreams
- diagram::grpc::__crossflow_GrpcStreams_StreamBuffers
- diagram::grpc::__crossflow_GrpcStreams_StreamChannels
- diagram::grpc::__crossflow_GrpcStreams_StreamInputPack
- diagram::grpc::__crossflow_GrpcStreams_StreamOutputPack
- diagram::grpc::__crossflow_GrpcStreams_StreamReceivers
- diagram::zenoh::ArcError
- diagram::zenoh::ZenohNodeStreams
- diagram::zenoh::ZenohPublisherConfig
- diagram::zenoh::ZenohPublisherHeartbeatConfig
- diagram::zenoh::ZenohQuerierConfig
- diagram::zenoh::ZenohSession
- diagram::zenoh::ZenohSubscriptionConfig
- diagram::zenoh::ZenohSubscriptionHistoryConfig
- diagram::zenoh::__crossflow_ZenohNodeStreams_StreamBuffers
- diagram::zenoh::__crossflow_ZenohNodeStreams_StreamChannels
- diagram::zenoh::__crossflow_ZenohNodeStreams_StreamInputPack
- diagram::zenoh::__crossflow_ZenohNodeStreams_StreamOutputPack
- diagram::zenoh::__crossflow_ZenohNodeStreams_StreamReceivers
- disposal::ClosedGate
- disposal::DeficientCollection
- disposal::Disposal
- disposal::DisposedBranch
- disposal::DisposedBufferKey
- disposal::EmptySpread
- disposal::Filtered
- disposal::IncompleteSplit
- disposal::PoisonedMutexDisposal
- disposal::ServiceUnavailable
- disposal::Supplanted
- disposal::TaskDespawned
- disposal::Trimming
- disposal::UnusedStreams
- errors::CancelFailure
- errors::ConnectionFailure
- errors::DisposalFailure
- errors::DuplicateStream
- errors::MiscellaneousFailure
- errors::SetupFailure
- errors::StopTaskFailure
- errors::UnhandledErrors
- errors::UnusedTargetDrop
- flush::FlushParameters
- gate::GateRequest
- input::Input
- input::InputBundle
- map::AsyncMapAdapter
- map::AsyncMapDef
- map::AsyncMapMarker
- map::BlockingMapAdapter
- map::BlockingMapDef
- map::BlockingMapMarker
- map::MapDef
- map_once::AsyncMapOnceAdapter
- map_once::AsyncMapOnceDef
- map_once::BlockingMapOnceAdapter
- map_once::BlockingMapOnceDef
- map_once::MapOnceDef
- node::ForkCloneOutput
- node::ForkOptionOutput
- node::ForkResultOutput
- node::InputSlot
- node::Node
- node::Output
- node::dyn_node::DynInputSlot
- node::dyn_node::DynNode
- node::dyn_node::DynOutput
- node::dyn_node::DynStreamInputPack
- node::dyn_node::DynStreamOutputPack
- node::dyn_node::TypeMismatch
- operation::AnonymousStreamRedirect
- operation::BufferKeyUsage
- operation::CheckBufferSizeFn
- operation::ClearBufferFn
- operation::DisposalListener
- operation::DisposalNotice
- operation::DisposalUpdate
- operation::DownstreamIter
- operation::ForkTargetStorage
- operation::FunnelInputStorage
- operation::GetBufferedSessionsFn
- operation::OperationReachability
- operation::OperationRequest
- operation::OperationRoster
- operation::OperationSetup
- operation::ParentSession
- operation::PendingOperationRequest
- operation::RedirectWorkflowStream
- operation::ScopeContents
- operation::ScopeStorage
- operation::SingleInputStorage
- operation::SingleTargetStorage
- operation::StreamNameStorage
- operation::TerminalStorage
- operation::ValidateScopeReachability
- operation::ValidationRequest
- outcome::Outcome
- prelude::In
- prelude::World
- promise::Interrupter
- promise::Promise
- re_exports::Commands
- re_exports::Entity
- re_exports::SmallVec
- re_exports::With
- re_exports::World
- reply::Reply
- series::Capture
- series::Collection
- series::Recipient
- series::Series
- series::Storage
- service::AsAsyncService
- service::AsBlockingService
- service::Blocking
- service::ContinuousQuery
- service::ContinuousQueueMut
- service::ContinuousQueueView
- service::ContinuousServiceKey
- service::DeliveryInstructions
- service::DeliveryLabelId
- service::IntoContinuousServiceBuilderMarker
- service::MissingStreamsError
- service::OrderMut
- service::OrderView
- service::Service
- service::ServiceBuilder
- service::ServiceInstructions
- service::discovery::IterServiceDiscovery
- service::discovery::ServiceDiscovery
- stream::AnonymousStream
- stream::DynamicallyNamedStream
- stream::DynamicallyNamedStreamBuffer
- stream::DynamicallyNamedStreamChannel
- stream::NamedStream
- stream::NamedStreamBuffer
- stream::NamedStreamChannel
- stream::NamedStreamRedirect
- stream::NamedStreamTargets
- stream::NamedValue
- stream::Receiver
- stream::Require
- stream::SendAnonymousStreams
- stream::SendNamedStreams
- stream::StreamAvailability
- stream::StreamBuffer
- stream::StreamChannel
- stream::StreamOf
- stream::StreamRequest
- stream::StreamTargetMap
- testing::App
- testing::CommandQueue
- testing::Commands
- testing::Duration
- testing::Entity
- testing::FlushConditions
- testing::In
- testing::Instant
- testing::Integer
- testing::InvalidValue
- testing::Local
- testing::Name
- testing::NonCopyBuffer
- testing::Query
- testing::RepeatRequest
- testing::ResMut
- testing::RunCount
- testing::Salutation
- testing::TestComponent
- testing::TestError
- testing::TestingContext
- testing::Update
- testing::WaitRequest
- testing::World
- trace::OperationInfo
- trace::OperationStarted
- trace::Trace
- trim::TrimBranch
- trim::TrimPoint
- type_info::TypeInfo
- workflow::Scope
- workflow::ScopeSettings
- workflow::WorkflowSettings
Enums
- buffer::BufferError
- buffer::BufferIdentifier
- buffer::JoinBehavior
- buffer::JsonMessage
- buffer::MessageTypeHint
- buffer::RetentionPolicy
- cancel::CancellationCause
- chain::split::ListSplitKey
- chain::split::MapSplitKey
- chain::split::SplitConnectionError
- diagram::BufferSelection
- diagram::BuildStatus
- diagram::BuiltinSource
- diagram::BuiltinTarget
- diagram::DiagramErrorCode
- diagram::DiagramOperation
- diagram::InputRemapping
- diagram::JsonPosition
- diagram::NextOperation
- diagram::OperationRef
- diagram::SectionError
- diagram::SectionProvider
- diagram::TraceToggle
- diagram::TransformError
- diagram::grpc::NameOrIndex
- diagram::zenoh::OrderingConfig
- diagram::zenoh::WaitForMatching
- diagram::zenoh::ZenohBuildError
- diagram::zenoh::ZenohCongestionControlConfig
- diagram::zenoh::ZenohEncodingConfig
- diagram::zenoh::ZenohLocalityConfig
- diagram::zenoh::ZenohPriorityConfig
- diagram::zenoh::ZenohPublisherError
- diagram::zenoh::ZenohPublisherHeartbeatOption
- diagram::zenoh::ZenohPublisherReliability
- diagram::zenoh::ZenohQuerierError
- diagram::zenoh::ZenohQueryConsolidationModeConfig
- diagram::zenoh::ZenohQueryTargetConfig
- diagram::zenoh::ZenohSubscriptionError
- diagram::zenoh::ZenohSubscriptionRecoveryConfig
- disposal::DisposalCause
- errors::FlushWarning
- gate::Gate
- operation::IncrementalScopeError
- operation::OperationError
- operation::SessionStatus
- prelude::JsonMessage
- promise::PromiseState
- service::ScheduleConfigs
- stream::NamedTarget
- trace::GetValueError
- workflow::DeliverySettings
Traits
- Sendish
- buffer::Accessible
- buffer::Accessing
- buffer::Accessor
- buffer::AddBufferToMap
- buffer::AnyBufferAccessInterface
- buffer::AnyBufferAccessMut
- buffer::AnyBufferAccessMutState
- buffer::AnyBufferWorldAccess
- buffer::AsAnyBuffer
- buffer::BufferKeyLifecycle
- buffer::BufferMapLayout
- buffer::BufferMapStruct
- buffer::BufferWorldAccess
- buffer::Bufferable
- buffer::Buffering
- buffer::InspectBuffer
- buffer::IterBufferable
- buffer::Joinable
- buffer::Joined
- buffer::Joining
- buffer::JsonBufferWorldAccess
- buffer::ManageBuffer
- callback::AsCallback
- callback::CallbackTrait
- callback::IntoAsyncCallback
- callback::IntoBlockingCallback
- cancel::ManageCancellation
- chain::fork_clone_builder::ForkCloneBuilder
- chain::split::ForRemaining
- chain::split::FromSequential
- chain::split::FromSpecific
- chain::split::IgnoreSplitChainResult
- chain::split::Splittable
- chain::unzip::UnzipBuilder
- chain::unzip::Unzippable
- diagram::BuildDiagramOperation
- diagram::ConnectIntoTarget
- diagram::DeserializeMessage
- diagram::DynType
- diagram::InferMessageType
- diagram::IntoNodeRegistration
- diagram::IntoSectionRegistration
- diagram::RegisterClone
- diagram::RegisterJson
- diagram::RegisterSplit
- diagram::Section
- diagram::SectionItem
- diagram::SectionMetadataProvider
- diagram::SerializeMessage
- diagram::grpc::AbortOnDropExt
- disposal::InspectDisposals
- disposal::ManageDisposal
- input::InspectInput
- input::ManageInput
- map::AsMap
- map::IntoAsyncMap
- map::IntoBlockingMap
- map_once::AsMapOnce
- map_once::IntoAsyncMapOnce
- map_once::IntoBlockingMapOnce
- operation::Operation
- operation::OrBroken
- operation::ReportUnhandled
- operation::StreamRedirect
- prelude::FutureExt
- provider::ProvideOnce
- provider::Provider
- re_exports::Clone
- re_exports::Copy
- request::RequestExt
- request::RunCommandsOnWorldExt
- service::AddContinuousServicesExt
- service::AddServicesExt
- service::AsDeliveryInstructions
- service::DeliveryLabel
- service::IntoAsyncService
- service::IntoBlockingService
- service::IsAsyncService
- service::SpawnServicesExt
- service::service_utils::DynEq
- service::traits::AlsoAdd
- service::traits::ChooseAsyncServiceDelivery
- service::traits::ConfigureContinuousService
- service::traits::DeliveryChoice
- service::traits::IntoContinuousService
- service::traits::IntoService
- service::traits::IntoServiceBuilder
- service::traits::QuickContinuousServiceBuild
- service::traits::QuickServiceBuild
- service::traits::ServiceTrait
- service::traits::WithEntityCommands
- service::traits::WithEntityWorldMut
- stream::StreamEffect
- stream::StreamFilter
- stream::StreamPack
- testing::Component
- testing::IntoSystem
- testing::Resolvable
- testing::Resource
- workflow::SpawnWorkflowExt
Macros
Derive Macros
- buffer::Accessor
- buffer::Joined
- diagram::Section
- prelude::Accessor
- prelude::DeliveryLabel
- prelude::Joined
- prelude::Section
- prelude::Stream
- prelude::StreamPack
- re_exports::Clone
- re_exports::Copy
- service::DeliveryLabel
- stream::Stream
- stream::StreamPack
- testing::Component
- testing::Resource
Functions
- cancel::try_emit_broken
- diagram::as_build_diagram_operation
- diagram::standard_input_connection
- disposal::emit_disposal
- flush::flush_execution
- operation::awaken_task
- operation::check_reachability
- operation::execute_operation
- operation::immediately_downstream_of
- operation::is_downstream_of
- re_exports::type_name_of_val
- service::event_streaming_service
- testing::add
- testing::concat
- testing::double
- testing::duplicate
- testing::opposite
- testing::print_debug
- testing::produce_err
- testing::produce_none
- testing::repeat_service
- testing::repeat_string
- testing::say_hello
- testing::spawn_test_entities
- testing::string_from_utf8
- testing::sum
- testing::to_lowercase
- testing::to_uppercase
- trace_supported
Type Aliases
- AsyncCallbackInput
- AsyncServiceInput
- BlockingCallbackInput
- BlockingServiceInput
- ContinuousServiceInput
- buffer::AnyMessageBox
- buffer::AnyMessageMut
- buffer::AnyMessagePushResult
- buffer::AnyMessageRef
- buffer::AnyMessageResult
- buffer::BufferDowncastBox
- buffer::BufferDowncastRef
- buffer::BufferKeys
- buffer::BufferMap
- buffer::CloneForAnyFn
- buffer::JoinedItem
- buffer::JsonMessagePushResult
- buffer::JsonMessageReplaceResult
- buffer::JsonMessageViewResult
- buffer::KeyDowncastBox
- buffer::KeyDowncastRef
- buffer::MessageTypeHintMap
- chain::split::SplitBranchResult
- chain::split::SplitChainResult
- diagram::BuilderId
- diagram::DisplayText
- diagram::OperationName
- map::RequestOfMap
- map::ResponseOfMap
- map::StreamsOfMap
- operation::OperationResult
- operation::ReachabilityResult
- stream::DefaultStreamBufferContainer