types

package

Go to main page

Versions in this module

v1

v1.8.1

Jul 15, 2024

v1.8.0

Aug 30, 2023

Changes in this version

+ var MILESTONE_VENUS7_NAME = "venus7"

+ func GetVenus7Height() int64

+ func HigherThanVenus7(h int64) bool

+ func InitMilestoneVenus7Height(h int64)

+ func UnittestOnlySetMilestoneVenus6Height(h int64)

v1.7.9

Jul 20, 2023

v1.7.8

Jul 11, 2023

Changes in this version

+ var WasmStoreCode = false

+ type WrappedMempoolTx struct

+ From string

+ GasLimit int64

+ GasWanted int64

+ Height int64

+ IsSim uint32

+ IsWrapCMTx bool

+ NodeKey []byte

+ Outdated uint32

+ SenderNonce uint64

+ Signature []byte

+ Tx Tx

+ WrapCMNonce uint64

v1.7.7

Jun 19, 2023

v1.7.6

Jun 7, 2023

v1.7.5

May 24, 2023

v1.7.4

May 16, 2023

v1.7.3

Apr 27, 2023

v1.7.2

Apr 27, 2023

Changes in this version

+ var MILESTONE_VENUS6_NAME = "venus6"

+ func GetVenus6Height() int64

+ func HigherThanVenus6(h int64) bool

+ func InitMilestoneVenus6Height(h int64)

v1.7.1

Apr 14, 2023

v1.7.0

Apr 12, 2023

Changes in this version

+ const CongestionHigherGpMode

+ const MinimalGpMode

+ const NoGasUsedCap

+ const NormalGpMode

+ var MILESTONE_VENUS5_HEIGHT string

+ func GetVenus5Height() int64

+ func HigherThanVenus5(h int64) bool

+ func IsPrivateNet() bool

+ func UnittestOnlySetMilestoneVenus5Height(h int64)

+ type BigIntArray []*big.Int

+ func (s BigIntArray) Len() int

+ func (s BigIntArray) Less(i, j int) bool

+ func (s BigIntArray) Swap(i, j int)

+ type BlockGPResults struct

+ func NewBlockGPResults(checkBlocksNum int) *BlockGPResults

+ func (rs *BlockGPResults) ExecuteSamplingBy(lastPrice *big.Int, adoptHigherGp bool) []*big.Int

+ func (rs *BlockGPResults) Pop() (*SingleBlockGPs, error)

+ func (rs *BlockGPResults) Push(gp *SingleBlockGPs) error

+ func (rs BlockGPResults) Cap() int

+ func (rs BlockGPResults) Front() int

+ func (rs BlockGPResults) IsEmpty() bool

+ func (rs BlockGPResults) IsFull() bool

+ func (rs BlockGPResults) Rear() int

type EventDataBlockTime

+ Available bool

+ TimeNow int64

+ TxNum int

type EventDataTx

+ Nonce uint64

+ type SingleBlockGPs struct

+ func NewSingleBlockGPs() *SingleBlockGPs

+ func (bgp *SingleBlockGPs) AddSampledGP(gp *big.Int)

+ func (bgp *SingleBlockGPs) Clear()

+ func (bgp *SingleBlockGPs) Copy() *SingleBlockGPs

+ func (bgp *SingleBlockGPs) SampleGP(adoptHigherGp bool)

+ func (bgp *SingleBlockGPs) Update(gp *big.Int, gas uint64)

+ func (bgp SingleBlockGPs) GetAll() []*big.Int

+ func (bgp SingleBlockGPs) GetGasUsed() uint64

+ func (bgp SingleBlockGPs) GetSampled() []*big.Int

+ type WrapCMTx struct

+ Nonce uint64

+ Tx Tx

+ func (wtx *WrapCMTx) GetNonce() uint64

+ func (wtx *WrapCMTx) GetTx() Tx

v1.7.0-browser

Apr 12, 2023

v1.6.8

Dec 30, 2022

v1.6.7

Dec 24, 2022

Changes in this version

+ const BlockHeightKey

+ const EventRmPendingTx

+ var MILESTONE_VENUS4_HEIGHT string

+ func GetVenus4Height() int64

+ func HigherThanVenus4(h int64) bool

+ func UnittestOnlySetMilestoneVenus4Height(h int64)

type Block

+ func (b Block) To() CM40Block

type BlockEventPublisher

+ PublishEventRmPendingTx func(EventDataRmPendingTx) error

type CM40Block

+ func (b CM40Block) From(block Block) CM40Block

+ type CM40EventDataNewBlock struct

+ Block *CM40Block

+ ResultBeginBlock abci.ResponseBeginBlock

+ ResultEndBlock abci.ResponseEndBlock

+ func (e CM40EventDataNewBlock) From(block EventDataNewBlock) CM40EventDataNewBlock

type Commit

+ func (c Commit) To() IBCCommit

type EventBus

+ func (b *EventBus) PublishEventRmPendingTx(data EventDataRmPendingTx) error

type EventDataNewBlock

+ func (e EventDataNewBlock) Upgrade() interface{}

+ type EventDataRmPendingTx struct

+ From string

+ Hash []byte

+ Nonce uint64

+ Reason RmPendingTxReason

type IBCBlockID

+ func (b IBCBlockID) From(bb BlockID) IBCBlockID

type IBCCommit

+ func (c IBCCommit) From(cc Commit) IBCCommit

type IBCHeader

+ func (h IBCHeader) From(header Header) IBCHeader

type IBCPartSetHeader

+ func (p IBCPartSetHeader) From(header PartSetHeader) IBCPartSetHeader

type NopEventBus

+ func (NopEventBus) PublishEventRmPendingTx(EventDataRmPendingTx) error

+ type RmPendingTxReason int

+ const Confirmed

+ const MinGasPrice

+ const Recheck

type TxEventPublisher

+ PublishEventRmPendingTx func(EventDataRmPendingTx) error

+ type UpgradeAble interface

+ Upgrade func() interface{}

v1.6.6

Dec 1, 2022

Changes in this version

+ const TimeoutCommit

v1.6.4

Oct 15, 2022

Changes in this version

+ const EventBlockTime

+ const EventTxs

+ var EnableEventBlockTime = false

+ var MILESTONE_EARTH_HEIGHT string

+ func GetEarthHeight() int64

+ func HigherThanEarth(h int64) bool

+ func UnittestOnlySetMilestoneEarthHeight(h int64)

type BlockEventPublisher

+ PublishEventLatestBlockTime func(time EventDataBlockTime) error

+ PublishEventTxs func(EventDataTxs) error

type EventBus

+ func (b *EventBus) PublishEventLatestBlockTime(data EventDataBlockTime) error

+ func (b *EventBus) PublishEventTxs(data EventDataTxs) error

+ type EventDataBlockTime struct

+ BlockTime int64

+ Height int64

+ NextProposer Address

+ type EventDataTxs struct

+ Height int64

+ Results []*abci.ResponseDeliverTx

type NopEventBus

+ func (NopEventBus) PublishEventLatestBlockTime(data EventDataBlockTime) error

+ func (NopEventBus) PublishEventTxs(data EventDataTxs) error

v1.6.3

