NewServer returns a new server. See the commentary on the Option functions for a detailed description of how to configure buffering. If no options are

NodeKeyFile returns the full path to the node_key.json file

Publish publishes the given message. An error will be returned to the caller if the context is canceled.

Reset resets the cache to an empty state.

actual address of the socket Deprecated: entities looking to act as peers should implement SendEnvelope instead. Send will be removed in v0.37.

ToProto takes the local state type and returns the equivalent proto type

ToProto converts a NetAddress to Protobuf.

TxSearch defines a method to search for a paginated set of transactions by DeliverTx event search criteria.

Verify that the Proof proves the root hash. Check sp.Index/sp.Total manually if needed

finishAsyncCall creates a ReqRes for an async call, and immediately populates it with the response. We don't complete it until it's been ordered via t

--------------------------------------------------------------------- Peers BroadcastEnvelope runs a go routine for each attempted send, which will bl

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

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

Key generates a snapshot key, used for lookups. It takes into account not only the height and format, but also the chunks, hash, and metadata in case

------------------------------------------------------------------------ Create a block from the latest state MakeBlock builds a block from the curren

MakeConnectedSwitches returns n switches, connected according to the connect func. If connect==Connect2Switches, the switches will be fully connected.

close original connection

PublishWithEvents publishes the given message with the set of events. The set is matched with clients queries. If there is a match, the message is sen

Query connection

SetAddrBook allows to set address book on Switch.

SetRoot sets the RootDir for all Config structs

Unmarshal needed for protobuf compatibility

ValidateBlock validates the given block against the given state. If the block is invalid, it returns an error. Validation does not mutate state, but d

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

finishSyncCall waits for an async call to complete. It is necessary to call all sync calls asynchronously as well, to maintain call and response order

------------------------------------ mock ticker

setupTestCase does setup common to all test cases.

Sets up a simple peer mock with an ID

CopyIncrementProposerPriority increments ProposerPriority and updates the proposer on a copy, and returns it.

Info/Query Connection

IsOK returns true if Code is OK.

NewABCIClient returns a new ABCI client.

NewTxIndex creates new KV indexer.

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

ToProto converts Data to protobuf

HELPERS

Bool returns a uniformly random boolean

CheckEvidence takes an array of evidence from a block and verifies all the evidence there. If it has already verified the evidence then it jumps to th

Client returns an RPC client for a node.

Signals the beginning of a block

GetIndex returns the bit at index i within the bit array. The behavior is undefined if i >= bA.Bits

GetPeers returns the peers for a snapshot.

GetRoundState returns an shallow copy of the PeerRoundState. There's no point in mutating it since it won't change PeerState.

Index analyzes, indexes and stores a single transaction.

Index indexes a single transaction using the given list of events. Each key that indexed from the tx's events is a composite of the event type and the

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

Marshal needed for protobuf compatibility

NewWeightedTime with time and weight.

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

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

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

func makeEquivocationEvidence() *types.LightClientAttackEvidence { } func makeAmnesiaEvidence() *types.LightClientAttackEvidence { }

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

----------------------------------------------------------------------------- Utils helper function to make config creation independent of root dir

sign the vote and publish on internalMsgQueue

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

DefaultStateSyncConfig returns a default configuration for the state sync service

Returns the firstmost (by task index) error as discovered by all previous Reap() calls.