Filters `account_ids` down to the subset classified as network accounts.

Returns the commitment of the final account state.

Freeze the rate at the current value. Idempotent — first freeze wins.

Generates a module containing the service's interface and implementation, including the methods.

Generates protobuf bindings from the given file descriptor set and stores them in the given destination directory.

Generate server facade modules (one per service) from the provided descriptor sets.

Builds the [`ExponentialBuilder`] used to back off retries on transient genesis-discovery failures.

Retrieves the value associated with the given block number from the cache.

Fetches the transaction inputs for a specific account. These inputs reference a specific `block_num`, and include a minimal partial account, plus its

Returns the [`BatchId`] mapped to this transaction, if any.

Fetches the inputs for a transaction batch from the database. ## Inputs The function takes as input: - The tx reference blocks are the set of blocks

Returns data needed by the block producer to construct and prove the next block.

Get account and nullifier witnesses for the requested account IDs and nullifier as well as the [`PartialMmr`] for the given blocks. The MMR won't cont

Get the genesis block header.

Reads the genesis block commitment persisted at bootstrap.

Fetches the genesis block header from the store. Automatically retries until the store connection becomes available.

Gets the account state commitment at the latest block.

Retrieves multiple values from the cache while holding the cache lock once.

Returns the script for a note by its root.

Returns the status for a note identified by its note ID.

Enumerates a storage map as it is stored in the SMT. Storage map keys are hashed before insertion, so returned keys are hashed SMT keys rather than t

Handles a single actor request then acknowledges the actor. Runs on the pinned loop connection so the actors' shared pool cannot starve these writes.

Handles the failure of a task. Waits for any task to complete or fail and returns an error. Since components are expected to run indefinitely, any ta

Applies a successful increment: advances the local wallet by the transaction's account delta, bumps the success count, and returns the value used as t

Update latency tracking state, performing RPC as needed while minimizing lock hold time.

Returns `true` if there are notes available for consumption by the given account.

Returns `true` if a notification is queued but not yet consumed by the actor. Used after an actor has shut down to detect the race where a notificati

Returns the number of historical blocks currently stored.

Returns the commitment of the initial account state.

Updates the forest with storage map changes from a delta and returns updated roots. Assumes that storage maps for the provided account are not in the

Inserts asset vault data into the forest for the specified account. Assumes that asset vault for this account does not yet exist in the forest.

Persists a note script to the local cache.

Converts from `InteractError` Note: Required since `InteractError` has at least one enum variant that is _not_ `Send + Sync` and hence prevents the `

Converts a terminal stream error into the gRPC status sent to the client.

Returns `true` if no more transaction resources can be consumed from this budget.

Returns `true` if the given node is a leaf node aka has no children.

Returns `true` if the batch has been proven previously.

Walk the error source chain looking for a tonic status or transport error. We classify resource-exhausted, unavailable, deadline-exceeded, and any tra