Sep 7, 2022

Changes in this version

+ var DBBackend = string(dbm.GoLevelDBBackend)

+ var MILESTONE_VENUS3_HEIGHT string

+ func GetVenus3Height() int64

+ func HigherThanVenus3(h int64) bool

+ func IsBlockDataCompressed(payload []byte) bool

+ func UncompressBlockFromBytesTo(payload []byte, buf *bytes.Buffer) (compressSign int, err error)

+ func UnittestOnlySetMilestoneVenus3Height(h int64)

type BlockExInfo

+ func (info BlockExInfo) IsCompressed() bool

type BlockMeta

+ func (bm *BlockMeta) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error

type DeltaPayload

+ func (payload *DeltaPayload) AminoSize(_ *amino.Codec) int

+ func (payload *DeltaPayload) MarshalAminoTo(_ *amino.Codec, buf *bytes.Buffer) error

+ func (payload *DeltaPayload) MarshalToAmino(cdc *amino.Codec) ([]byte, error)

+ func (payload *DeltaPayload) UnmarshalFromAmino(_ *amino.Codec, data []byte) error

type DeltasMessage

+ func (m *DeltasMessage) AminoSize(_ *amino.Codec) int

+ func (m *DeltasMessage) MarshalAminoTo(_ *amino.Codec, buf *bytes.Buffer) error

+ func (m *DeltasMessage) MarshalToAmino(cdc *amino.Codec) ([]byte, error)

+ func (m *DeltasMessage) UnmarshalFromAmino(_ *amino.Codec, data []byte) error

v1.6.2

Aug 25, 2022

Changes in this version

+ const MainNet

+ const MainNetGenesisHeight

+ const MainNetMercuyHeight

+ const MainNetVeneus1Height

+ const MainNetVeneusHeight

+ const TestNet

+ const TestNetChainName1

+ const TestNetChangeChainId

+ const TestNetGenesisHeight

+ const TestNetMercuryHeight

+ const TestNetVeneus1Height

+ const TestNetVeneusHeight

+ func GetNodePruneHeight() int64

+ func SetupMainNetEnvironment(pruneH int64)

+ func SetupTestNetEnvironment(pruneH int64)

+ type CM40Block struct

+ Evidence EvidenceData

+ LastCommit *IBCCommit

type DeltaPayload

+ WasmWatchBytes []byte

type Deltas

+ func (d *Deltas) WasmWatchBytes() []byte

type IBCHeader

+ func (h IBCHeader) ToCM39Header() Header

v1.6.1

Jul 29, 2022

v1.6.0

Jul 18, 2022

Changes in this version

+ const AddressStringLen

+ const TxHashLen

+ var MILESTONE_VENUS2_HEIGHT string

+ func GetVenus2Height() int64

+ func HigherThanVenus2(h int64) bool

+ func UnittestOnlySetMilestoneVenus2Height(h int64)

type Vote

+ HasVC bool

v1.5.6

Jun 22, 2022

v1.5.5

Jun 17, 2022

Changes in this version

+ const EventProposeRequest

type MockPV

+ func (pv MockPV) SignBytes(bz []byte) ([]byte, error)

type PrivValidator

+ SignBytes func(bz []byte) ([]byte, error)

type Proposal

+ HasVC bool

v1.5.4

Jun 14, 2022

v1.5.3

Jun 2, 2022

Changes in this version

+ type ValidatorsByVotingPower []*Validator

+ func (valz ValidatorsByVotingPower) Len() int

+ func (valz ValidatorsByVotingPower) Less(i, j int) bool

+ func (valz ValidatorsByVotingPower) Swap(i, j int)

v1.5.2

May 30, 2022

Changes in this version

type Commit

+ func (commit *Commit) IBCVoteSignBytes(chainID string, valIdx int) []byte

type Header

+ func (h *Header) PureIBCHash() tmbytes.HexBytes

type SignedHeader

+ func (sh SignedHeader) ValidateBasicForIBC(chainID string) error

type Validator

+ func (v *Validator) IBCHeightBytes() []byte

type ValidatorSet

+ func (vals *ValidatorSet) IBCHash() []byte

+ func (vals *ValidatorSet) IBCVerifyCommitLight(chainID string, blockID BlockID, height int64, commit *Commit) error

v1.5.1

May 27, 2022

v1.5.0

May 23, 2022

Changes in this version

+ const CompressDividing

+ const EventBlockPart

+ const FlagBlockCompressFlag

+ const FlagBlockCompressThreshold

+ const FlagBlockCompressType

+ var BlockCompressFlag = 0

+ var BlockCompressThreshold = 1024000

+ var BlockCompressType = 0x00

+ var MILESTONE_MARS_HEIGHT string

+ func GetMarsHeight() int64

+ func HigherThanMars(height int64) bool

+ func UncompressBlockFromBytes(payload []byte) (res []byte, compressSign int, err error)

+ func UncompressBlockFromReader(pbpReader io.Reader) (io.Reader, error)

+ func UnittestOnlySetMilestoneMarsHeight(height int64)

+ func UpdateBlockPartSizeBytes(size int)

type Block

+ func (b *Block) MakePartSetByExInfo(exInfo *BlockExInfo) *PartSet

+ type BlockExInfo struct

+ BlockCompressFlag int

+ BlockCompressType int

+ BlockPartSize int

v1.3.1

May 4, 2022

v1.3.0

Apr 28, 2022

Changes in this version

+ const EventSignVote

+ var MILESTONE_VENUS1_HEIGHT string

+ func GetVenus1Height() int64

+ func HigherThanVenus1(h int64) bool

+ func IBCCanonicalizeBlockID(rbid *BlockID) *tmproto.CanonicalBlockID

+ func IBCCanonicalizePartSetHeader(psh PartSetHeader) tmproto.CanonicalPartSetHeader

+ func IBCCanonicalizeProposal(chainID string, proposal *Proposal) tmproto.CanonicalProposal

+ func IBCCanonicalizeVote(chainID string, vote *Vote) tmproto.CanonicalVote

+ func ProposalSignBytes(chainID string, p *Proposal) []byte

+ func UnittestOnlySetMilestoneVenus1Height(h int64)

+ func VoteSignBytes(chainID string, vote *Vote) []byte

type BlockID

+ func (blockID *BlockID) ToIBCProto() tmproto.BlockID

type Header

+ func (h *Header) IBCHash() tmbytes.HexBytes

+ type IBCBlockID struct

+ Hash tmbytes.HexBytes

+ PartSetHeader IBCPartSetHeader

+ func (b IBCBlockID) ToBlockID() BlockID

+ type IBCCommit struct

+ BlockID IBCBlockID

+ Height int64

+ Round int32

+ Signatures []CommitSig

+ func (c *IBCCommit) ToCommit() *Commit

+ type IBCHeader struct

+ AppHash tmbytes.HexBytes

+ ChainID string

+ ConsensusHash tmbytes.HexBytes

+ DataHash tmbytes.HexBytes

+ EvidenceHash tmbytes.HexBytes

+ Height int64

+ LastBlockID IBCBlockID

+ LastCommitHash tmbytes.HexBytes

+ LastResultsHash tmbytes.HexBytes

