Crate dynamo_runtime

Crate dynamo_runtime 

Source
Expand description

Dynamo

Re-exports§

pub use system_status_server::SystemStatusServerInfo;
pub use worker::Worker;

Modules§

component
The Component module defines the top-level API for building distributed applications.
discovery
distributed
engine
Asynchronous Engine System with Type Erasure Support
instances
Instance management functions for the distributed runtime.
logging
Dynamo Distributed Logging Module.
metrics
Metrics registry trait and implementation for Prometheus metrics
pipeline
prelude
protocols
runnable
Runnable Module.
runtime
The Runtime module is the interface for crate::component::Component to access shared resources. These include thread pool, memory allocators and other shared resources.
service
slug
storage
stream
Asynchronous streams.
system_status_server
traits
transports
The Transports module hosts all the network communication stacks used for talking to services or moving data around the network.
utils
worker
The Worker class is a convenience wrapper around the construction of the Runtime and execution of the users application.

Macros§

error
Construct an ad-hoc error from a string or existing non-anyhow error value.
raise
Return early with an error.

Structs§

CancellationToken
A token which can be used to signal a cancellation request to one or more tasks.
DistributedRuntime
Distributed Runtime which provides access to shared resources across the cluster, this includes communication protocols and transports.
Error
The Error type, a wrapper around a dynamic error type.
MetricsRegistryEntry
Structure to hold Prometheus registries and associated callbacks for a given hierarchy
Runtime
Local Runtime which provides access to shared resources local to the physical node/machine.
RuntimeConfig
Runtime configuration Defines the configuration for Tokio runtimes
SystemHealth
Current Health Status If use_endpoint_health_status is set then initialize the endpoint_health hashmap to the starting health status

Traits§

ErrorContext
Provides the context method for Result.

Functions§

OK
Equivalent to Ok::<_, anyhow::Error>(value).

Type Aliases§

Result
Result<T, Error>