Structsยง
- Default
Connector - Initiates a connection with given timeout in milliseconds
Traitsยง
- BSConnector
- Specifies a common interface that can be used by standard, or mockers
Functionsยง
- align_
consensus_ ๐resume_ state_ before_ ask - bootstrap_
from_ ๐server - Gets the state from a bootstrap server (internal private function) needs to be CANCELLABLE
- capped_
consensus_ ๐cursor_ ids - Ids for the reconnect ask: all finals if under the cap, otherwise the newest
max_idsby slot. - capped_
consensus_ ๐resume_ step - check_
restart_ ๐metadata - Checks the network restart metadata announced by a bootstrap server.
- connect_
to_ ๐server - filter_
bootstrap_ ๐list - get_
bootstrap_ ๐list_ iter - get_
state - Uses the cond-var pattern to handle sig-int cancellation.
Make sure that the passed in
interruptedshares its Arc with a sig-int handler setup. - restart_
state_ ๐streaming - Drop everything streamed from the current server so that the next attempt streams the state again from scratch, instead of resuming on top of what this server sent.
- send_
client_ ๐message - shutdown_
range ๐ - Computes the slot range of the last network shutdown, as startup does: from the slot right after the last one executed before the downtime, to the slot right before the restart.
- stream_
final_ ๐state_ and_ consensus - This function will send the starting point to receive a stream of the ledger and will receive and process each part until receive a
BootstrapServerMessage::FinalStateFinishedmessage from the server.next_bootstrap_messagepassed as parameter must beBootstrapClientMessage::AskFinalStatePartenum variant.next_bootstrap_messagewill be updated after receiving each part so that in case of connection lost we can restart from the last message we processed. - warn_
user_ ๐about_ versioning_ updates