+ NextValidatorsHash tmbytes.HexBytes

+ ProposerAddress Address

+ Time time.Time

+ ValidatorsHash tmbytes.HexBytes

+ Version tmversion.Consensus

+ type IBCPartSetHeader struct

+ Hash tmbytes.HexBytes

+ Total uint32

+ type IBCSignedHeader struct

+ Commit *IBCCommit

type PartSetHeader

+ func (psh *PartSetHeader) ToIBCProto() tmproto.PartSetHeader

type Validator

+ func (v *Validator) HeightBytes(h int64) []byte

+ func (v *Validator) OriginBytes() []byte

type ValidatorSet

+ func (vals *ValidatorSet) IBCGetByAddress(address []byte) (index int, val *Validator)

+ func (vals *ValidatorSet) IBCVerifyCommitLightTrusting(chainID string, blockID BlockID, height int64, commit *Commit, ...) error

v1.2.4

Jun 17, 2022

v1.2.3

Jun 15, 2022

v1.2.2

Jun 1, 2022

v1.2.1

May 6, 2022

v1.2.0

Mar 23, 2022

v1.1.10

Mar 10, 2022

v1.1.9

Feb 25, 2022

Changes in this version

+ const FlagSigCacheSize

+ func Bytes2Hash(txBytes []byte, height int64) string

+ func InitSignatureCache()

type ABCIResult

+ func (a ABCIResult) AminoSize() int

+ func (a ABCIResult) MarshalToAmino(_ *amino.Codec) ([]byte, error)

type Block

+ func (b *Block) AminoSize(cdc *amino.Codec) int

+ func (b *Block) FastSize() (size int)

+ type Cache struct

+ func SignatureCache() *Cache

+ func (c *Cache) Add(key string, value *TxSigCache)

+ func (c *Cache) Get(key string) (*TxSigCache, bool)

+ func (c *Cache) HitCount() int64

+ func (c *Cache) ReadCount() int64

+ func (c *Cache) Remove(key string)

type Commit

+ func (commit Commit) AminoSize(cdc *amino.Codec) int

type CommitSig

+ func (cs CommitSig) AminoSize(_ *amino.Codec) int

type Data

+ func (d Data) AminoSize(_ *amino.Codec) int

type DuplicateVoteEvidence

+ func (dve DuplicateVoteEvidence) AminoSize(cdc *amino.Codec) int

type EvidenceData

+ func (d EvidenceData) AminoSize(cdc *amino.Codec) int

type Header

+ func (h Header) AminoSize(cdc *amino.Codec) int

+ type TxSigCache struct

+ From ethcmn.Address

+ Signer ethtypes.Signer

+ func (s TxSigCache) EqualSiger(siger ethtypes.Signer) bool

+ func (s TxSigCache) GetFrom() ethcmn.Address

+ func (s TxSigCache) GetSigner() ethtypes.Signer

type Vote

+ func (vote Vote) AminoSize(cdc *amino.Codec) int

v1.1.8

Feb 18, 2022

Changes in this version

+ const FlagDeltaVersion

v1.1.7

Feb 7, 2022

v1.1.6

Jan 30, 2022

v1.1.5

Jan 19, 2022

Changes in this version

+ const DuplicateVoteEvidenceName

+ const FlagRedisDB

type Block

+ func (b *Block) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error

type BlockID

+ func (blockID *BlockID) UnmarshalFromAmino(data []byte) error

+ func (blockID BlockID) AminoSize() int

type Commit

+ func (commit *Commit) UnmarshalFromAmino(data []byte) error

type CommitSig

+ func (cs *CommitSig) UnmarshalFromAmino(data []byte) error

type Data

+ func (d *Data) UnmarshalFromAmino(data []byte) error

type DuplicateVoteEvidence

+ func (dve *DuplicateVoteEvidence) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error

type EvidenceData

+ func (d *EvidenceData) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error

type Header

+ func (h *Header) UnmarshalFromAmino(data []byte) error

type Part

+ func (part *Part) UnmarshalFromAmino(data []byte) error

type PartSetHeader

+ func (psh *PartSetHeader) UnmarshalFromAmino(data []byte) error

+ func (psh PartSetHeader) AminoSize() int

type TxResult

+ func (txResult *TxResult) UnmarshalFromAmino(data []byte) error

type Vote

+ func (vote *Vote) UnmarshalFromAmino(data []byte) error

v1.1.4

Jan 12, 2022

v1.1.3

Jan 12, 2022

Changes in this version

+ func GetMilestoneVenusHeight() int64

+ func UnittestOnlySetMilestoneVenusHeight(height int64)

v1.1.2

Jan 11, 2022

v1.1.1

Jan 10, 2022

Changes in this version

+ var DownloadDelta = false

+ var FastQuery = false

+ var UploadDelta = false

v1.1.0

Jan 5, 2022

Changes in this version

+ var MILESTONE_GENESIS_HEIGHT string

+ var MILESTONE_MERCURY_HEIGHT string

+ var MILESTONE_VENUS_HEIGHT string

+ func GetMercuryHeight() int64

+ func GetVenusHeight() int64

+ func HigherThanMercury(height int64) bool

+ func HigherThanVenus(height int64) bool

v1.0.3

Jan 4, 2022

Changes in this version

+ const FlagBufferSize

type Deltas

+ func (d *Deltas) HashElapsed() time.Duration

type DeltasMessage

+ MetadataHash []byte

v1.0.2

Dec 29, 2021

Changes in this version

+ const FlagAppendPid

type Deltas

+ From string

type DeltasMessage

+ From string

v1.0.1

Dec 28, 2021

Changes in this version

+ const FlagDDSCompressFlag

+ const FlagDDSCompressType

+ const FlagRedisExpire

+ type DeltaPayload struct

+ ABCIRsp []byte

+ DeltasBytes []byte

+ WatchBytes []byte

type Deltas

+ CompressFlag int

+ CompressType int

+ Payload DeltaPayload

+ func (d *Deltas) CompressOrUncompressElapsed() time.Duration

+ func (d *Deltas) MarshalOrUnmarshalElapsed() time.Duration

+ func (dds *Deltas) Validate(height int64) bool

+ type DeltasMessage struct

+ CompressType int

+ Height int64

+ Metadata []byte

+ Version int

v1.0.0

Dec 22, 2021

Changes in this version

+ const DataCenterUrl

+ const DeltaVersion

+ const FlagApplyP2PDelta

+ const FlagBroadcastP2PDelta

+ const FlagDataCenter

+ const FlagDownloadDDS

+ const FlagFastQuery

+ const FlagRedisAuth

+ const FlagRedisUrl

+ const FlagUploadDDS

+ const MaxDeltasSizeBytes

+ var Json = jsoniter.ConfigCompatibleWithStandardLibrary

+ func EnableApplyP2PDelta() bool

+ func EnableBroadcastP2PDelta() bool

+ func EnableDownloadDelta() bool

+ func EnableUploadDelta() bool

+ func GetCenterUrl() string

+ func IsCenterEnabled() bool

+ func IsFastQuery() bool

+ func RedisAuth() string

+ func RedisUrl() string

+ type Deltas struct

+ ABCIRsp []byte

