Recover the public key from a Secp256k1 Based on how `Signature` does it, but without the final address hashing.

Removes the all the keys above the target value, exclusive.

Remove a subnet no longer supported by this node.

Gather any messages that have been enabled by transactions added to a block. These are removed from the cache, submission is only attempted once.

Remove the sender of a web socket.

Replaces the built in actor with custom actor. This assumes the system actor is already created, else it would throw an error.

Handle the results from a resolve attempt. If it succeeded, notify the listener. Otherwise if we have fallback peers to try, start another query and s

Indicate whether we have configured the IPLD Resolver to run.

Handle requests in a loop, interpreting each message as a JSON-RPC request. Messages are evaluated one by one. We could spawn tasks like Forest, but

Start running all services

Run the bottom up checkpoint submission daemon in the foreground

The HTTP interface provides JSON-RPC request/response endpoints.

The HTTP interface provides JSON-RPC request/response endpoints.

The HTTP interface provides JSON-RPC request/response endpoints.

Spawn a Tendermint subscription handler in a new task. The subscription sends [Event] records to the driver over a channel.

The WebSocket interface provides JSON-RPC request/response interactions as well as subscriptions, both using messages over the socket. We subscribe t

Take a chunk sent to us by a remote peer. This is our chance to validate chunks on the fly. Returns `None` while there are more chunks to download an

Part of error handling. In our case we enqueued the task from transaction processing, which will not happen again, so there is no point further propa

Directory where scripts are exported, to be mounted into containers.

Seed a new builder. The seed carries the size as well as the initial randomness.

Get rid of parts of an address which are considered ephemeral, keeping just the parts which would stay the same if for example the same peer opened an

Call the RPC method and respond through the Web Socket.

Invoke or call SimpleCoin to send some coins to self.

Best effort attempt to broadcast previously out-of-order transactions which have been unblocked.

Send value between two addresses in a subnet

Get the next sequence number (nonce) of an account.

Get the next sequence number (nonce) of an account.

Get the next sequence number (nonce) of an account.

Overwrite the power table after it has changed to a new snapshot. This method expects absolute values, it completely replaces the existing powers.

Set the complete list of subnets currently supported by this node.

Sign takes in `SignatureType`, private key and message. Returns a Signature for that message

Sign a transaction pre-image in the same way Ethereum clients would sign it.

Sort nodes in a subnet in topological order, so we strive to first start the ones others use as a seed node. However, do allow cycles so that we can h

Start a node. Fails if the node hasn't been created yet.

Start a CID resolution.

Run task resolution in the background, so as not to block items from other subnets being tried.

Start the parent finality listener in the background

Subscribe to `NewBlock` notifications and clear transactions from the caches.`

The state is effective at the *next* block, that is, the effects of block N are visible in the header of block N+1, so the height of the state itself

Path where the state of the materializer is saved.

Read a CID from the underlying IPLD store.

Checks if the relayer has already submitted at the next submission epoch, if not it submits it.

Returns the address of the actor governing the subnet in the parent If there is no subnet actor it returns the address ID=0

Create a new [`broadcast::Receiver`] instance bound to this `Service`, which will be notified upon each event coming from any of the subnets the `Serv

Replace the dropper with a new one and return the existing one so that we can await all the drop tasks being completed.

Take the execution state during block execution. Has to be non-empty.

Take the execution state during block execution. Has to be non-empty.

Tendermint RPC URL from the environment or the config file.

Directory where we keep the docker-materializer related data files.

Return all namespaces used by the tests, so they can be pre-allocated, if necessary.

The timestamp of the currently executing block.

Construct an indexable event from a custom transaction hash.

Event about the message itself.

Map to query results.

Convert a snapshot manifest to the Tendermint ABCI type.