List of all items
Structs
- adapters::agentic_memory_storage::AgenticMemoryRecordsPersistence
- adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceCursor
- adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceErrorFact
- adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceStatusFact
- adapters::agentic_memory_storage::AgenticMemoryRecordsRestoreState
- adapters::agentic_memory_storage::LoadAgenticMemoryRecordsStateOptions
- adapters::agentic_memory_storage::OpenPersistentAgenticMemoryRecords
- adapters::agentic_memory_storage::OpenPersistentAgenticMemoryRecordsOptions
- adapters::agentic_memory_storage::PersistAgenticMemoryRecordsOptions
- adapters::bridge::RemoteCallBundle
- adapters::bridge::RemoteCallError
- adapters::bridge::RemoteCallOptions
- adapters::bridge::RemoteCallRequest
- adapters::bridge::RemoteCallResult
- adapters::bridge::RemoteCallStatus
- adapters::bridge::RemoteCallTimeout
- adapters::bridge::RemoteResponderBundle
- adapters::bridge::RemoteResponderHandlerDefinition
- adapters::bridge::RemoteResponderOptions
- adapters::bridge::RemoteResponderStatus
- adapters::bridge::WireBridgeAck
- adapters::bridge::WireBridgeAttempt
- adapters::bridge::WireBridgeBundle
- adapters::bridge::WireBridgeEnvelope
- adapters::bridge::WireBridgeEnvelopeInput
- adapters::bridge::WireBridgeInbound
- adapters::bridge::WireBridgeMetadata
- adapters::bridge::WireBridgeNack
- adapters::bridge::WireBridgeOptions
- adapters::bridge::WireBridgeStatus
- adapters::bridge::WireEdgeGroupBundle
- adapters::bridge::WireEdgeGroupEdge
- adapters::bridge::WireEdgeGroupIssue
- adapters::bridge::WireEdgeGroupOptions
- adapters::bridge::WireEdgeGroupStatus
- adapters::bridge_protobuf::CanonicalProtobufError
- adapters::bridge_protobuf::CanonicalWireBridgeEnvelope
- adapters::bridge_protobuf::CanonicalWireBridgeMetadata
- adapters::bridge_protobuf::CanonicalWireEdgeFrame
- adapters::bridge_protobuf::WireBridgeProtobufDecode
- adapters::bridge_protobuf::WireBridgeProtobufEncode
- adapters::bridge_protobuf::WireBridgeProtobufEnvelope
- adapters::bridge_protobuf::WireBridgeProtobufHelperShape
- adapters::bridge_protobuf::WireBridgeProtobufIssue
- adapters::bridge_protobuf::WireBridgeProtobufStatus
- adapters::environment::OutboundAdapterOptions
- adapters::environment::OutboundBundle
- adapters::environment::OutboundStatus
- adapters::environment::WebSocketSessionBundle
- adapters::environment::WebSocketSessionOptions
- adapters::environment::WebSocketSessionStatus
- adapters::observe_storage::AttachObserveEventLogOptions
- adapters::observe_storage::ObserveEventLogErrorContext
- adapters::observe_storage::ObserveEventLogHandle
- adapters::reactive_collection_storage::OpenPersistentReactiveIndex
- adapters::reactive_collection_storage::OpenPersistentReactiveIndexOptions
- adapters::reactive_collection_storage::OpenPersistentReactiveList
- adapters::reactive_collection_storage::OpenPersistentReactiveListOptions
- adapters::reactive_collection_storage::OpenPersistentReactiveLog
- adapters::reactive_collection_storage::OpenPersistentReactiveLogOptions
- adapters::reactive_collection_storage::OpenPersistentReactiveMap
- adapters::reactive_collection_storage::OpenPersistentReactiveMapOptions
- adapters::reactive_collection_storage::PersistReactiveCollectionOptions
- adapters::reactive_collection_storage::ReactiveCollectionPersistence
- adapters::reactive_collection_storage::ReactiveCollectionPersistenceCursor
- adapters::reactive_collection_storage::ReactiveCollectionPersistenceErrorFact
- adapters::reactive_collection_storage::ReactiveCollectionPersistenceStatusFact
- async_driver::TokioLocalDriver
- batch::BatchCtx
- cascading_cache::CascadingCachePolicy
- cascading_cache::ReactiveCascadingCache
- cascading_cache::ReactiveCascadingCacheOptions
- checkpoint::GraphCheckpoint
- checkpoint::GraphCheckpointCtxState
- checkpoint::GraphCheckpointEdge
- checkpoint::GraphCheckpointLifecycle
- checkpoint::GraphCheckpointMount
- checkpoint::GraphCheckpointNode
- checkpoint::GraphRestoreDefinition
- checkpoint::GraphRestoreError
- checkpoint::GraphRestoreRegistry
- checkpoint::MapJsonRestoreDescriptor
- checkpoint::ReactiveIndexDeltaRestoreDescriptor
- checkpoint::ReactiveIndexSnapshotRestoreDescriptor
- checkpoint::ReactiveListDeltaRestoreDescriptor
- checkpoint::ReactiveListSnapshotRestoreDescriptor
- checkpoint::ReactiveLogDeltaRestoreDescriptor
- checkpoint::ReactiveLogSnapshotRestoreDescriptor
- checkpoint::ReactiveMapDeltaRestoreDescriptor
- checkpoint::ReactiveMapSnapshotRestoreDescriptor
- checkpoint::RestoreDefineCtx
- checkpoint::RestoreGraphOptions
- checkpoint::RestoreNodeDefinition
- checkpoint::StateRestoreDescriptor
- composition::Pipe
- composition::Stratified
- composition::StratifyOptions
- composition::StratifyRule
- cqrs::CqrsAuditRecord
- cqrs::CqrsBundle
- cqrs::CqrsCommand
- cqrs::CqrsCommandHandlerDefinition
- cqrs::CqrsCursor
- cqrs::CqrsDedupePolicy
- cqrs::CqrsDedupeSnapshot
- cqrs::CqrsError
- cqrs::CqrsEvent
- cqrs::CqrsEventDraft
- cqrs::CqrsOptions
- cqrs::CqrsProjection
- cqrs::CqrsProjectionError
- cqrs::CqrsProjectionOptions
- cqrs::CqrsProjectionStatus
- cqrs::CqrsStatus
- cqrs::messaging::CqrsDeliveredCommand
- cqrs::messaging::CqrsMessageAckOptions
- cqrs::messaging::CqrsMessagingPolicy
- cqrs::messaging::CqrsMessagingRecipeBundle
- cqrs::messaging::CqrsMessagingRecipeOptions
- cqrs::messaging::MessageBusDelivery
- cqrs::work_queue::CqrsQueuedCommandPayload
- cqrs::work_queue::CqrsWorkQueueAttempt
- cqrs::work_queue::CqrsWorkQueuePolicy
- cqrs::work_queue::CqrsWorkQueueRecipeBundle
- cqrs::work_queue::CqrsWorkQueueRecipeOptions
- ctx::Ctx
- ctx::DeferredCtx
- data_structures::IndexRow
- data_structures::ReactiveIndex
- data_structures::ReactiveIndexOptions
- data_structures::ReactiveList
- data_structures::ReactiveListOptions
- data_structures::ReactiveLog
- data_structures::ReactiveLogOptions
- data_structures::ReactiveMap
- data_structures::ReactiveMapOptions
- data_structures::ReactiveView
- diagnostics::CausalChain
- diagnostics::CausalStep
- diagnostics::DescribeChangeset
- diagnostics::ExplainPathOptions
- diagnostics::IslandReport
- diagnostics::ProfileSummary
- diagnostics::ProfileSummaryNode
- diagnostics::ProfileSummaryOptions
- diagnostics::ProfileSummaryStatus
- diagnostics::ReachableOptions
- diagnostics::ReachableResult
- diagnostics::ValidateNoIslandsResult
- dispatcher::Dispatcher
- dispatcher::ProfileStat
- environment::EnvironmentDrivers
- environment::HttpRequest
- environment::HttpResponse
- environment::HttpStreamHead
- environment::ProcessCommand
- environment::ProcessResult
- environment::SseEvent
- environment::SseRequest
- environment::TokioHttpDriver
- environment::TokioHttpStreamDriver
- environment::TokioProcessDriver
- environment::TokioWebSocketDriver
- environment::WebSocketRequest
- environment::WebSocketSend
- environment::WebSocketSendResult
- environment::WebhookEvent
- environment::WebhookRegistration
- graph::DescribeEdge
- graph::DescribeNode
- graph::DescribeOpts
- graph::DescribeSnapshot
- graph::Explain
- graph::Graph
- graph::GraphNode
- graph::GraphNodeOpts
- graph::GraphObserver
- graph::GraphOptions
- graph::GraphTopologyObserver
- graph::NodeProfile
- graph::ObserveEvent
- graph::ObserveStream
- graph::Profile
- graph::RestoreFactoryMeta
- graph::TopologyEvent
- graph::TopologyGroup
- graph::TopologyGroupOptions
- graph::TopologyStream
- graph::Values
- higher_order::MergeMapOptions
- json::JsonCodec
- json::StrictJsonCodec
- messaging::DataIssue
- messaging::EventMessage
- messaging::EventMessageOptions
- messaging::JsonSchema
- messaging::JsonSchemaValidationError
- messaging::MessageBus
- messaging::MessageBusAvailablePage
- messaging::MessageBusAvailableParams
- messaging::MessageBusCatalogEntry
- messaging::MessageBusCatalogPage
- messaging::MessageBusCatalogParams
- messaging::MessageBusCursor
- messaging::MessageBusDeadLetterEntry
- messaging::MessageBusDeadLetterPage
- messaging::MessageBusDeadLetterParams
- messaging::MessageBusDedupePolicy
- messaging::MessageBusOptions
- messaging::MessageBusPullProjection
- messaging::MessageBusRetentionPolicy
- messaging::MessageBusStatus
- messaging::MessageBusSubscription
- messaging::MessageBusSubscriptionOptions
- messaging::MessageBusTopicPage
- messaging::MessageBusTopicParams
- messaging::MessageEnvelope
- messaging::ToTopicBundle
- messaging::TopicMessage
- node::Core
- node::Node
- node::NodeOpts
- operators::Operator
- patterns::AdmissionScore3DOptions
- patterns::AdmissionScoredOptions
- patterns::AdmissionScores
- patterns::CollectionEntry
- patterns::FactStore
- patterns::KnowledgeAssertion
- patterns::KnowledgeGraphCursor
- patterns::KnowledgeGraphEntity
- patterns::KnowledgeGraphError
- patterns::KnowledgeGraphIndex
- patterns::KnowledgeGraphPolicy
- patterns::KnowledgeGraphReducerBundle
- patterns::KnowledgeGraphReducerBundleOptions
- patterns::KnowledgeGraphRelation
- patterns::KnowledgeGraphSnapshot
- patterns::KnowledgeGraphStatus
- patterns::KnowledgeGraphTopic
- patterns::MemoryAnswer
- patterns::MemoryFragment
- patterns::MemoryFragmentValidation
- patterns::MemoryQuery
- patterns::MemoryRetrievalBundle
- patterns::MemoryRetrievalBundleOptions
- patterns::MemoryRetrievalCursor
- patterns::MemoryRetrievalError
- patterns::MemoryRetrievalIndex
- patterns::MemoryRetrievalQuery
- patterns::MemoryRetrievalSnapshot
- patterns::MemoryRetrievalStatus
- patterns::OutcomeSignal
- patterns::RankedCollectionEntry
- patterns::RetrievalEntry
- patterns::RetrievalQuery
- patterns::RetrievalTrace
- patterns::ShardByTenantConfig
- patterns::ShardByTenantOptions
- patterns::StoreReadHandle
- patterns::VectorSearchResult
- process::ProcessAuditRecord
- process::ProcessBundle
- process::ProcessBundleOptions
- process::ProcessCommand
- process::ProcessCursor
- process::ProcessEffectCommandPayload
- process::ProcessEffectOutcome
- process::ProcessEffectRequest
- process::ProcessEffectRequestDraft
- process::ProcessEffectRunnerBundle
- process::ProcessEffectRunnerError
- process::ProcessEffectRunnerOptions
- process::ProcessEffectRunnerStatus
- process::ProcessError
- process::ProcessEvent
- process::ProcessEventDraft
- process::ProcessReduction
- process::ProcessStatus
- process::messaging::MessageBusDelivery
- process::messaging::ProcessDeliveredCommand
- process::messaging::ProcessMessageAckOptions
- process::messaging::ProcessMessagingPolicy
- process::messaging::ProcessMessagingRecipeBundle
- process::messaging::ProcessMessagingRecipeOptions
- process::work_queue::ProcessQueueAuditRecord
- process::work_queue::ProcessQueueEvidence
- process::work_queue::ProcessQueueStatus
- process::work_queue::ProcessQueuedEffectPayload
- process::work_queue::ProcessWorkQueueRecipeBundle
- process::work_queue::ProcessWorkQueueRecipeOptions
- protocol::Handle
- protocol::LockId
- protocol::PullDemand
- resilience::BreakerStatus
- resilience::RateLimitBundle
- resilience::RateLimitStatus
- resilience::RetryPolicy
- resilience::RetryStatus
- resilience::TimeoutBundle
- scheduled_readiness::ScheduledReadinessAuditRecord
- scheduled_readiness::ScheduledReadinessBundle
- scheduled_readiness::ScheduledReadinessClock
- scheduled_readiness::ScheduledReadinessOptions
- scheduled_readiness::ScheduledReadinessOverdue
- scheduled_readiness::ScheduledReadinessPending
- scheduled_readiness::ScheduledReadinessReady
- scheduled_readiness::ScheduledReadinessRequested
- scheduled_readiness::ScheduledReadinessStatus
- scheduled_readiness::ScheduledReadinessViews
- scheduled_readiness::SourceRef
- solutions::AgenticMemoryBundle
- solutions::AgenticMemoryBundleOptions
- solutions::AgenticMemoryConsolidationBundle
- solutions::AgenticMemoryConsolidationBundleOptions
- solutions::AgenticMemoryConsolidationCommand
- solutions::AgenticMemoryConsolidationCursor
- solutions::AgenticMemoryConsolidationRecordDraft
- solutions::AgenticMemoryConsolidationRequest
- solutions::AgenticMemoryConsolidationResult
- solutions::AgenticMemoryConsolidationSnapshot
- solutions::AgenticMemoryConsolidationStatus
- solutions::AgenticMemoryContext
- solutions::AgenticMemoryContextEntry
- solutions::AgenticMemoryContextPackingBundle
- solutions::AgenticMemoryContextPackingBundleOptions
- solutions::AgenticMemoryContextPackingCursor
- solutions::AgenticMemoryContextPackingPolicy
- solutions::AgenticMemoryContextPackingSnapshot
- solutions::AgenticMemoryContextPackingStatus
- solutions::AgenticMemoryCursor
- solutions::AgenticMemoryError
- solutions::AgenticMemoryFieldValidation
- solutions::AgenticMemoryKgAssertionDraft
- solutions::AgenticMemoryKgProjectionBundle
- solutions::AgenticMemoryKgProjectionBundleOptions
- solutions::AgenticMemoryKgProjectionCursor
- solutions::AgenticMemoryKgProjectionSnapshot
- solutions::AgenticMemoryKgProjectionStatus
- solutions::AgenticMemoryPackedContext
- solutions::AgenticMemoryProjection
- solutions::AgenticMemoryRecord
- solutions::AgenticMemoryRecordFrame
- solutions::AgenticMemoryRecordFrameCodec
- solutions::AgenticMemoryRecordMetadata
- solutions::AgenticMemoryRecordValidation
- solutions::AgenticMemoryRetentionBundle
- solutions::AgenticMemoryRetentionBundleOptions
- solutions::AgenticMemoryRetentionCommand
- solutions::AgenticMemoryRetentionCursor
- solutions::AgenticMemoryRetentionSnapshot
- solutions::AgenticMemoryRetentionStatus
- solutions::AgenticMemoryScope
- solutions::AgenticMemorySourceProjection
- solutions::AgenticMemoryStatus
- solutions::AgenticMemoryTextProjection
- sources::CronInstant
- sources::CronParseError
- sources::CronSchedule
- sources::CronTick
- sources::FromCronOptions
- sources::FromFsWatchOptions
- sources::FromGitHookOptions
- sources::FsEvent
- sources::GitEvent
- storage::AppendLogEntry
- storage::AppendLogPage
- storage::AppendLogReadOptions
- storage::AppendLogStorage
- storage::ChangeEnvelope
- storage::ChangeEnvelopeCodec
- storage::ChangeEnvelopeOptions
- storage::CodecKvStorage
- storage::ContentAddressedKv
- storage::ContentAddressedKvOptions
- storage::FileAppendLogOptions
- storage::FileBackend
- storage::FileBackendOptions
- storage::KvGeneration
- storage::LoadReactiveCollectionStateOptions
- storage::MemoryKv
- storage::MultiWriterAppendLogStorage
- storage::ObserveEventFrame
- storage::ObserveEventFrameCodec
- storage::ObserveEventFrameOptions
- storage::ReactiveCollectionChangeFrame
- storage::ReactiveCollectionChangeFrameCodec
- storage::ReactiveCollectionChangesRestoreMeta
- storage::ReactiveCollectionRestoreState
- storage::ReactiveCollectionSnapshotFrame
- storage::ReactiveCollectionSnapshotFrameCodec
- storage::ReactiveCollectionSnapshotRestoreMeta
- storage::ReadThroughErrorContext
- storage::ReadThroughLookupFact
- storage::ReadThroughLookupTier
- storage::ReadThroughMissContext
- storage::ReadThroughPromotionFact
- storage::TieredReadThroughOptions
- storage::TieredReadThroughResult
- storage::WalFrame
- storage::WalFrameBody
- storage::WalFrameCodec
- storage::WalFrameOptions
- work_queue::WorkQueue
- work_queue::WorkQueueActiveLease
- work_queue::WorkQueueAvailableItem
- work_queue::WorkQueueAvailablePage
- work_queue::WorkQueueAvailableParams
- work_queue::WorkQueueAvailableProjection
- work_queue::WorkQueueClaimOptions
- work_queue::WorkQueueDeadLetterPage
- work_queue::WorkQueueDeadLetterParams
- work_queue::WorkQueueMessageBusRef
- work_queue::WorkQueueOptions
- work_queue::WorkQueueProjection
- work_queue::WorkQueueStatus
- work_queue::WorkQueueSubmit
- work_queue::WorkQueueSubmitOptions
- work_queue::WorkQueueWorkSnapshot
- work_queue::readiness::WorkQueueLeaseExpirationCommandProjectorOptions
- work_queue::readiness::WorkQueueReadinessCandidate
- work_queue::readiness::WorkQueueReadinessHandoffBundle
- work_queue::readiness::WorkQueueReadinessHandoffOptions
- work_queue::readiness::WorkQueueReadinessStatus
- work_queue::readiness::WorkQueueReadinessViews
- work_queue::readiness::WorkQueueScheduledReadinessBundle
- work_queue::readiness::WorkQueueScheduledReadinessOptions
Enums
- NodeVersion
- NodeVersioningPolicy
- ResolvedNodeVersioningPolicy
- adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceStatus
- adapters::bridge::RemoteCallResponse
- adapters::bridge::RemoteCallStatusState
- adapters::bridge::RemoteResponderEvent
- adapters::bridge::RemoteResponderStatusState
- adapters::bridge::WireBridgeCommand
- adapters::bridge::WireBridgeEnvelopeError
- adapters::bridge::WireBridgeEnvelopeType
- adapters::bridge::WireBridgeEvent
- adapters::bridge::WireBridgeIngress
- adapters::bridge::WireBridgePayload
- adapters::bridge::WireBridgeReceipt
- adapters::bridge::WireBridgeStatusState
- adapters::bridge::WireEdgeGroupIssueCode
- adapters::bridge::WireEdgeGroupStatusState
- adapters::bridge_protobuf::CanonicalProtobufErrorCategory
- adapters::bridge_protobuf::CanonicalWireBridgeDataBody
- adapters::bridge_protobuf::CanonicalWireBridgePayload
- adapters::bridge_protobuf::CanonicalWireEdgeKind
- adapters::bridge_protobuf::WireBridgeProtobufDataBody
- adapters::bridge_protobuf::WireBridgeProtobufPayload
- adapters::bridge_protobuf::WireBridgeProtobufStatusKind
- adapters::environment::OutboundEvent
- adapters::environment::OutboundState
- adapters::environment::WebSocketSessionCommand
- adapters::environment::WebSocketSessionInbound
- adapters::environment::WebSocketSessionLifecycle
- adapters::environment::WebSocketSessionOutbound
- adapters::environment::WebSocketSessionSendPolicy
- adapters::environment::WebSocketSessionStateKind
- adapters::observe_storage::ObserveEventLogErrorPhase
- adapters::reactive_collection_storage::ReactiveCollectionPersistenceStatus
- cascading_cache::CascadingCacheEvent
- cascading_cache::CascadingCacheStatus
- checkpoint::GraphCheckpointFactory
- checkpoint::GraphCheckpointTerminal
- checkpoint::GraphCheckpointValue
- checkpoint::GraphRestoreEntry
- checkpoint::RestoreNodeKind
- cqrs::CqrsAuditOutcome
- cqrs::CqrsDedupeWindow
- cqrs::CqrsErrorCode
- cqrs::CqrsProjectionErrorCode
- cqrs::CqrsProjectionFrame
- cqrs::CqrsProjectionStatusState
- cqrs::CqrsRuntimeFact
- cqrs::CqrsStatusState
- cqrs::work_queue::CqrsWorkQueueOutcome
- ctx::DepTerminal
- ctx::WaveData
- data_structures::IndexChange
- data_structures::ListChange
- data_structures::LogChange
- data_structures::MapChange
- diagnostics::DescribeEvent
- diagnostics::ExplainPathReason
- diagnostics::ReachableDirection
- dispatcher::PoolKind
- environment::HttpStreamDriverEvent
- environment::SseDriverEvent
- environment::WebSocketDriverEvent
- environment::WebSocketEvent
- environment::WebhookDriverEvent
- graph::DescribeValue
- graph::ObserveMessage
- graph::TopologyEventKind
- json::JsonCodecError
- messaging::JsonSchemaAdditionalProperties
- messaging::JsonSchemaItems
- messaging::JsonSchemaType
- messaging::JsonSchemaTypeSpec
- messaging::MessageBusCommand
- messaging::MessageBusDedupeAction
- messaging::MessageBusStatusKind
- messaging::MessageBusSubscriptionFrom
- messaging::MessageBusTopicPolicy
- node::Pausable
- node::Status
- patterns::KnowledgeAssertionObject
- patterns::KnowledgeGraphErrorCode
- patterns::KnowledgeGraphStatusState
- patterns::MemoryRetrievalErrorCode
- patterns::MemoryRetrievalStatusState
- patterns::RetrievalEntrySource
- process::ProcessAuditOutcome
- process::ProcessEffectCommandType
- process::ProcessEffectOutcomeKind
- process::ProcessEffectRunnerErrorCode
- process::ProcessEffectRunnerStatusState
- process::ProcessErrorCode
- process::ProcessRuntimeFact
- process::ProcessStatusState
- protocol::Message
- protocol::Tier
- render::DiagramDirection
- resilience::BackoffPolicy
- resilience::BreakerState
- resilience::RetryEvent
- resilience::RetryState
- resilience::TimeoutStatus
- scheduled_readiness::ScheduledReadinessStatusState
- solutions::AgenticMemoryArtifactKind
- solutions::AgenticMemoryConsolidationCommandKind
- solutions::AgenticMemoryConsolidationOutcome
- solutions::AgenticMemoryConsolidationResultState
- solutions::AgenticMemoryErrorCode
- solutions::AgenticMemoryKind
- solutions::AgenticMemoryPersistenceLevel
- solutions::AgenticMemoryRetentionCommandKind
- solutions::AgenticMemoryStatusState
- sources::FsEventKind
- sources::GitHookType
- sources::SyncValueFromError
- storage::ChangeLifecycle
- storage::ContentAddressedMode
- storage::KvVersionedRead
- storage::PromotionPolicy
- storage::ReactiveCollectionKind
- storage::ReactiveCollectionRestoreSource
- storage::ReadThroughErrorStage
- storage::ReadThroughOutcome
- storage::StorageError
- storage::TieredReadThroughStatus
- work_queue::WorkQueueCommand
- work_queue::WorkQueueDerivedState
- work_queue::WorkQueueRecord
- work_queue::WorkQueueStatusKind
- work_queue::readiness::WorkQueueReadinessCandidateKind
- work_queue::readiness::WorkQueueReadinessScheduleKind
- work_queue::readiness::WorkQueueReadinessStatusState
Traits
- async_driver::LocalAsyncDriver
- checkpoint::GraphRestoreDescriptor
- environment::LocalHttpDriver
- environment::LocalHttpStreamDriver
- environment::LocalProcessDriver
- environment::LocalSseDriver
- environment::LocalWebSocketDriver
- environment::LocalWebSocketSession
- environment::LocalWebhookDriver
- json::Codec
- storage::AppendLogStorageTier
- storage::ByteStorageBackend
- storage::KvStorageTier
Functions
- adapters::agentic_memory_storage::agentic_memory_record_change_frame
- adapters::agentic_memory_storage::agentic_memory_record_snapshot_frame
- adapters::agentic_memory_storage::agentic_memory_records_snapshot_key
- adapters::agentic_memory_storage::load_agentic_memory_records_state
- adapters::agentic_memory_storage::open_persistent_agentic_memory_records
- adapters::agentic_memory_storage::persist_agentic_memory_records
- adapters::bridge::remote_call
- adapters::bridge::remote_call_with_options
- adapters::bridge::remote_responder
- adapters::bridge::remote_responder_handler
- adapters::bridge::wire_bridge
- adapters::bridge::wire_bridge_envelope
- adapters::bridge::wire_bridge_idempotency_key
- adapters::bridge::wire_edge_group
- adapters::bridge_protobuf::decode_canonical_wire_bridge_envelope
- adapters::bridge_protobuf::decode_canonical_wire_edge_frame
- adapters::bridge_protobuf::decode_wire_bridge_protobuf_bytes
- adapters::bridge_protobuf::encode_canonical_wire_bridge_envelope
- adapters::bridge_protobuf::encode_canonical_wire_edge_frame
- adapters::bridge_protobuf::encode_wire_bridge_protobuf_bytes
- adapters::environment::to_http
- adapters::environment::to_http_with_options
- adapters::environment::to_process
- adapters::environment::to_process_with_options
- adapters::environment::to_websocket
- adapters::environment::to_websocket_with_options
- adapters::environment::websocket_session
- adapters::environment::websocket_session_with_options
- adapters::observe_storage::attach_observe_event_log
- adapters::reactive_collection_storage::open_persistent_reactive_index
- adapters::reactive_collection_storage::open_persistent_reactive_list
- adapters::reactive_collection_storage::open_persistent_reactive_log
- adapters::reactive_collection_storage::open_persistent_reactive_map
- adapters::reactive_collection_storage::persist_reactive_index
- adapters::reactive_collection_storage::persist_reactive_list
- adapters::reactive_collection_storage::persist_reactive_log
- adapters::reactive_collection_storage::persist_reactive_map
- batch::batch
- cascading_cache::reactive_cascading_cache
- checkpoint::default_restore_registry
- checkpoint::restore_graph
- checkpoint::restore_registry
- checkpoint::restored_opts
- combinators::buffer
- combinators::buffer_count
- combinators::combine
- combinators::combine_latest
- combinators::concat
- combinators::race
- combinators::sample
- combinators::take_until
- combinators::with_latest_from
- combinators::zip
- composition::pipe
- composition::stratify
- composition::stratify_branch
- cqrs::cqrs
- cqrs::cqrs_command_handler
- cqrs::cqrs_projection
- cqrs::cqrs_with_options
- cqrs::messaging::cqrs_event_outbox_commands
- cqrs::messaging::cqrs_message_ack_commands
- cqrs::messaging::cqrs_messaging_recipe
- cqrs::work_queue::cqrs_submit_command
- cqrs::work_queue::cqrs_work_queue_disposition_command
- cqrs::work_queue::cqrs_work_queue_recipe
- data_structures::merge_reactive_logs
- data_structures::reactive_index
- data_structures::reactive_list
- data_structures::reactive_log
- data_structures::reactive_map
- data_structures::restore_reactive_index
- data_structures::restore_reactive_list
- data_structures::restore_reactive_log
- data_structures::restore_reactive_map
- data_structures::scan_log
- default_node_version_hash
- diagnostics::explain_path
- diagnostics::profile_summary
- diagnostics::profile_summary_from_snapshots
- diagnostics::reachable
- diagnostics::topology_diff
- diagnostics::validate_no_islands
- dispatcher::default_dispatcher
- graph::graph
- graph::graph_opts
- higher_order::concat_map
- higher_order::exhaust_map
- higher_order::flat_map
- higher_order::merge_map
- higher_order::merge_map_with_options
- higher_order::repeat
- higher_order::switch_map
- json::assert_decimal_integer_string
- json::assert_non_negative_decimal_integer_string
- json::decimal_string_to_i128
- json::i128_to_decimal_string
- json::is_decimal_integer_string
- json::is_non_negative_decimal_integer_string
- json::json_codec_for
- json::non_negative_decimal_string_to_u128
- json::stable_json_string
- json::strict_canonical_json_bytes
- json::strict_json_codec_for
- json::strict_json_decode
- json::u128_to_non_negative_decimal_string
- json::validate_strict_json_value
- messaging::event_message
- messaging::is_json_schema_valid
- messaging::message_bus
- messaging::to_topic
- messaging::validate_json_schema
- messaging::validate_topic_message_payload
- operators::catch_error
- operators::distinct_until_changed
- operators::element_at
- operators::filter
- operators::find
- operators::first
- operators::first_any
- operators::init_node
- operators::last
- operators::last_any
- operators::map
- operators::merge
- operators::on_first_data
- operators::on_first_data_where
- operators::pairwise
- operators::reduce
- operators::rescue
- operators::scan
- operators::settle
- operators::settle_by
- operators::skip
- operators::take
- operators::take_while
- operators::tap
- operators::tap_first
- operators::valve
- patterns::admission_filter_3d
- patterns::admission_scored
- patterns::cosine_similarity
- patterns::filter_memory_fragments
- patterns::knowledge_graph_reducer_bundle
- patterns::memory_fragment_matches_query
- patterns::memory_fragment_valid_at
- patterns::memory_retrieval_bundle
- patterns::shard_by_tenant
- patterns::validate_memory_fragment
- process::messaging::process_event_outbox_commands
- process::messaging::process_message_ack_commands
- process::messaging::process_messaging_recipe
- process::process_bundle
- process::process_effect_runner
- process::work_queue::process_effect_submit_command
- process::work_queue::process_effect_submit_commands
- process::work_queue::process_work_queue_recipe
- render::describe_to_ascii
- render::describe_to_d2
- render::describe_to_d2_with_direction
- render::describe_to_json
- render::describe_to_mermaid
- render::describe_to_mermaid_url
- render::describe_to_mermaid_with_direction
- render::describe_to_pretty
- render::mermaid_live_url
- resilience::breaker_status_node
- resilience::rate_limit_bundle
- resilience::retry_status_node
- resilience::timeout_bundle
- scheduled_readiness::parse_scheduled_readiness_requested
- scheduled_readiness::readiness_issue
- scheduled_readiness::scheduled_readiness_projector
- solutions::agentic_memory_bundle
- solutions::agentic_memory_consolidation_bundle
- solutions::agentic_memory_context_packing_bundle
- solutions::agentic_memory_kg_projection_bundle
- solutions::agentic_memory_record_frame
- solutions::agentic_memory_record_frame_codec
- solutions::agentic_memory_retention_bundle
- solutions::validate_agentic_memory_artifact_kind
- solutions::validate_agentic_memory_kind
- solutions::validate_agentic_memory_persistence_level
- solutions::validate_agentic_memory_record
- solutions::validate_agentic_memory_scope
- sources::empty
- sources::first_sync_value_from
- sources::from_cron
- sources::from_cron_with_options
- sources::from_fs_watch
- sources::from_fs_watch_with_options
- sources::from_git_hook
- sources::from_git_hook_with_options
- sources::from_http
- sources::from_http_with_options
- sources::from_iter
- sources::from_process
- sources::from_sse
- sources::from_sse_with_options
- sources::from_timer
- sources::from_webhook
- sources::from_webhook_with_options
- sources::from_websocket
- sources::from_websocket_with_options
- sources::future_local
- sources::interval
- sources::matches_cron
- sources::never
- sources::of
- sources::parse_cron
- sources::run_process
- sources::run_process_with_options
- sources::single_sync_value_from
- sources::stream_local
- sources::throw_error
- sources::timer
- storage::append_log_key
- storage::append_log_storage
- storage::assert_change_envelope
- storage::assert_observe_event_frame
- storage::assert_reactive_collection_change_frame
- storage::assert_reactive_collection_snapshot_frame
- storage::assert_wal_frame
- storage::change_envelope_codec
- storage::codec_kv_storage
- storage::content_addressed_kv
- storage::content_addressed_storage
- storage::dict_kv
- storage::envelope_change
- storage::file_append_log
- storage::file_backend
- storage::file_kv
- storage::load_reactive_index_state
- storage::load_reactive_list_state
- storage::load_reactive_log_state
- storage::load_reactive_map_state
- storage::memory_append_log
- storage::memory_kv
- storage::memory_multi_writer_append_log
- storage::multi_writer_append_log_storage
- storage::now_ns
- storage::observe_event_frame
- storage::observe_event_frame_codec
- storage::reactive_collection_change_frame
- storage::reactive_collection_change_frame_codec
- storage::reactive_collection_snapshot_frame
- storage::reactive_collection_snapshot_frame_codec
- storage::reactive_collection_snapshot_key
- storage::read_append_log_page
- storage::read_observe_event_log_page
- storage::read_through_kv
- storage::tiered_read_through
- storage::verify_wal_frame_checksum
- storage::wal_frame
- storage::wal_frame_checksum
- storage::wal_frame_codec
- storage::wal_frame_key
- storage::wal_frame_prefix
- time::audit
- time::audit_time
- time::buffer_time
- time::debounce
- time::debounce_time
- time::delay
- time::throttle
- time::throttle_time
- time::timeout
- work_queue::readiness::work_queue_lease_expiration_command
- work_queue::readiness::work_queue_lease_expiration_command_projector
- work_queue::readiness::work_queue_readiness_handoff_projector
- work_queue::readiness::work_queue_scheduled_readiness_projector
- work_queue::work_queue
- worker::worker_derived
Type Aliases
- NodeVersionHashFn
- adapters::bridge::RemoteResponderHandler
- adapters::observe_storage::ObserveEventLogErrorFn
- adapters::observe_storage::ObserveEventLogMap
- async_driver::DriverCancel
- cascading_cache::ReactiveCascadingCacheLoadFn
- checkpoint::GraphCheckpointJson
- checkpoint::GraphRestoreResult
- cqrs::CqrsCommandHandler
- cqrs::CqrsProjectionReducer
- cqrs::messaging::CqrsMessageCommandFn
- dispatcher::NodeFn
- json::DecimalIntegerString
- json::JsonCodecResult
- json::JsonValue
- json::NonNegativeDecimalIntegerString
- messaging::JsonSchemaValidationResult
- messaging::MessageBusTopicProjection
- patterns::AdmissionScore3DFn
- patterns::AdmissionScoreFn
- patterns::AdmissionThresholds
- patterns::FactId
- patterns::MemoryRetrievalFact
- patterns::ShardByFn
- patterns::ShardKey
- patterns::TenantShardFn
- process::ProcessReducer
- process::ProcessReducerFn
- process::messaging::ProcessMessageCommandFn
- protocol::AnyValue
- protocol::GraphError
- protocol::Wave
- storage::ContentAddressedKeyContext
- storage::ContentAddressedStorage
- storage::ContentAddressedStorageOptions
- storage::FileKv
- storage::ObserveEventLogPage
- storage::ReactiveIndexRestoreState
- storage::ReactiveListRestoreState
- storage::ReactiveLogRestoreState
- storage::ReactiveMapRestoreState
- storage::ReadThroughErrorFn
- storage::ReadThroughLoadFn
- storage::ReadThroughMissFn
- storage::StorageResult
- storage::WalFrameTimestampNs
Constants
- adapters::agentic_memory_storage::AGENTIC_MEMORY_RECORD_CHANGE_FORMAT
- adapters::agentic_memory_storage::AGENTIC_MEMORY_RECORD_SNAPSHOT_FORMAT
- adapters::agentic_memory_storage::AGENTIC_MEMORY_RECORD_STORAGE_FRAME_VERSION
- adapters::bridge_protobuf::WIRE_BRIDGE_PROTOBUF_HELPER_SHAPE
- checkpoint::GRAPH_CHECKPOINT_VERSION
- dispatcher::ASYNC_POOL_ID
- dispatcher::SYNC_POOL_ID
- messaging::CONTEXT_TOPIC
- messaging::DEFERRED_TOPIC
- messaging::INJECTIONS_TOPIC
- messaging::PROMPTS_TOPIC
- messaging::RESPONSES_TOPIC
- messaging::SPAWNS_TOPIC
- messaging::STANDARD_TOPICS
- messaging::TODOS_TOPIC
- solutions::AGENTIC_MEMORY_RECORD_FRAME_FORMAT
- solutions::AGENTIC_MEMORY_RECORD_FRAME_VERSION
- storage::APPEND_LOG_SEQ_PAD
- storage::REACTIVE_COLLECTION_CHANGE_FORMAT
- storage::REACTIVE_COLLECTION_FRAME_VERSION
- storage::REACTIVE_COLLECTION_SNAPSHOT_FORMAT
- storage::WAL_FORMAT_VERSION
- storage::WAL_FRAME_SEQ_PAD
- storage::WAL_KEY_SEGMENT