+ DeltasBytes []byte

+ Height int64

+ Version int

+ WatchBytes []byte

+ func (d *Deltas) Marshal() ([]byte, error)

+ func (d *Deltas) Size() int

+ func (d *Deltas) String() string

+ func (d *Deltas) Unmarshal(bs []byte) error

+ type DeltasMeta struct

+ DeltasSize int

+ func (bm *DeltasMeta) Marshal() ([]byte, error)

+ func (bm *DeltasMeta) MarshalTo(data []byte) (int, error)

+ func (bm *DeltasMeta) Size() int

+ func (bm *DeltasMeta) Unmarshal(bs []byte) error

v0

v0.19.17

Nov 29, 2021

v0.19.16

Nov 20, 2021

Changes in this version

+ func IsMainNet() bool

+ func IsTestNet() bool

v0.19.15

Nov 16, 2021

v0.19.14

Nov 13, 2021

Changes in this version

+ const ABCIEvidenceTypeDuplicateVote

+ const ABCIEvidenceTypeMock

+ const ABCIPubKeyTypeEd25519

+ const ABCIPubKeyTypeSecp256k1

+ const ABCIPubKeyTypeSr25519

+ const BlockPartSizeBytes

+ const EventCompleteProposal

+ const EventLock

+ const EventNewBlock

+ const EventNewBlockHeader

+ const EventNewRound

+ const EventNewRoundStep

+ const EventPendingTx

+ const EventPolka

+ const EventRelock

+ const EventTimeoutPropose

+ const EventTimeoutWait

+ const EventTx

+ const EventTypeKey

+ const EventUnlock

+ const EventValidBlock

+ const EventValidatorSetUpdates

+ const EventVote

+ const MaxAminoOverheadForBlock

+ const MaxBlockPartsCount

+ const MaxBlockSizeBytes

+ const MaxChainIDLen

+ const MaxEvidenceBytes

+ const MaxEvidenceBytesDenominator

+ const MaxHeaderBytes

+ const MaxTotalVotingPower

+ const MaxVoteBytes

+ const MaxVotesCount

+ const PriorityWindowSizeFactor

+ const TimeFormat

+ const TxHashKey

+ const TxHeightKey

+ var ABCIPubKeyTypesToAminoNames = map[string]string

+ var ErrInvalidBlockPartHash = errors.New("error invalid block part hash")

+ var ErrInvalidBlockPartSignature = errors.New("error invalid block part signature")

+ var ErrPartSetInvalidProof = errors.New("error part set invalid proof")

+ var ErrPartSetUnexpectedIndex = errors.New("error part set unexpected index")

+ var ErrVoteInvalidBlockHash = errors.New("invalid block hash")

+ var ErrVoteInvalidSignature = errors.New("invalid signature")

+ var ErrVoteInvalidValidatorAddress = errors.New("invalid validator address")

+ var ErrVoteInvalidValidatorIndex = errors.New("invalid validator index")

+ var ErrVoteNil = errors.New("nil vote")

+ var ErrVoteNonDeterministicSignature = errors.New("non-deterministic signature")

+ var ErrVoteUnexpectedStep = errors.New("unexpected step")

+ var ErroringMockPVErr = errors.New("erroringMockPV always returns an error")

+ var EventQueryCompleteProposal = QueryForEvent(EventCompleteProposal)

+ var EventQueryLock = QueryForEvent(EventLock)

+ var EventQueryNewBlock = QueryForEvent(EventNewBlock)

+ var EventQueryNewBlockHeader = QueryForEvent(EventNewBlockHeader)

+ var EventQueryNewRound = QueryForEvent(EventNewRound)

+ var EventQueryNewRoundStep = QueryForEvent(EventNewRoundStep)

+ var EventQueryPolka = QueryForEvent(EventPolka)

+ var EventQueryRelock = QueryForEvent(EventRelock)

+ var EventQueryTimeoutPropose = QueryForEvent(EventTimeoutPropose)

+ var EventQueryTimeoutWait = QueryForEvent(EventTimeoutWait)

+ var EventQueryTx = QueryForEvent(EventTx)

+ var EventQueryUnlock = QueryForEvent(EventUnlock)

+ var EventQueryValidBlock = QueryForEvent(EventValidBlock)

+ var EventQueryValidatorSetUpdates = QueryForEvent(EventValidatorSetUpdates)

+ var EventQueryVote = QueryForEvent(EventVote)

+ var MaxSignatureSize = tmmath.MaxInt(ed25519.SignatureSize, 64)

+ var PB2TM = pb2tm

+ var PeerStateKey = "ConsensusReactor.peerState"

+ var TM2PB = tm2pb

+ func CanonicalTime(t time.Time) string

+ func ComputeAminoOverhead(tx Tx, fieldNum int) int64

+ func EventQueryTxFor(tx Tx) tmpubsub.Query

+ func EvidenceToProto(evidence Evidence) (*tmproto.Evidence, error)

+ func GetCodec() *amino.Codec

+ func GetStartBlockHeight() int64

+ func IsErrNotEnoughVotingPowerSigned(err error) bool

+ func IsVoteTypeValid(t SignedMsgType) bool

+ func MaxDataBytes(maxBytes int64, valsCount, evidenceCount int) int64

+ func MaxDataBytesUnknownEvidence(maxBytes int64, valsCount int) int64

+ func MaxEvidencePerBlock(blockMaxBytes int64) (int64, int64)

+ func QueryForEvent(eventType string) tmpubsub.Query

+ func RandValidator(randPower bool, minPower int64) (*Validator, PrivValidator)

+ func RandValidatorSet(numValidators int, votingPower int64) (*ValidatorSet, []PrivValidator)

+ func RegisterBlockAmino(cdc *amino.Codec)

+ func RegisterEventDatas(cdc *amino.Codec)

+ func RegisterEvidences(cdc *amino.Codec)

+ func RegisterMockEvidences(cdc *amino.Codec)

+ func RegisterMockEvidencesGlobal()

+ func ValidateHash(h []byte) error

+ func ValidateTime(t time.Time) error

+ func ValidatorListString(vals []*Validator) string

+ type ABCIResult struct

+ Code uint32

+ Data bytes.HexBytes

+ func NewResultFromResponse(response *abci.ResponseDeliverTx) ABCIResult

+ func (a ABCIResult) Bytes() []byte

+ type ABCIResults []ABCIResult

+ func NewResults(responses []*abci.ResponseDeliverTx) ABCIResults

+ func (a ABCIResults) Bytes() []byte

+ func (a ABCIResults) Hash() []byte

+ func (a ABCIResults) ProveResult(i int) merkle.SimpleProof

+ type Address = crypto.Address

+ type Block struct

+ Evidence EvidenceData

+ LastCommit *Commit

+ func MakeBlock(height int64, txs []Tx, lastCommit *Commit, evidence []Evidence) *Block

+ func (b *Block) Hash() tmbytes.HexBytes

+ func (b *Block) HashesTo(hash []byte) bool

+ func (b *Block) MakePartSet(partSize int) *PartSet

+ func (b *Block) Marshal() ([]byte, error)

+ func (b *Block) MarshalTo(data []byte) (int, error)

+ func (b *Block) Size() int

