Module utils

Macros§

delayed_panic 🔒: Delays the exit of the program for 15 seconds, to allow for logs to be flushed. Then panics with the given arguments.

Last20Bytes: Trait to extract last 20 bytes (for address derivation).
NamedEntity: A trait for entities that have a name, operator, verifier, etc. Used to distinguish between state machines with different owners in the database, and to provide a human-readable name for the entity for task names.
ScriptBufExt: Extension trait for [ScriptBuf].
TryLast20Bytes: Fallible version of Last20Bytes.

combine_errors: Collects errors from an iterator of results and returns a combined error if any failed.
flatten_join_named_results: Collects all errors (both outer and inner) from named task results and returns a combined error if any task failed.
get_vergen_response
initialize_logger: Initializes a [tracing] subscriber depending on the environment. [EnvFilter] is used with an optional default level. Sets up the color_eyre handler.
initialize_telemetry
join_all_partition_results: Executes a collection of fallible futures concurrently and partitions results into successes and errors.
monitor_standalone_task: Monitors a [tokio::task::JoinHandle] in the background and logs it’s end result.
timed_request: Wraps a future with a timeout, returning a Status::deadline_exceeded gRPC error if the future does not complete within the specified duration.
timed_request_base: Wraps a future with a timeout and adds a debug span with the description.
timed_try_join_all: Concurrently executes a collection of futures, applying a timeout to each one individually. If any future fails or times out, the entire operation is aborted and an error is returned.
try_join_all_combine_errors: Executes a collection of fallible futures concurrently and aggregates failures into a single [BridgeError].