GetMinersForServiceType retrieves the list of miners for a given service type from the database.

Implements PrivValidator.

HashFromByteSlices computes a Merkle tree where the leaves are the byte slice, in the provided order. It follows RFC-6962.

InitPeer is called by the switch before the peer is started. Use it to initialize data for the peer (e.g. peer state). NOTE: The switch won't call Ad

LoadOrGenNodeKey attempts to load the NodeKey from the given filePath. If the file does not exist, it generates and saves a new NodeKey.

Return CList with MaxLength. CList will panic if it goes beyond MaxLength.

PendingEvidence is used primarily as part of block proposal and returns up to maxNum of uncommitted evidence.

Reactor returns the reactor with the given name. NOTE: Not goroutine safe.

Receive is called by the switch when msgBytes is received from the peer. NOTE reactor can not keep msgBytes around after Receive completes without co

RemotePubKey returns authenticated remote pubkey

RemovePeer is called by the switch when the peer is stopped (due to error or other reason).

UnsubscribeAll unsubscribes given subscriber from all the queries.

Unwrap implements the p2p Wrapper interface and unwraps a wrapped PEX message.

WriteLine writes line into the current head of the group. It also appends "\n". NOTE: Writes are buffered so they don't write synchronously TODO: Make

state transitions on complete-proposal, 2/3-any, 2/3-one

newMultiplexTransport returns a tcp connected multiplexed peer using the default MConnConfig. It's a convenience function used for testing.

Convenience: Return new vote with different blockHash

ApplyBlock validates the block against the state, executes it against the app, fires the relevant events, commits the app, and saves the new state and

FromProto sets a protobuf Block to the given pointer. It returns an error if the block is invalid.

FromProto sets a protobuf BlockID to the given pointer. It returns an error if the block id is invalid.

GenFilePV generates a new validator with randomly generated private key and sets the filePaths, but does not call Save().

Send a selection of addresses with bias

ID returns the peer's canonical ID - the hash of its public key.

Validate a tx for the mempool Consensus Connection

LoadABCIResponses loads the abciResponse for a given height

LoadFromDBOrGenesisDoc loads the most recent state. If the chain is new it will use the genesis doc as the current state.

LoadOrGenFilePV loads a FilePV from the given filePaths or else generates a new one and saves it to the filePaths.

-------------------------------------------------------------------------------- Commit MakeCommit constructs a Commit from the VoteSet. It only inclu

NewBpPeer creates a new peer.

NewPeer creates and starts a new mock peer. If the ip is nil, random routable address is used.

Constructs a new VoteSet struct used to accumulate votes for given height/round.

NewWALDecoder returns a new decoder that reads from rd.

Propose returns the amount of time to wait for a proposal

CONTRACT: data smaller than dataMaxSize is read atomically.

ReadMessage reads a varint length-delimited protobuf message.

ReapMaxTxs reaps up to max transactions from the mempool. If max is negative, there is no cap on the size of all returned transactions (~ all availabl

Safe for concurrent use by multiple goroutines.

State returns the current state of the evpool.

VerifyLightClientAttack verifies LightClientAttackEvidence against the state of the full node. This involves the following checks: - the common header

WriteMessage writes a varint length-delimited protobuf message.

Create the next block to propose and return it. Returns nil block upon error. We really only need to return the parts, but the block is returned for

----------------------------------------------------------------------------- State functions Used internally by handleTimeout and handleMsg to make s

makeIndexedEvent constructs an event from the specified composite key and value. If the key has the form "type.name", the event will have a single att

mustEncode proto encodes a proto.message and panics if fails

testNode runs tests for testnet nodes. The callback function is given a single node to test, running as a subtest in parallel with other subtests. Th

Absent returns true if CommitSig is absent.

BlockAndPeerAtHeight retrieves the block and delivery peer at specified height. Returns errMissingBlock if a block was not found

DialTCPFn dials the given tcp addr, using the given timeoutReadWrite and privKey for the authenticated encryption handshake.

Discard discards a chunk. It will be removed from the queue, available for allocation, and can be added and returned via Next() again. If the chunk is

EnableTxsAvailable initializes the TxsAvailable channel, ensuring it will trigger once every height when transactions are available.

TODO make it return an index

Send a selection of addresses to peers

IsComplete returns true if this is a valid BlockID of a non-nil block.

IsVoteTypeValid returns true if t is a valid vote type.

MakeSecretConnection performs handshake and returns a new authenticated SecretConnection. Returns nil if there is an error in handshake. Caller should

MaxRetryAttempts option can be used to set max attempts before replacing primary with a witness.

NewFilter wraps next and implements filtering. See the commentary on the Option functions for a detailed description of how to configure levels. If no

NewRPCFunc wraps a function for introspection. f is the function, args are comma separated argument names