+ func (b *Block) String() string

+ func (b *Block) StringIndented(indent string) string

+ func (b *Block) StringShort() string

+ func (b *Block) Unmarshal(bs []byte) error

+ func (b *Block) ValidateBasic() error

+ type BlockEventPublisher interface

+ PublishEventNewBlock func(block EventDataNewBlock) error

+ PublishEventNewBlockHeader func(header EventDataNewBlockHeader) error

+ PublishEventPendingTx func(EventDataTx) error

+ PublishEventTx func(EventDataTx) error

+ PublishEventValidatorSetUpdates func(EventDataValidatorSetUpdates) error

+ type BlockID struct

+ Hash tmbytes.HexBytes

+ PartsHeader PartSetHeader

+ func BlockIDFromProto(bID *tmproto.BlockID) (*BlockID, error)

+ func (blockID *BlockID) ToProto() tmproto.BlockID

+ func (blockID BlockID) Equals(other BlockID) bool

+ func (blockID BlockID) IsComplete() bool

+ func (blockID BlockID) IsZero() bool

+ func (blockID BlockID) Key() string

+ func (blockID BlockID) String() string

+ func (blockID BlockID) ValidateBasic() error

+ type BlockIDFlag byte

+ const BlockIDFlagAbsent

+ const BlockIDFlagCommit

+ const BlockIDFlagNil

+ type BlockMeta struct

+ BlockID BlockID

+ BlockSize int

+ Header Header

+ NumTxs int

+ func NewBlockMeta(block *Block, blockParts *PartSet) *BlockMeta

+ func (bm *BlockMeta) Marshal() ([]byte, error)

+ func (bm *BlockMeta) MarshalTo(data []byte) (int, error)

+ func (bm *BlockMeta) Size() int

+ func (bm *BlockMeta) Unmarshal(bs []byte) error

+ func (bm *BlockMeta) ValidateBasic() error

+ type BlockParams struct

+ MaxBytes int64

+ MaxGas int64

+ TimeIotaMs int64

+ func DefaultBlockParams() BlockParams

+ type CanonicalBlockID struct

+ Hash bytes.HexBytes

+ PartsHeader CanonicalPartSetHeader

+ func CanonicalizeBlockID(blockID BlockID) CanonicalBlockID

+ type CanonicalPartSetHeader struct

+ Hash bytes.HexBytes

+ Total int

+ func CanonicalizePartSetHeader(psh PartSetHeader) CanonicalPartSetHeader

+ type CanonicalProposal struct

+ BlockID CanonicalBlockID

+ ChainID string

+ Height int64

+ POLRound int64

+ Round int64

+ Timestamp time.Time

+ Type SignedMsgType

+ func CanonicalizeProposal(chainID string, proposal *Proposal) CanonicalProposal

+ type CanonicalVote struct

+ BlockID CanonicalBlockID

+ ChainID string

+ Height int64

+ Round int64

+ Timestamp time.Time

+ Type SignedMsgType

+ func CanonicalizeVote(chainID string, vote *Vote) CanonicalVote

+ type Commit struct

+ BlockID BlockID

+ Height int64

+ Round int

+ Signatures []CommitSig

+ func CommitFromProto(cp *tmproto.Commit) (*Commit, error)

+ func MakeCommit(blockID BlockID, height int64, round int, voteSet *VoteSet, ...) (*Commit, error)

+ func NewCommit(height int64, round int, blockID BlockID, commitSigs []CommitSig) *Commit

+ func (commit *Commit) BitArray() *bits.BitArray

+ func (commit *Commit) GetByIndex(valIdx int) *Vote

+ func (commit *Commit) GetHeight() int64

+ func (commit *Commit) GetRound() int

+ func (commit *Commit) GetVote(valIdx int) *Vote

+ func (commit *Commit) Hash() tmbytes.HexBytes

+ func (commit *Commit) IsCommit() bool

+ func (commit *Commit) Size() int

+ func (commit *Commit) StringIndented(indent string) string

+ func (commit *Commit) ToProto() *tmproto.Commit

+ func (commit *Commit) Type() byte

+ func (commit *Commit) ValidateBasic() error

+ func (commit *Commit) VoteSignBytes(chainID string, valIdx int) []byte

+ type CommitSig struct

+ BlockIDFlag BlockIDFlag

+ Signature []byte

+ Timestamp time.Time

+ ValidatorAddress Address

+ func NewCommitSigAbsent() CommitSig

+ func NewCommitSigForBlock(signature []byte, valAddr Address, ts time.Time) CommitSig

+ func (cs *CommitSig) FromProto(csp tmproto.CommitSig) error

+ func (cs *CommitSig) ToProto() *tmproto.CommitSig

+ func (cs CommitSig) Absent() bool

+ func (cs CommitSig) BlockID(commitBlockID BlockID) BlockID

+ func (cs CommitSig) ForBlock() bool

+ func (cs CommitSig) String() string

+ func (cs CommitSig) ValidateBasic() error

+ type ConsensusParams struct

+ Block BlockParams

+ Evidence EvidenceParams

+ Validator ValidatorParams

+ func DefaultConsensusParams() *ConsensusParams

+ func (params *ConsensusParams) Equals(params2 *ConsensusParams) bool

+ func (params *ConsensusParams) Hash() []byte

+ func (params *ConsensusParams) Validate() error

+ func (params ConsensusParams) Update(params2 *abci.ConsensusParams) ConsensusParams

+ type Data struct

+ Txs Txs

+ func (data *Data) Hash() tmbytes.HexBytes

+ func (data *Data) StringIndented(indent string) string

+ type DuplicateVoteEvidence struct

+ PubKey crypto.PubKey

+ VoteA *Vote

+ VoteB *Vote

+ func NewDuplicateVoteEvidence(pubkey crypto.PubKey, vote1 *Vote, vote2 *Vote) *DuplicateVoteEvidence

+ func (dve *DuplicateVoteEvidence) Address() []byte

+ func (dve *DuplicateVoteEvidence) Bytes() []byte

+ func (dve *DuplicateVoteEvidence) Equal(ev Evidence) bool

+ func (dve *DuplicateVoteEvidence) Hash() []byte

+ func (dve *DuplicateVoteEvidence) Height() int64

+ func (dve *DuplicateVoteEvidence) String() string

+ func (dve *DuplicateVoteEvidence) Time() time.Time

+ func (dve *DuplicateVoteEvidence) ValidateBasic() error

+ func (dve *DuplicateVoteEvidence) Verify(chainID string, pubKey crypto.PubKey) error

+ type ErrEvidenceInvalid struct

+ ErrorValue error

+ Evidence Evidence

+ func NewErrEvidenceInvalid(ev Evidence, err error) *ErrEvidenceInvalid

+ func (err *ErrEvidenceInvalid) Error() string

+ type ErrEvidenceOverflow struct

+ GotNum int64

+ MaxNum int64

+ func NewErrEvidenceOverflow(max, got int64) *ErrEvidenceOverflow

+ func (err *ErrEvidenceOverflow) Error() string

+ type ErrInvalidCommitHeight struct

+ Actual int64

+ Expected int64

+ func NewErrInvalidCommitHeight(expected, actual int64) ErrInvalidCommitHeight

