Size returns the number of valid transactions in the mempool. It is thread-safe.

SplitAndTrimEmpty slices s into all subslices separated by sep and returns a slice of the string s with all leading and trailing Unicode code points c

SyncAny tries to sync any of the snapshots in the snapshot pool, waiting to discover further snapshots if none were found and discoveryTime > 0. It re

TestConfig returns a configuration that can be used for testing

Unsubscribe unsubscribes given subscriber from query.

ValidatorSetFromProto sets a protobuf ValidatorSet to the given pointer. It returns an error if any of the validators from the set or the proposer is

VerifyCommit verifies +2/3 of the set had signed the given commit and all other signatures are valid

WriteRPCResponseHTTPError marshals res as JSON (with indent) and writes it to w. Maps JSON RPC error codes to HTTP Status codes as follows: HTTP Sta

Add adds a block to the queue to be verified and stored CONTRACT: light blocks should have passed basic validation

addPeer starts up the Peer and adds it to the Switch. Error is returned if the peer is filtered out or failed to start or can't be added.

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

genPrivKeys produces an array of private keys to generate commits.

----------------------------------------------------------------------------- Messages mustEncode proto encodes a tmp2p.Message

newDefaultNode returns a Tendermint node with default settings for the PrivValidator, ClientCreator, GenesisDoc, and DBProvider. It implements NodePro

Parse URL and set defaults

NextHeight returns the next height that needs to be retrieved. We assume that for every height allocated that the peer will eventually add the block o

pickSendVote picks a vote and sends it to the peer. It will return true if there is a vote to send and false otherwise.

------------------------------------------------------------------------------ Helper functions sumReceivedNumbers takes two channels and adds all num

FIXME: This function is used in place of testing.TB.TempDir() as the latter seems to cause test cases to fail when it is unable to remove the temporar

Make some blocks. Start a fresh app and apply nBlocks blocks. Then restart the app and sync it up with the remaining blocks

SetChannels sets the channel descriptors to be used when establishing a connection. FIXME: To be removed when the legacy p2p stack is removed. Channe

Base returns the first known contiguous block height, or 0 for empty block stores.

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

Query for state Mempool Connection

DefaultMConnConfig returns the default config.

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

EvictNext returns the next peer to evict (i.e. disconnect). If no evictable peers are found, the call will block until one becomes available.

ExpandPath will check if the given path begins with a "~" symbol, and if so, will expand it to become the user's home directory. If it fails to expand

Format writes either address of 0th element in a slice in base 16 notation, with leading 0x (%p), or casts HexBytes to bytes and writes as hexadecimal

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

GenNodeKey generates a new node key.

GenPrivKey generates a new sr25519 private key. It uses OS randomness in conjunction with the current global random seed in tendermint/libs/common to

GetByAddress returns an index of the validator with address and validator itself (copy) if found. Otherwise, -1 and nil are returned.

Get full address without the protocol - useful for Dialer connections

Hash returns a hash of a subset of the parameters to store in the block header. Only the Block.MaxBytes and Block.MaxGas are included in the hash. Thi

Height returns the last known contiguous block height, or 0 for empty block stores.

IsNilOrEmpty returns true if validator set is nil or empty.

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

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

LocalEndpoint returns the local endpoint for the connection.

Mark address

Mempool connection

New parses and compiles the query expression into an executable query.

NewCommitSigAbsent returns new CommitSig with BlockIDFlagAbsent. Other fields are all empty.

NewDuplicateVoteEvidence creates DuplicateVoteEvidence with right ordering given two conflicting votes. If either of the votes is nil, the val set is

NewErroringMockPV returns a MockPV that fails on each signing request. Again, for testing only.

NewNetAddress returns a new NetAddress using the provided TCP address. When testing, other net.Addr (except TCP) will result in using 0.0.0.0:0. When

NewNetAddressIPPort returns a new NetAddress using the provided IP and port number.

NewPeerUpdates creates a new PeerUpdates subscription. It is primarily for internal use, callers should typically use PeerManager.Subscribe(). The sub

NewReactor creates new PEX reactor.

NewSignerDialerEndpoint returns a SignerDialerEndpoint that will dial using the given dialer and respond to any signature requests over the connection

NewState returns a new State.

NewWALEncoder returns a new encoder that writes to wr.

PreCheckMaxBytes checks that the size of the transaction is smaller or equal to the expected maxBytes.

ProofsFromByteSlices computes inclusion proof for given items. proofs[0] is the proof for items[0].

Push adds the given raw transaction to the cache and returns true if it was newly added. Otherwise, it returns false.

Register allows you to inject a custom PeerUpdate instance into the PeerManager, rather than relying on the instance constructed by the Subscribe meth

RegisterType registers a type for Amino-compatible interface encoding in the global type registry. These types will be encoded with a type wrapper `{"

SetEventBus sets event bus.

SetLogger sets the Logger.