Data returns an original data published.

Nonblocking, may return nil if at the end.

Update informs the mempool that the given txs were committed and can be discarded. NOTE: 1. This should be called *after* block is committed by conse

XXX: panics on nil or unknown pubkey type

If there was a +2/3 majority for blockID, return blockID and true. Else, return the empty BlockID{} and false.

Logger option can be used to set a logger for the client.

Next returns the next chunk from the queue, or errDone if all chunks have been returned. It blocks until the chunk is available. Concurrent Next() cal

Addr returns the NetAddress for the rejected Peer.

MustParse turns the given string into a query or panics; for tests or others cases where you know the string is valid.

NewCommit returns a new Commit.

Add and remove an address

Consensus connection

NewReader returns a new group reader. CONTRACT: Caller must close the returned GroupReader.

Stop the service. If it's already stopped, will return an error. OnStop must never error.

hash of the evidence

EnvelopeSendShim implements a shim to allow the legacy peer type that does not implement SendEnvelope to be used in places where envelopes are being s

Sub subtracts the two bit-arrays bitwise, without carrying the bits. Note that carryless subtraction of a - b is (a and not b). The output is the same

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

SizeBytes returns the total size of all txs in the mempool.

Start the service. If it's already started or stopped, will return an error. If OnStart() returns an error, it's returned by Start()

------------------------------------------------------------------------------- Functions for transitioning the consensus state

LightBlock returns the LightBlock that corresponds to the given height. height must be > 0. If LightBlock is not found, ErrLightBlockNotFound is ret

VerifyLightBlockAtHeight fetches the light block at the given height and verifies it. It returns the block immediately if it exists in the trustedStor

NewNopLogger returns a logger that doesn't do anything.

remote IP of the connection

Reset the service. Panics by default - must be overwritten to enable reset.

IncrementProposerPriority increments ProposerPriority of each validator and updates the proposer. Panics if validator set is empty. `times` must be po

NewAppConns calls NewMultiAppConn.

NewTMLogger returns a logger that encodes msg and keyvals to the Writer using go-kit's log as an underlying logger and our custom formatter. Note that

NewValidator returns a new validator with the given pubkey and voting power.

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

MakeBlock returns a new block with an empty header, except what can be computed from itself. It populates the same set of fields validated by Validate

NewAddrBook creates a new address book. Use Start to begin processing asynchronous address updates.

PrivValidatorFile returns the full path to the priv_validator_state.json file

EnvelopeTrySendShim implements a shim to allow the legacy peer type that does not implement TrySendEnvelope to be used in places where envelopes are b

Convenience: Return new vote with different validator address/index

IsZero returns true if this is the BlockID of a nil block.

assumes voting power to be 10 and validator to be the only one in the set

Now returns the current time in UTC with no monotonic component.

RoundStateEvent returns the H/R/S of the RoundState as an event.

AddSnapshot adds a snapshot to the snapshot pool. It returns true if a new, previously unseen snapshot was accepted and added.

GenesisFile returns the full path to the genesis.json file

HashesTo is a convenience function that checks if a block hashes to the given argument. Returns false if the block is nil or the hash is empty.

NewBlockStore returns a new BlockStore with the given DB, initialized to the last height that was committed to the DB.

NewNetAddressString returns a new NetAddress using the provided address in the form of "ID@IP:Port". Also resolves the host if host is not an IP. Erro

PrivValidatorKeyFile returns the full path to the priv_validator_key.json file

PubKeyToID returns the ID corresponding to the given PubKey. It's the hex-encoding of the pubKey.Address().

Read reads up to len(p) bytes into p without exceeding the current transfer rate limit. It returns (0, nil) immediately if r is non-blocking and no ne

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

reset the timer

ToProto converts Proposal to protobuf

GenSecpPrivKeys produces an array of secp256k1 private keys to generate commits. func GenSecpPrivKeys(n int) privKeys { res := make(privKeys, n) for

Dial connects to the Peer for the address.

GetClients returns a slice of clients for table-driven tests