+ func (e ErrInvalidCommitHeight) Error() string

+ type ErrInvalidCommitSignatures struct

+ Actual int

+ Expected int

+ func NewErrInvalidCommitSignatures(expected, actual int) ErrInvalidCommitSignatures

+ func (e ErrInvalidCommitSignatures) Error() string

+ type ErrNotEnoughVotingPowerSigned struct

+ Got int64

+ Needed int64

+ func (e ErrNotEnoughVotingPowerSigned) Error() string

+ type ErrVoteConflictingVotes struct

+ func NewConflictingVoteError(val *Validator, vote1, vote2 *Vote) *ErrVoteConflictingVotes

+ func (err *ErrVoteConflictingVotes) Error() string

+ type ErroringMockPV struct

+ func NewErroringMockPV() *ErroringMockPV

+ func (pv *ErroringMockPV) SignProposal(chainID string, proposal *Proposal) error

+ func (pv *ErroringMockPV) SignVote(chainID string, vote *Vote) error

+ type EventBus struct

+ func NewEventBus() *EventBus

+ func NewEventBusWithBufferCapacity(cap int) *EventBus

+ func (b *EventBus) NumClientSubscriptions(clientID string) int

+ func (b *EventBus) NumClients() int

+ func (b *EventBus) OnStart() error

+ func (b *EventBus) OnStop()

+ func (b *EventBus) Publish(eventType string, eventData TMEventData) error

+ func (b *EventBus) PublishEventCompleteProposal(data EventDataCompleteProposal) error

+ func (b *EventBus) PublishEventLock(data EventDataRoundState) error

+ func (b *EventBus) PublishEventNewBlock(data EventDataNewBlock) error

+ func (b *EventBus) PublishEventNewBlockHeader(data EventDataNewBlockHeader) error

+ func (b *EventBus) PublishEventNewRound(data EventDataNewRound) error

+ func (b *EventBus) PublishEventNewRoundStep(data EventDataRoundState) error

+ func (b *EventBus) PublishEventPendingTx(data EventDataTx) error

+ func (b *EventBus) PublishEventPolka(data EventDataRoundState) error

+ func (b *EventBus) PublishEventRelock(data EventDataRoundState) error

+ func (b *EventBus) PublishEventTimeoutPropose(data EventDataRoundState) error

+ func (b *EventBus) PublishEventTimeoutWait(data EventDataRoundState) error

+ func (b *EventBus) PublishEventTx(data EventDataTx) error

+ func (b *EventBus) PublishEventUnlock(data EventDataRoundState) error

+ func (b *EventBus) PublishEventValidBlock(data EventDataRoundState) error

+ func (b *EventBus) PublishEventValidatorSetUpdates(data EventDataValidatorSetUpdates) error

+ func (b *EventBus) PublishEventVote(data EventDataVote) error

+ func (b *EventBus) SetLogger(l log.Logger)

+ func (b *EventBus) Subscribe(ctx context.Context, subscriber string, query tmpubsub.Query, ...) (Subscription, error)

+ func (b *EventBus) SubscribeUnbuffered(ctx context.Context, subscriber string, query tmpubsub.Query) (Subscription, error)

+ func (b *EventBus) Unsubscribe(ctx context.Context, subscriber string, query tmpubsub.Query) error

+ func (b *EventBus) UnsubscribeAll(ctx context.Context, subscriber string) error

+ type EventBusSubscriber interface

+ NumClientSubscriptions func(clientID string) int

+ NumClients func() int

+ Subscribe func(ctx context.Context, subscriber string, query tmpubsub.Query, ...) (Subscription, error)

+ Unsubscribe func(ctx context.Context, subscriber string, query tmpubsub.Query) error

+ UnsubscribeAll func(ctx context.Context, subscriber string) error

+ type EventDataCompleteProposal struct

+ BlockID BlockID

+ Height int64

+ Round int

+ Step string

+ type EventDataNewBlock struct

+ Block *Block

+ ResultBeginBlock abci.ResponseBeginBlock

+ ResultEndBlock abci.ResponseEndBlock

+ type EventDataNewBlockHeader struct

+ Header Header

+ NumTxs int64

+ ResultBeginBlock abci.ResponseBeginBlock

+ ResultEndBlock abci.ResponseEndBlock

+ type EventDataNewRound struct

+ Height int64

+ Proposer ValidatorInfo

+ Round int

+ Step string

+ type EventDataRoundState struct

+ Height int64

+ Round int

+ Step string

+ type EventDataString string

+ type EventDataTx struct

+ type EventDataValidatorSetUpdates struct

+ ValidatorUpdates []*Validator

+ type EventDataVote struct

+ Vote *Vote

+ type Evidence interface

+ Address func() []byte

+ Bytes func() []byte

+ Equal func(Evidence) bool

+ Hash func() []byte

+ Height func() int64

+ String func() string

+ Time func() time.Time

+ ValidateBasic func() error

+ Verify func(chainID string, pubKey crypto.PubKey) error

+ func EvidenceFromProto(evidence *tmproto.Evidence) (Evidence, error)

+ type EvidenceData struct

+ Evidence EvidenceList

+ func (data *EvidenceData) Hash() tmbytes.HexBytes

+ func (data *EvidenceData) StringIndented(indent string) string

+ type EvidenceList []Evidence

+ func (evl EvidenceList) Has(evidence Evidence) bool

+ func (evl EvidenceList) Hash() []byte

+ func (evl EvidenceList) String() string

+ type EvidenceParams struct

+ MaxAgeDuration time.Duration

+ MaxAgeNumBlocks int64

+ func DefaultEvidenceParams() EvidenceParams

+ type GenesisDoc struct

+ AppHash tmbytes.HexBytes

+ AppState json.RawMessage

+ ChainID string

+ ConsensusParams *ConsensusParams

+ GenesisTime time.Time

+ Validators []GenesisValidator

+ func GenesisDocFromFile(genDocFile string) (*GenesisDoc, error)

+ func GenesisDocFromJSON(jsonBlob []byte) (*GenesisDoc, error)

+ func (genDoc *GenesisDoc) SaveAs(file string) error

+ func (genDoc *GenesisDoc) ValidateAndComplete() error

+ func (genDoc *GenesisDoc) ValidatorHash() []byte

+ type GenesisValidator struct

+ Address Address

+ Name string

+ Power int64

+ PubKey crypto.PubKey

+ type HashedParams struct

+ BlockMaxBytes int64

+ BlockMaxGas int64

+ type Header struct

+ AppHash tmbytes.HexBytes

+ ChainID string

+ ConsensusHash tmbytes.HexBytes

+ DataHash tmbytes.HexBytes

+ EvidenceHash tmbytes.HexBytes

+ Height int64

+ LastBlockID BlockID

+ LastCommitHash tmbytes.HexBytes

+ LastResultsHash tmbytes.HexBytes

+ NextValidatorsHash tmbytes.HexBytes

+ ProposerAddress Address

+ Time time.Time

+ ValidatorsHash tmbytes.HexBytes

+ Version version.Consensus

+ func HeaderFromProto(ph *tmproto.Header) (Header, error)

