List of all items
Structs
- config::ShardingConfig
- cron::ClusterCron
- cron::CronSchedule
- detachment::DetachedState
- entity::EntityContext
- entity_client::EntityClient
- entity_manager::EntityManager
- entity_reaper::EntityReaper
- entity_resource::EntityResource
- envelope::AckChunk
- envelope::EnvelopeRequest
- envelope::Interrupt
- metrics::ClusterMetrics
- reply::ReplyChunk
- reply::ReplyWithExit
- resource_map::ResourceEntry
- resource_map::ResourceMap
- runner::Runner
- runner_storage::BatchAcquireResult
- runner_storage::BatchRefreshResult
- runner_storage::LeaseHealth
- schema::DefaultShardGroupResolver
- shard_assigner::ShardAssigner
- sharding_impl::ShardingImpl
- single_runner::SingleRunner
- singleton::SingletonBuilder
- singleton::SingletonContext
- snowflake::Snowflake
- snowflake::SnowflakeGenerator
- snowflake::SnowflakeParts
- state_guard::ActivityScope
- state_guard::ActivityTx
- state_guard::SqlTransactionHandle
- storage::noop_health::NoopRunnerHealth
- storage::noop_runners::NoopRunners
- storage::sql_message::SqlMessageStorage
- storage::sql_workflow_journal::SqlJournalTransaction
- storage::sql_workflow_journal::SqlWorkflowStorage
- storage::sql_workflow_runtime::SqlWorkflowEngine
- transport::grpc::GrpcRunnerHealth
- transport::grpc::GrpcRunnerServer
- transport::grpc::GrpcRunners
- transport::grpc::proto::NotifyRequest
- transport::grpc::proto::NotifyResponse
- transport::grpc::proto::PingRequest
- transport::grpc::proto::PingResponse
- transport::grpc::proto::ReplyMessage
- transport::grpc::proto::SendRequest
- transport::grpc::proto::runner_service_client::RunnerServiceClient
- transport::grpc::proto::runner_service_server::RunnerServiceServer
- types::EntityAddress
- types::EntityId
- types::EntityType
- types::MachineId
- types::MachineIdError
- types::RunnerAddress
- types::ShardId
- types::SingletonAddress
Enums
- detachment::DetachmentReason
- envelope::Envelope
- error::ClusterError
- message::IncomingMessage
- message::OutgoingMessage
- message_storage::SaveResult
- reply::ExitResult
- reply::Reply
- schema::Uninterruptible
- shard_assigner::ShardAssignmentStrategy
- sharding::ShardingRegistrationEvent
- snowflake::SnowflakeError
Traits
- entity::Entity
- entity::EntityHandler
- entity_client::EntityClientAccessor
- entity_client::WorkflowClientFactory
- message_storage::MessageStorage
- runner_health::RunnerHealth
- runner_storage::RunnerStorage
- runners::Runners
- schema::Persisted
- schema::ShardGroupResolver
- sharding::Sharding
- transport::grpc::proto::runner_service_server::RunnerService
Attribute Macros
- activity_group
- activity_group_impl
- entity
- entity_impl
- entity_trait
- entity_trait_impl
- prelude::activity
- prelude::activity_group
- prelude::activity_group_impl
- prelude::entity
- prelude::entity_impl
- prelude::entity_trait
- prelude::entity_trait_impl
- prelude::private
- prelude::protected
- prelude::public
- prelude::rpc
- prelude::rpc_group
- prelude::rpc_group_impl
- prelude::state
- prelude::workflow
- prelude::workflow_impl
- rpc_group
- rpc_group_impl
- workflow_impl
Functions
- hash::djb2_hash
- hash::djb2_hash64
- hash::djb2_hash64_with_seed
- hash::hash64
- hash::sha256_hex
- hash::shard_for_entity
- reply::dead_letter_reply_id
- reply::fallback_reply_id
- singleton::register_singleton
- singleton::register_singletons
- singleton::singleton
- storage::migrate
- storage::sql_workflow_journal::save_journal_entry