cdcEncode returns nil if the input is nil, otherwise returns proto.Marshal(<type>Value{Value: item})

close closes the queue. After this call enqueue() will block, so the caller must select on closed() as well to avoid blocking forever. The enqueue() a

Create proposal block from cs1 but sign it with vs.

fireEvents takes an EventSwitch and fires a thousand integers under a given `event` with the integers mootonically increasing from `offset` to `offset

mustCheckTx invokes txmp.CheckTx for the given transaction and waits until its callback has finished executing. It fails t if CheckTx fails.

----------------------------------------------------------------------------- mustEncode proto encodes a proto.message and panics if fails

Addresses returns all known addresses for a peer, primarily for testing. The order is arbitrary.

Encode writes the custom encoding of v to the stream. It returns an error if the encoded size of v is greater than 1MB. Any error encountered during t

Validate a tx for the mempool Consensus Connection

IsSet returns whether the Boolean is true.

LoadBlock returns the block with the given height. If no block is found for that height, it returns nil.

MakeNetwork creates a test network with the given number of nodes and connects them to each other.

New returns an Inspector that serves RPC on the specified BlockStore and StateStore. The Inspector type does not modify the state or block stores. The

Returns an empty PartSet ready to be populated.

NewWALDecoder returns a new decoder that reads from rd.

---------------------------------------- Parallel Run tasks in parallel, with ability to abort early. Returns ok=false iff any of the tasks returned a

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

ProposalSignBytes returns the proto-encoding of the canonicalized Proposal, for signing. Panics if the marshaling fails. The encoded Protobuf message

Scores returns the peer scores for all known peers, primarily for testing.

StopPeerForError disconnects from a peer due to external error. If the peer is persistent, it will attempt to reconnect. TODO: make record depending o

TxsAvailable returns a channel which fires once for every height, and only when transactions are available in the mempool. NOTE: 1. The returned chan

UnsubscribeAll unsubscribes given subscriber from all the queries.

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

execCompose runs a Docker Compose command for a testnet.

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

Convenience: Return new vote with different blockHash

AddEvidence checks the evidence is valid and adds it to the pool.

IDAddressString returns id@hostPort. It strips the leading protocol from protocolHostPort if it exists.

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

Errored reports a peer error, causing the peer to be evicted if it's currently connected. FIXME: This should probably be replaced with a peer behavio

indexes Fail calls

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

MakeHeader fills the rest of the contents of the header such that it passes validate basic

MaxPeerHeight returns the highest reported height.

NodeKeyFile returns the full path to the node_key.json file

RandomNode returns a random node.

ReceiveMessage returns the next message received on the connection, blocking until one is available. Returns io.EOF if closed.

RequireReceive requires that the given envelope is received on the channel.

SaveSignedHeaderAndValidatorSet saves a SignedHeader (h: sh.Height) and a ValidatorSet (h: sh.Height). height must be > 0.

Score calculates a score for the peer. Higher-scored peers will be preferred over lower scores.

Safe for concurrent use by multiple goroutines.

Unmarshal unmarshals JSON into the given value, using Amino-compatible JSON encoding (strings for 64-bit numbers, and type wrappers for registered typ

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

Finished returns true when the block queue has has all light blocks retrieved, verified and stored. There is no more work left to be done

----------------------------------------------------------------------------- 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

make a Commit with a single vote containing just the height and a timestamp

--------------------------------------------------------------------------------

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

AddPeer is called by the switch after the peer is added and successfully started. Use it to start goroutines communicating with the peer.

Close gracefully closes the Closer. A caller should only call Close once, but it is safe to call it successive times.

DefaultP2PConfig returns a default configuration for the peer-to-peer layer