List of all items
Structs
- call::Call
- client_data_store::ClientDataStoreManager
- context::InvocationContext
- context::RunnerContext
- error::TaskError
- invocation::InvocationHandle
- invocation::SyncInvocation
- logging::LogConfig
- observability::CompositeEmitter
- observability::NoopEmitter
- observability::WorkerState
- orchestrator::ActiveRunnerInfo
- orchestrator::AtomicServiceExecution
- prelude::AppConfig
- prelude::CallDTO
- prelude::CallId
- prelude::ClientDataStoreConfig
- prelude::CompositeCondition
- prelude::ConditionId
- prelude::ConfigParseError
- prelude::CronCondition
- prelude::CronContext
- prelude::EventCondition
- prelude::EventContext
- prelude::ExceptionCondition
- prelude::ExceptionContext
- prelude::InvocationDTO
- prelude::InvocationHistory
- prelude::InvocationId
- prelude::InvocationStatusRecord
- prelude::OwnershipError
- prelude::ParseTaskIdError
- prelude::ResultCondition
- prelude::ResultContext
- prelude::RunnerId
- prelude::SerializedArguments
- prelude::StatusCondition
- prelude::StatusContext
- prelude::StatusDefinition
- prelude::StatusTransitionError
- prelude::TaskConfig
- prelude::TaskId
- prelude::TriggerDefinitionDTO
- prelude::TriggerDefinitionId
- prelude::TriggerRunId
- prelude::ValidCondition
- prelude::WorkflowIdentity
- serializer::SerdeSerializer
- state_backend::StoredRunnerContext
- task::TaskDefinition
- task::TaskRegistry
- trigger::TriggerManager
- workflow::DeterministicExecutor
Enums
- error::InfraErrorKind
- error::RustvelloError
- invocation::Invocation
- logging::LogFormat
- logging::LogStream
- observability::EventLevel
- observability::LastResult
- prelude::ArgumentPrintMode
- prelude::CompositeLogic
- prelude::ConcurrencyControlType
- prelude::ConditionContext
- prelude::InvocationStatus
- prelude::LogFormat
- prelude::ParseCallIdError
- prelude::StatusMachineError
- prelude::TriggerCondition
- prelude::TriggerLogic
Traits
- broker::Broker
- client_data_store::ClientDataStore
- middleware::TaskMiddleware
- observability::EventEmitter
- orchestrator::Orchestrator
- orchestrator::OrchestratorBlocking
- orchestrator::OrchestratorConcurrency
- orchestrator::OrchestratorQuery
- orchestrator::OrchestratorRecovery
- orchestrator::OrchestratorStatus
- reconnectable::Reconnectable
- runner::Runner
- serializer::Serializer
- state_backend::StateBackend
- state_backend::StateBackendCore
- state_backend::StateBackendQuery
- state_backend::StateBackendRunner
- task::CrossLanguageSafe
- task::DynTask
- task::ForeignTask
- task::Task
- task::TaskModule
- trigger::TriggerStore
Functions
- call::call_dto_from_parts
- client_data_store::generate_reference_key
- client_data_store::is_reference
- context::clear_thread_invocation_context
- context::clear_thread_runner_context
- context::get_invocation_context
- context::get_or_create_runner_context
- context::get_or_create_runner_id
- context::get_runner_context
- context::set_thread_invocation_context
- context::set_thread_runner_context
- context::with_invocation_context
- context::with_runner_context
- error::lock_err
- error::status_machine_error_to_rustvello
- prelude::compute_new_owner
- prelude::get_initial_definition
- prelude::get_status_definition
- prelude::status_record_transition
- prelude::validate_ownership
- prelude::validate_transition
- task::serialized_args_to_json