+ func (h *Header) Hash() tmbytes.HexBytes

+ func (h *Header) Populate(version version.Consensus, chainID string, timestamp time.Time, ...)

+ func (h *Header) StringIndented(indent string) string

+ func (h *Header) ToProto() *tmproto.Header

+ func (h Header) ValidateBasic() error

+ type MockEvidence struct

+ EvidenceAddress []byte

+ EvidenceHeight int64

+ EvidenceTime time.Time

+ func NewMockEvidence(height int64, eTime time.Time, idx int, address []byte) MockEvidence

+ func (e MockEvidence) Address() []byte

+ func (e MockEvidence) Bytes() []byte

+ func (e MockEvidence) Equal(ev Evidence) bool

+ func (e MockEvidence) Hash() []byte

+ func (e MockEvidence) Height() int64

+ func (e MockEvidence) String() string

+ func (e MockEvidence) Time() time.Time

+ func (e MockEvidence) ValidateBasic() error

+ func (e MockEvidence) Verify(chainID string, pubKey crypto.PubKey) error

+ type MockPV struct

+ PrivKey crypto.PrivKey

+ func NewMockPV() MockPV

+ func NewMockPVWithParams(privKey crypto.PrivKey, breakProposalSigning, breakVoteSigning bool) MockPV

+ func (pv MockPV) DisableChecks()

+ func (pv MockPV) GetPubKey() (crypto.PubKey, error)

+ func (pv MockPV) SignProposal(chainID string, proposal *Proposal) error

+ func (pv MockPV) SignVote(chainID string, vote *Vote) error

+ func (pv MockPV) String() string

+ type MockRandomEvidence struct

+ func NewMockRandomEvidence(height int64, eTime time.Time, address []byte, randBytes []byte) MockRandomEvidence

+ func (e MockRandomEvidence) Hash() []byte

+ type NopEventBus struct

+ func (NopEventBus) PublishEventCompleteProposal(data EventDataRoundState) error

+ func (NopEventBus) PublishEventLock(data EventDataRoundState) error

+ func (NopEventBus) PublishEventNewBlock(data EventDataNewBlock) error

+ func (NopEventBus) PublishEventNewBlockHeader(data EventDataNewBlockHeader) error

+ func (NopEventBus) PublishEventNewRound(data EventDataRoundState) error

+ func (NopEventBus) PublishEventNewRoundStep(data EventDataRoundState) error

+ func (NopEventBus) PublishEventPendingTx(data EventDataTx) error

+ func (NopEventBus) PublishEventPolka(data EventDataRoundState) error

+ func (NopEventBus) PublishEventRelock(data EventDataRoundState) error

+ func (NopEventBus) PublishEventTimeoutPropose(data EventDataRoundState) error

+ func (NopEventBus) PublishEventTimeoutWait(data EventDataRoundState) error

+ func (NopEventBus) PublishEventTx(data EventDataTx) error

+ func (NopEventBus) PublishEventUnlock(data EventDataRoundState) error

+ func (NopEventBus) PublishEventValidatorSetUpdates(data EventDataValidatorSetUpdates) error

+ func (NopEventBus) PublishEventVote(data EventDataVote) error

+ func (NopEventBus) Subscribe(ctx context.Context, subscriber string, query tmpubsub.Query, ...) error

+ func (NopEventBus) Unsubscribe(ctx context.Context, subscriber string, query tmpubsub.Query) error

+ func (NopEventBus) UnsubscribeAll(ctx context.Context, subscriber string) error

+ type P2PID string

+ type Part struct

+ Bytes tmbytes.HexBytes

+ Index int

+ Proof merkle.SimpleProof

+ func (part *Part) String() string

+ func (part *Part) StringIndented(indent string) string

+ func (part *Part) ValidateBasic() error

+ type PartSet struct

+ func NewPartSetFromData(data []byte, partSize int) *PartSet

+ func NewPartSetFromHeader(header PartSetHeader) *PartSet

+ func (ps *PartSet) AddPart(part *Part) (bool, error)

+ func (ps *PartSet) BitArray() *bits.BitArray

+ func (ps *PartSet) Count() int

+ func (ps *PartSet) GetPart(index int) *Part

+ func (ps *PartSet) GetReader() io.Reader

+ func (ps *PartSet) HasHeader(header PartSetHeader) bool

+ func (ps *PartSet) Hash() []byte

+ func (ps *PartSet) HashesTo(hash []byte) bool

+ func (ps *PartSet) Header() PartSetHeader

+ func (ps *PartSet) IsComplete() bool

+ func (ps *PartSet) MarshalJSON() ([]byte, error)

+ func (ps *PartSet) StringShort() string

+ func (ps *PartSet) Total() int

+ type PartSetHeader struct

+ Hash tmbytes.HexBytes

+ Total int

+ func PartSetHeaderFromProto(ppsh *tmproto.PartSetHeader) (*PartSetHeader, error)

+ func (psh *PartSetHeader) ToProto() tmproto.PartSetHeader

+ func (psh PartSetHeader) Equals(other PartSetHeader) bool

+ func (psh PartSetHeader) IsZero() bool

+ func (psh PartSetHeader) String() string

+ func (psh PartSetHeader) ValidateBasic() error

+ type PartSetReader struct

+ func NewPartSetReader(parts []*Part) *PartSetReader

+ func (psr *PartSetReader) Read(p []byte) (n int, err error)

+ type PrivValidator interface

+ GetPubKey func() (crypto.PubKey, error)

+ SignProposal func(chainID string, proposal *Proposal) error

+ SignVote func(chainID string, vote *Vote) error

+ type PrivValidatorsByAddress []PrivValidator

+ func (pvs PrivValidatorsByAddress) Len() int

+ func (pvs PrivValidatorsByAddress) Less(i, j int) bool

+ func (pvs PrivValidatorsByAddress) Swap(i, j int)

+ type Proposal struct

+ BlockID BlockID

+ Height int64

+ POLRound int

+ Round int

+ Signature []byte

+ Timestamp time.Time

+ Type SignedMsgType

+ func NewProposal(height int64, round int, polRound int, blockID BlockID) *Proposal

+ func ProposalFromProto(pp *tmproto.Proposal) (*Proposal, error)

+ func (p *Proposal) SignBytes(chainID string) []byte

+ func (p *Proposal) String() string

+ func (p *Proposal) ToProto() *tmproto.Proposal

+ func (p *Proposal) ValidateBasic() error

+ type Signable interface

+ SignBytes func(chainID string) []byte

+ type SignedHeader struct

+ Commit *Commit

+ func SignedHeaderFromProto(shp *tmproto.SignedHeader) (*SignedHeader, error)

+ func (sh *SignedHeader) ToProto() *tmproto.SignedHeader

+ func (sh SignedHeader) String() string

+ func (sh SignedHeader) StringIndented(indent string) string

+ func (sh SignedHeader) ValidateBasic(chainID string) error

+ type SignedMsgType byte

+ const PrecommitType

+ const PrevoteType

+ const ProposalType

+ type Subscription interface

+ Cancelled func() <-chan struct{}

+ Err func() error

+ Out func() <-chan tmpubsub.Message

+ type TMEventData interface

+ type Tx []byte

