fresh state and mock store

------------------------------------------------------------- stop the timer and drain if necessary

NOTE: s is interpreted as a string unless prefixed with 0x

return the power voted, the total, and the fraction

XXX: Maybe get rid of this

Creates a peer with the default config

Creates a peer which knows about the provided seed. Starting and stopping the peer is left to the caller

Creates a seed which knows about the provided addresses / source address pairs. Starting and stopping the seed is left to the caller

------------------------------------------------------------- NOTE: assume returns is result struct and error. If error is not nil, return it

Updates State and increments height to match that of state. The round becomes 0 and cs.Step becomes cstypes.RoundStepNewHeight.

add, update, or remove a validator

Batch verification verifyCommitBatch batch verifies commits. This routine is equivalent to verifyCommitSingle in behavior, just faster iff every sign

Single Verification verifyCommitSingle single verifies commits. If a key does not support batch verification, or batch verification fails this will be

see VerifyHeader verifySkipping finds the middle light block between a trusted and new light block, reiterating the action until it verifies a light

Convenience: Return new vote with different blockParts

All writes to the websocket must (re)set the write deadline. If some writes don't set it while others do, they may timeout incorrectly (https://github

writeStateToFile pretty JSON encodes an object and writes it to file composed of dir and filename. It returns an error upon failure to encode or write

AddBlock validates that the block comes from the peer it was expected from and calls the requester to store it. TODO: ensure that blocks come in order

AddProvider adds a providers to the light clients set NOTE: The light client does not check for uniqueness

Returns added=true if vote is valid and new. Otherwise returns err=ErrVote[ UnexpectedStep | InvalidIndex | InvalidAddress | InvalidSignature | In

AnyBound returns either the lower bound if non-nil, otherwise the upper bound.

App extracts out the application specific configuration parameters

AppHash returns the app hash after the given height has been committed.

ApplyVoteSetBitsMessage updates the peer state for the bit-array of votes it claims to have for the corresponding BlockID. `ourVotes` is a BitArray of

BenchmarkKeyGeneration benchmarks the given key generation algorithm using a dummy reader.

BenchmarkSigning benchmarks the given signing algorithm using the provided privkey.

BenchmarkVerification benchmarks the given verification algorithm using the provided privkey on a constant message.

Return the bit-array of votes including the fraction of power that has voted like: "BA{29:xx__x__x_x___x__x_______xxx__} 856/1304 = 0.66"

BufferCapacity returns capacity of the internal server's queue.

Buffered returns the size of the currently buffered data.

ByteSize returns the total byte size of all the evidence

Bytes returns the byte representation of the bits within the bitarray.

CheckHRS checks the given height, round, step (HRS) against that of the FilePVLastSignState. It returns an error if the arguments constitute a regress

CheckValid checks whether the specified config appears to be a valid Tendermint config file. This emulates how the node loads the config.

Clear will empty out this batch of requests and return the number of requests that were cleared out.

Close implements Connection.

CommitToVoteSet constructs a VoteSet from the Commit and validator set. Panics if signatures from the commit can't be added to the voteset. Inverse of

Compute the root hash given a leaf hash. Does not verify the result.

nolint:gosec // G404: Use of weak random number generator

CreateTransport creates a new memory transport endpoint with the given node ID and immediately begins listening on the address "memory:<id>". It panic

DB returns the underlying Postgres connection used by the sink. This is exported to support testing.

DataFromProto takes a protobuf representation of Data & returns the native type.

secret must be 32 bytes long. Use something like Sha256(Bcrypt(passphrase)) The ciphertext is (secretbox.Overhead + 24) bytes longer than the plaintex

DefaultBlockSyncConfig returns a default configuration for the block sync service

DefaultClientCreator returns a default ClientCreator, which will create a local client if addr is one of: 'kvstore', 'persistent_kvstore', 'e2e', or '

DefaultHTTPClient is used to create an http client with some default parameters. We overwrite the http.Client.Dial so we can do http over tcp or unix.

DefaultInstrumentationConfig returns a default configuration for metrics reporting.

DefaultRPCConfig returns a default configuration for the RPC server

DefaultTxIndexConfig returns a default configuration for the transaction indexer.

DeleteSignedHeaderAndValidatorSet deletes SignedHeader (h: height) and ValidatorSet (h: height). height must be > 0.

DeliverTx implements ABCI.

IsConnected indicates if there is an active connection

EnableTxsAvailable enables the mempool to trigger events when transactions are available on a block by block basis.

secret must be 32 bytes long. Use something like Sha256(Bcrypt(passphrase)) The ciphertext is (secretbox.Overhead + 24) bytes longer than the plaintex

EnsureVoteBitArrays ensures the bit-arrays have been allocated for tracking what votes this peer has received. NOTE: It's important to make sure that

EventSinksFromConfig constructs a slice of indexer.EventSink using the provided configuration.

Events returns events, which matched the client's query.

EvidenceWaitChan is a channel that closes once the first evidence in the list is there. i.e Front is not nil.

Change replaces the key at index i. func (pkz privKeys) Change(i int) privKeys { res := make(privKeys, len(pkz)) copy(res, pkz) res[i] = ed25519.Ge

FirstTrustedHeight returns a first trusted height. -1 and nil are returned if there are no trusted headers. Safe for concurrent use by multiple gorou