Resets back off and stops rate limiting requests.

Returns updated back off if no other thread increased it in the mean time.

Retries `f` while the error is a transient transport failure (`is_node_error`). Contract reverts and decoding failures bail out immediately. On giveup

Retry on every error.

Create a request for the driver /reveal endpoint.

Whether there is a reasonable risk of this solution reverting on chain.

Re-simulate a single solution and return its id if it started reverting on this block. Reports metrics and solver notifications as a side effect.

Rotates to the next backend by moving the current backend to the end of the queue.

Builds the axum `Router` for the pool-indexer API, and mounts the routes and the metrics middleware.

Creates an [`RpcClient`] from the given URL with [`LabelingLayer`], [`InstrumentationLayer`], [`TracingRequestIdLayer`], [`BatchCallLayer`] and [`RpcH

Assumes tracing and metrics registry have already been set up.

Drain the update stream until it ends or the decoder hangs up. Recoverable stream errors never reach this loop: the `AutoReconnect` wrapper handles t

Main loop. Drains the channel and routes each transaction's tracked instructions to their per-program decoders. Returns when the ingester drops the se

Runs all the maintenance tasks that are needed to ensure the next auction gets built using the most up-to-date information.

Runs all the maintenance tasks that should run eventually but are not very time sensitive.

Creates a SanitizedPriceEstimator that is used for native price estimations

Scales the passed `amount` based on the `executed_amount`.

Converts a token decimal count to its corresponding scaling exponent.

Given two solutions returns the factors with which prices of the second solution would have to be multiplied so that the given token would have the sa

Retrieves the scaling exponents for the specified tokens.

One entry per known event type, mapping the NATS subject to the JSON schema of the full [`Envelope`]-wrapped wire format consumers receive. Drives the

Observe the settlement score.

Score as defined per CIP38. Equal to surplus + protocol fees.

Returns the total scores for each directed token pair of the solution. E.g. if a solution contains 3 orders like: sell A for B with a score of 10 sell

Observe that scoring is about to start.

Seeds pools and ticks from the subgraph and returns the seeded block. The caller catches up from there via `UniswapV3Indexer::catch_up`.

The sell amount with the surplus factor.

Observe how long serializing and streaming the solve request body to a solver took, both the isolated serialization cost and the total including the s