+ func (tx Tx) Hash() []byte

+ func (tx Tx) String() string

+ type TxEventPublisher interface

+ PublishEventPendingTx func(EventDataTx) error

+ PublishEventTx func(EventDataTx) error

+ type TxProof struct

+ Data Tx

+ Proof merkle.SimpleProof

+ RootHash tmbytes.HexBytes

+ func (tp TxProof) Leaf() []byte

+ func (tp TxProof) Validate(dataHash []byte) error

+ type TxResult struct

+ Height int64

+ Index uint32

+ Result abci.ResponseDeliverTx

+ Tx Tx

+ type Txs []Tx

+ func (txs Txs) Hash() []byte

+ func (txs Txs) Index(tx Tx) int

+ func (txs Txs) IndexByHash(hash []byte) int

+ func (txs Txs) Proof(i int) TxProof

+ type Validator struct

+ Address Address

+ ProposerPriority int64

+ PubKey crypto.PubKey

+ VotingPower int64

+ func NewValidator(pubKey crypto.PubKey, votingPower int64) *Validator

+ func ValidatorFromProto(vp *tmproto.Validator) (*Validator, error)

+ func (v *Validator) Bytes() []byte

+ func (v *Validator) CompareProposerPriority(other *Validator) *Validator

+ func (v *Validator) Copy() *Validator

+ func (v *Validator) String() string

+ func (v *Validator) ToProto() (*tmproto.Validator, error)

+ type ValidatorInfo struct

+ Address Address

+ Index int

+ type ValidatorParams struct

+ PubKeyTypes []string

+ func DefaultValidatorParams() ValidatorParams

+ func (params *ValidatorParams) IsValidPubkeyType(pubkeyType string) bool

+ type ValidatorSet struct

+ Proposer *Validator

+ Validators []*Validator

+ func NewValidatorSet(valz []*Validator) *ValidatorSet

+ func ValidatorSetFromProto(vp *tmproto.ValidatorSet) (*ValidatorSet, error)

+ func (vals *ValidatorSet) Copy() *ValidatorSet

+ func (vals *ValidatorSet) CopyIncrementProposerPriority(times int) *ValidatorSet

+ func (vals *ValidatorSet) GetByAddress(address []byte) (index int, val *Validator)

+ func (vals *ValidatorSet) GetByIndex(index int) (address []byte, val *Validator)

+ func (vals *ValidatorSet) GetProposer() (proposer *Validator)

+ func (vals *ValidatorSet) HasAddress(address []byte) bool

+ func (vals *ValidatorSet) Hash() []byte

+ func (vals *ValidatorSet) IncrementProposerPriority(times int)

+ func (vals *ValidatorSet) IsNilOrEmpty() bool

+ func (vals *ValidatorSet) Iterate(fn func(index int, val *Validator) bool)

+ func (vals *ValidatorSet) RescalePriorities(diffMax int64)

+ func (vals *ValidatorSet) Size() int

+ func (vals *ValidatorSet) String() string

+ func (vals *ValidatorSet) StringIndented(indent string) string

+ func (vals *ValidatorSet) ToProto() (*tmproto.ValidatorSet, error)

+ func (vals *ValidatorSet) TotalVotingPower() int64

+ func (vals *ValidatorSet) UpdateWithChangeSet(changes []*Validator) error

+ func (vals *ValidatorSet) VerifyCommit(chainID string, blockID BlockID, height int64, commit *Commit) error

+ func (vals *ValidatorSet) VerifyCommitLight(chainID string, blockID BlockID, height int64, commit *Commit) error

+ func (vals *ValidatorSet) VerifyCommitLightTrusting(chainID string, blockID BlockID, height int64, commit *Commit, ...) error

+ func (vals *ValidatorSet) VerifyFutureCommit(newSet *ValidatorSet, chainID string, blockID BlockID, height int64, ...) error

+ type ValidatorsByAddress []*Validator

+ func (valz ValidatorsByAddress) Len() int

+ func (valz ValidatorsByAddress) Less(i, j int) bool

+ func (valz ValidatorsByAddress) Swap(i, j int)

+ type Vote struct

+ BlockID BlockID

+ Height int64

+ Round int

+ Signature []byte

+ Timestamp time.Time

+ Type SignedMsgType

+ ValidatorAddress Address

+ ValidatorIndex int

+ func MakeVote(height int64, blockID BlockID, valSet *ValidatorSet, privVal PrivValidator, ...) (*Vote, error)

+ func VoteFromProto(pv *tmproto.Vote) (*Vote, error)

+ func (vote *Vote) CommitSig() CommitSig

+ func (vote *Vote) Copy() *Vote

+ func (vote *Vote) SignBytes(chainID string) []byte

+ func (vote *Vote) String() string

+ func (vote *Vote) ToProto() *tmproto.Vote

+ func (vote *Vote) ValidateBasic() error

+ func (vote *Vote) Verify(chainID string, pubKey crypto.PubKey) error

+ type VoteSet struct

+ func CommitToVoteSet(chainID string, commit *Commit, vals *ValidatorSet) *VoteSet

+ func NewVoteSet(chainID string, height int64, round int, signedMsgType SignedMsgType, ...) *VoteSet

+ func (voteSet *VoteSet) AddVote(vote *Vote) (added bool, err error)

+ func (voteSet *VoteSet) BitArray() *bits.BitArray

+ func (voteSet *VoteSet) BitArrayByBlockID(blockID BlockID) *bits.BitArray

+ func (voteSet *VoteSet) BitArrayString() string

+ func (voteSet *VoteSet) ChainID() string

+ func (voteSet *VoteSet) GetByAddress(address []byte) *Vote

+ func (voteSet *VoteSet) GetByIndex(valIndex int) *Vote

+ func (voteSet *VoteSet) GetHeight() int64

+ func (voteSet *VoteSet) GetRound() int

+ func (voteSet *VoteSet) HasAll() bool

+ func (voteSet *VoteSet) HasTwoThirdsAny() bool

+ func (voteSet *VoteSet) HasTwoThirdsMajority() bool

+ func (voteSet *VoteSet) IsCommit() bool

+ func (voteSet *VoteSet) MakeCommit() *Commit

+ func (voteSet *VoteSet) MarshalJSON() ([]byte, error)

+ func (voteSet *VoteSet) SetPeerMaj23(peerID P2PID, blockID BlockID) error

+ func (voteSet *VoteSet) Size() int

+ func (voteSet *VoteSet) String() string

+ func (voteSet *VoteSet) StringIndented(indent string) string

+ func (voteSet *VoteSet) StringShort() string

+ func (voteSet *VoteSet) TwoThirdsMajority() (blockID BlockID, ok bool)

+ func (voteSet *VoteSet) Type() byte

+ func (voteSet *VoteSet) VoteStrings() []string

+ type VoteSetJSON struct

+ PeerMaj23s map[P2PID]BlockID

+ Votes []string

+ VotesBitArray string

+ type VoteSetReader interface

+ BitArray func() *bits.BitArray

+ GetByIndex func(int) *Vote

+ GetHeight func() int64

+ GetRound func() int

+ IsCommit func() bool

+ Size func() int

+ Type func() byte

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL