OfferSnapshotSync provides a mock function with given fields: _a0, _a1

OfferSnapshotSync provides a mock function with given fields: _a0, _a1

OnReset provides a mock function with given fields:

OnReset provides a mock function with given fields:

OnReset implements Service by panicking.

OnReset implements Service.OnReset

OnStart implements Service by connecting to the server and spawning reading and writing goroutines.

OnStart provides a mock function with given fields:

OnStart starts the gRPC service.

OnStart implements service.Service.

OnStart implements service.Service.

OnStart starts separate go routines for each p2p Channel and listens for envelopes on each. In addition, it also listens for peer updates and handles

OnStart starts separate go routines for each p2p Channel and listens for envelopes on each. In addition, it also listens for peer updates and handles

OnStart starts separate go routines for each p2p Channel and listens for envelopes on each. In addition, it also listens for peer updates and handles

OnStart implements service.Service by subscribing for all transactions and indexing them by events.

OnStart implements service.Service.

OnStart executes the reactor shim's OnStart hook where we start all the necessary go-routines in order to proxy peer envelopes and errors per p2p Chan

OnStart implements BaseService.

--------------------------------------------------------------------- Service start/stop OnStart implements BaseService. It starts all the reactors an

OnStart implements BaseService

OnStart implements Service

OnStart implements Service

OnStart provides a mock function with given fields:

OnStart implements BaseService

OnStart starts separate go routines for each p2p Channel and listens for envelopes on each. In addition, it also listens for peer updates and handles

OnStart implements Service.

OnStart implements service.Service by starting the goroutine that checks file and group limits.

OnStart starts separate go routines for each p2p Channel and listens for envelopes on each. In addition, it also listens for peer updates and handles

OnStart implements service.Service. It starts the timeout routine.

OnStart starts separate go routines for each p2p Channel and listens for envelopes on each. In addition, it also listens for peer updates and handles

OnStart loads the latest state via the WAL, and starts the timeout and receive routines.

OnStart starts separate go routines for each p2p Channel and listens for envelopes on each. In addition, it also listens for peer updates and handles

OnStart implements service.Service by spawning requesters routine and recording pool's start time.

OnStart implements Service by doing nothing. NOTE: Do not put anything in here, that way users don't need to call BaseService.OnStart()

OnStart implements Service.OnStart by starting the server.

OnStart starts the Node. It implements service.Service.

OnStop implements Service by closing connection and flushing all queues.

OnStop provides a mock function with given fields:

OnStop stops the gRPC server.

OnStop implements service.Service

OnStop implements service.Service.

OnStop stops the reactor by signaling to all spawned goroutines to exit and blocking until they all exit.

OnStop stops the reactor by signaling to all spawned goroutines to exit and blocking until they all exit.

OnStop stops the reactor by signaling to all spawned goroutines to exit and blocking until they all exit.

OnStop implements service.Service by unsubscribing from all transactions and close the eventsink.

OnStop implements service.Service. All channels must be closed by OpenChannel() callers before stopping the router, to prevent blocked channel sends

OnStop implements BaseService.

OnStop implements BaseService. It stops all peers and reactors.

OnStop implements BaseService

OnStop implements Service

OnStop implements Service Nothing to do since the goroutine shuts down by itself via BaseService.Quit()

OnStop provides a mock function with given fields:

OnStop implements BaseService

OnStop stops the reactor by signaling to all spawned goroutines to exit and blocking until they all exit.

OnStop implements Service.

OnStop implements service.Service by stopping the goroutine described above. NOTE: g.Head must be closed separately using Close.

OnStop stops the reactor by signaling to all spawned goroutines to exit and blocking until they all exit.

OnStop implements service.Service. It stops the timeout routine.

OnStop stops the reactor by signaling to all spawned goroutines to exit and blocking until they all exit, as well as unsubscribing from events and sto

OnStop implements service.Service.

Stop the underlying autofile group. Use Wait() to ensure it's finished shutting down before cleaning up files.

OnStop stops the reactor by signaling to all spawned goroutines to exit and blocking until they all exit.

OnStop implements Service by doing nothing. NOTE: Do not put anything in here, that way users don't need to call BaseService.OnStop()

OnStop implements Service.OnStop by shutting down the server.

OnStop stops the Node. It implements service.Service.

OurAddress returns true if it is our address.

Out returns a channel onto which messages and events are published. Unsubscribe/UnsubscribeAll does not close the channel to avoid clients from receiv

Peers returns the set of peers that are connected to the switch.

Peers returns a node's peers (i.e. everyone except itself).

PendingEvidence provides a mock function with given fields: maxBytes

PickAddress implements AddrBook. It picks an address to connect to. The address is picked randomly from an old or new bucket according to the biasTowa