NewMConnection wraps net.Conn and creates multiplex connection

NewMultiAppConn makes all necessary abci connections to the application.

NewP2PStateProvider creates a light client state provider but uses a dispatcher connected to the P2P layer

NewParser constructs a new parser that reads the input from r.

NewPeerState returns a new PeerState for the given node ID.

NewRPCStateProvider creates a new StateProvider using a light client and RPC clients.

NewReactor returns a reference to a new reactor.

NewReactor returns a reference to a new reactor.

NewReactor returns new reactor instance.

NewReader restricts all Read operations on r to limit bytes per second.

NewRequestBatch starts a batch of requests for this client.

NewRetrySignerClient returns RetrySignerClient. If +retries+ is 0, the client will be retrying each operation indefinitely.

NewRoundEvent returns the RoundState with proposer information as an event.

NewRunState returns a new unstarted run state tracker with the given logging label and log sink. If logger == nil, a no-op logger is provided by defau

NewSignerListener creates a new SignerListenerEndpoint using the corresponding listen address

NewSnapshotStore creates a new snapshot store.

NewSocketClient creates a new socket client, which connects to a given address. If mustConnect is true, the client will return an error upon start if

NewState creates a new state.

NewSubscription returns a new subscription with the given outCapacity.

NewSwitchReporter return a new SwitchReporter instance which wraps the Switch.

NewTicker returns a normal time.Ticker wrapped to meet our interface

NewTruncated returns a new hash.Hash.

NewTxMempool constructs a new, empty priority mempool at the specified initial height and using the given config and options.

NewWSWithOptions allows you to provide custom WSOptions.

NewWithClientAndWSOptions allows you to set a custom http client and WebSocket options. An error is returned on invalid remote. The function panics wh

NewWithHTTPClient returns a Client pointed at the given address using a custom http client. An error is returned on invalid remote. The function panic

NewWithOptions is an extension to creating a new http provider that allows the addition of a specified timeout and maxRetryAttempts

NewWriter restricts all Write operations on w to limit bytes per second. The transfer rate and the default blocking behavior (true) can be changed dir

NopMetrics returns no-op Metrics.

NopMetrics returns no-op Metrics.

NopMetrics returns no-op Metrics.

Not returns a bit array resulting from a bitwise Not of the provided bit array.

NumClientSubscriptions returns the number of subscriptions the client has.

NumClients returns the number of clients.

NOTE: call is synchronous, use ctx to break early if needed

OnDisconnect sets a callback which is used upon disconnect - not Goroutine-safe. Nop by default.

OnReconnect sets the callback, which will be called every time after successful reconnect. Could only be set before Start.

OpenGroup creates a new Group with head at headPath. It returns an error if it fails to open head file.

Check if it is our address

Last round and blockID that has +2/3 prevotes for a particular block or nil. Returns -1 if no such round exists.

ParseFractions takes the string of a fraction as input i.e "2/3" and converts this to the equivalent fraction else returns an error. The format of the

PeerDisconnected pauses the trust metric associated with the peer identified by the key

PerturbNode perturbs a node with a given perturbation, returning its status after recovering.

PickVoteToSend picks a vote to send to the peer. It will return true if a vote was picked. NOTE: `votes` must be the correct Size() for the Height().

PingPeriod sets the duration for sending websocket pings. It should only be used in the constructor - not Goroutine-safe.

Populate the Header with state-derived data. Call this after MakeBlock to complete the Header.

PrevWaitChan can be used to wait until Prev becomes not nil. Once it does, channel will be closed.

PrometheusMetrics returns Metrics build using Prometheus client library. Optionally, labels can be provided along with their values ("foo", "fooValue"

PrometheusMetrics returns Metrics build using Prometheus client library. Optionally, labels can be provided along with their values ("foo", "fooValue"

PrometheusMetrics constructs a Metrics instance that collects metrics samples. The resulting metrics will be prefixed with namespace and labeled with

PrometheusMetrics returns Metrics build using Prometheus client library. Optionally, labels can be provided along with their values ("foo", "fooValue"

PruningSize option sets the maximum amount of light blocks that the light client stores. When Prune() is run, all light blocks that are earlier than t

NOTE: call is synchronous, use ctx to break early if needed

Quit provides a mock function with given fields:

From the JSON-RPC 2.0 spec: If there was an error in detecting the id in the Request object (e.g. Parse error/Invalid Request), it MUST be Null.

RandVal creates one random validator, with a key derived from the input value

ReachabilityTo checks whenever o can be reached from na.

ReactorMetrics sets the reactor's metrics as an option function.

Reactors returns a map of reactors registered on the switch. NOTE: Not goroutine safe.

Read implements net.Conn.

Read should run in a go-routine and updates count by one every time a packet comes in

Read implements io.Reader, reading bytes from the current Reader incrementing index until enough bytes are read.

ReadLimit sets the maximum size for reading message. It should only be used in the constructor - not Goroutine-safe.

ReadWait sets the amount of time to wait before a websocket read times out. It should only be used in the constructor - not Goroutine-safe.

NOTE: Not concurrency safe. Writes results to trs.results without waiting for all tasks to complete.

ReceiveAddrs adds the given addrs to the addrbook if theres an open request for this peer and deletes the open request. If there's no open request for