Token returns the type of the current input token.

TrustScore gets a score based on the trust value always between 0 and 100

Wait waits for a number of blocks to be produced, and for all nodes to catch up with it.

Wait blocks until the service is stopped.

WaitForTxs returns true if the consensus should wait for transactions before entering the propose step

WriteFileAtomic creates a temporary file with data and provided perm and swaps it atomically with filename if successful.

WriteMessage writes a message from the endpoint

NOTE: this function is called manually in tests.

used in place of assert.Equal(t, want, actual) to avoid failures due to scheduler.lastAdvanced timestamp inequalities.

closed returns a channel that's closed when the scheduler is closed.

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

latestHeight can be either latest committed or uncommitted (+1) height.

lightBlockFromPrimary retrieves the lightBlock from the primary provider at the specified height. This method also handles provider behavior as follow

used for testing by state store

newChunkQueue creates a new chunk queue for a snapshot, using a temp dir for storage. Callers must call Close() when done.

onError calls the peer error callback.

Use a fast thread safe LCG for atomic write file names. Returns a string corresponding to a 64 bit int. If it was a negative int, the leading number i

round returns x rounded to the nearest int64 (non-negative values only).

saveValidatorsInfo persists the validator set. `height` is the effective height for which the validator is responsible for signing. It should be call

Attempt to schedule a timeout (by sending timeoutInfo on the tickChan)

Sign vote for type/hash/header

Makes a copy of the validator list.

NOTE: Assumes that s is ASCII as per IsASCIIText(), otherwise panics.

ApplyFixes transforms doc and reports whether it succeeded.

Load a snapshot chunk

CanSend returns true if you can send more data onto the chID, false otherwise. Use only as a heuristic.

TODO: We should decide whether we want channel descriptors to be housed within each reactor (as they are now) or, considering that the reactor doesn't

Cleanup removes the Docker Compose containers and testnet directory.

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

CompatibleWith checks if two NodeInfo are compatible with each other. CONTRACT: two nodes are compatible if the Block version and network match and th

Copy returns a new trust metric with members containing the same values

CreateProposalBlock calls state.MakeBlock with evidence from the evpool and txs from the mempool. The max bytes must be big enough to fit the commit.

Dial implements Transport.

EnableTxsAvailable initializes the TxsAvailable channel, ensuring it will trigger once every height when transactions are available.

EvidenceFromProto is a generalized function for decoding protobuf into the evidence interface

EvidenceFront goes to the first evidence in the clist

------------------------------------------ PROTO -------------------------------------- EvidenceToProto is a generalized function for encoding evidenc

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

GenSignedHeaderLastBlockID calls genHeader and signHeader and combines them into a SignedHeader.

Generate generates random testnets using the given RNG.

GetOrSet returns the existing value if present. Othewise, it stores `newValue` and returns it.