types

package

Go to main page

Versions in this module

v0

v0.16.0

Feb 21, 2018

Changes in this version

+ type Address = cmn.HexBytes

type Mempool

+ FlushAppConn func() error

type MockMempool

+ func (m MockMempool) FlushAppConn() error

v0.15.0

Dec 29, 2017

Changes in this version

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

+ func CanonicalTime(t time.Time) string

+ type ABCIResult struct

+ Code uint32

+ Data data.Bytes

+ func NewResultFromResponse(response *abci.ResponseDeliverTx) ABCIResult

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

+ type ABCIResults []ABCIResult

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

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

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

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

type Block

+ Evidence EvidenceData

+ func (b *Block) AddEvidence(evidence []Evidence)

+ type BlockEventPublisher interface

+ PublishEventNewBlock func(block EventDataNewBlock) error

+ PublishEventNewBlockHeader func(header EventDataNewBlockHeader) error

+ PublishEventTx func(EventDataTx) error

+ type BlockGossip struct

+ BlockPartSizeBytes int

+ func DefaultBlockGossip() BlockGossip

+ type BlockSize struct

+ MaxBytes int

+ MaxGas int64

+ MaxTxs int

+ func DefaultBlockSize() BlockSize

type CanonicalJSONProposal

+ Timestamp string

type CanonicalJSONVote

+ Timestamp string

type Commit

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

type ConsensusParams

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

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

+ type DuplicateVoteEvidence struct

+ PubKey crypto.PubKey

+ VoteA *Vote

+ VoteB *Vote

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

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

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

+ func (dve *DuplicateVoteEvidence) Height() int64

+ func (dve *DuplicateVoteEvidence) Index() int

+ func (dve *DuplicateVoteEvidence) String() string

+ func (dve *DuplicateVoteEvidence) Verify(chainID string) error

+ type ErrEvidenceInvalid struct

+ ErrorValue error

+ Evidence Evidence

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

+ func (err *ErrEvidenceInvalid) Error() string

type ErrVoteConflictingVotes

+ func NewConflictingVoteError(val *Validator, voteA, voteB *Vote) *ErrVoteConflictingVotes

+ type Evidence interface

+ Address func() []byte

+ Equal func(Evidence) bool

+ Hash func() []byte

+ Height func() int64

+ Index func() int

+ String func() string

+ Verify func(chainID string) error

+ type EvidenceData struct

+ Evidence EvidenceList

+ func (data *EvidenceData) Hash() data.Bytes

+ 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

+ MaxAge int64

+ func DefaultEvidenceParams() EvidenceParams

+ type EvidencePool interface

+ AddEvidence func(Evidence) error

+ PendingEvidence func() []Evidence

+ Update func(*Block)

type Header

+ ConsensusHash data.Bytes

+ EvidenceHash data.Bytes

+ LastResultsHash data.Bytes

+ TotalTxs int64

+ type MockBadEvidence struct

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

+ func (e MockBadEvidence) String() string

+ func (e MockBadEvidence) Verify(chainID string) error

+ type MockEvidencePool struct

+ func (m MockEvidencePool) AddEvidence(Evidence) error

+ func (m MockEvidencePool) PendingEvidence() []Evidence

+ func (m MockEvidencePool) Update(*Block)

+ type MockGoodEvidence struct

+ Address_ []byte

+ Height_ int64

+ Index_ int

+ func NewMockGoodEvidence(height int64, index int, address []byte) MockGoodEvidence

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

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

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

+ func (e MockGoodEvidence) Height() int64

+ func (e MockGoodEvidence) Index() int

+ func (e MockGoodEvidence) String() string

+ func (e MockGoodEvidence) Verify(chainID string) error

type Proposal

+ Timestamp time.Time

+ type TxSize struct

+ MaxBytes int

+ MaxGas int64

+ func DefaultTxSize() TxSize

type Vote

+ Timestamp time.Time

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

v0.14.0

Dec 12, 2017

Changes in this version

+ func QueryForEvent(eventType string) tmpubsub.Query

+ type EventBusSubscriber interface

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

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

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

v0.13.0

Dec 6, 2017

Changes in this version

+ const EventBond

+ const EventCompleteProposal

+ const EventDupeout

+ const EventFork

+ const EventLock

+ const EventNewBlock

+ const EventNewBlockHeader

+ const EventNewRound

+ const EventNewRoundStep

+ const EventPolka

+ const EventProposalHeartbeat

+ const EventRebond

+ const EventRelock

+ const EventTimeoutPropose

+ const EventTimeoutWait

+ const EventTx

+ const EventTypeKey

+ const EventUnbond

+ const EventUnlock

+ const EventVote

+ const TxHashKey

+ const TxHeightKey

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

+ var EventQueryBond = queryForEvent(EventBond)

+ var EventQueryCompleteProposal = queryForEvent(EventCompleteProposal)

+ var EventQueryDupeout = queryForEvent(EventDupeout)

+ var EventQueryFork = queryForEvent(EventFork)

+ 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 EventQueryProposalHeartbeat = queryForEvent(EventProposalHeartbeat)

+ var EventQueryRebond = queryForEvent(EventRebond)

+ var EventQueryRelock = queryForEvent(EventRelock)

+ var EventQueryTimeoutPropose = queryForEvent(EventTimeoutPropose)

+ var EventQueryTimeoutWait = queryForEvent(EventTimeoutWait)

+ var EventQueryTx = queryForEvent(EventTx)

+ var EventQueryUnbond = queryForEvent(EventUnbond)

+ var EventQueryUnlock = queryForEvent(EventUnlock)

+ var EventQueryVote = queryForEvent(EventVote)

+ func EventQueryTxFor(tx Tx) tmpubsub.Query

+ type EventBus struct

+ func NewEventBus() *EventBus

+ func NewEventBusWithBufferCapacity(cap int) *EventBus

+ func (b *EventBus) OnStart() error

+ func (b *EventBus) OnStop()

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

+ func (b *EventBus) PublishEventCompleteProposal(event EventDataRoundState) error

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

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

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

+ func (b *EventBus) PublishEventNewRound(event EventDataRoundState) error

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

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

+ func (b *EventBus) PublishEventProposalHeartbeat(event EventDataProposalHeartbeat) error

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

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

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

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

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

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

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

+ func (b *EventBus) Subscribe(ctx context.Context, subscriber string, query tmpubsub.Query, ...) 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 NopEventBus struct

+ func (NopEventBus) PublishEventCompleteProposal(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventLock(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventNewBlock(block EventDataNewBlock) error

+ func (NopEventBus) PublishEventNewBlockHeader(header EventDataNewBlockHeader) error

+ func (NopEventBus) PublishEventNewRound(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventNewRoundStep(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventPolka(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventRelock(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventTimeoutPropose(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventTimeoutWait(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventTx(tx EventDataTx) error

+ func (NopEventBus) PublishEventUnlock(rs EventDataRoundState) error

+ func (NopEventBus) PublishEventVote(vote 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 TxEventBuffer struct

+ func NewTxEventBuffer(next TxEventPublisher, capacity int) *TxEventBuffer

+ func (b *TxEventBuffer) Flush() error

+ func (b *TxEventBuffer) PublishEventTx(e EventDataTx) error

+ func (b TxEventBuffer) Len() int

+ type TxEventPublisher interface

+ PublishEventTx func(EventDataTx) error

v0.12.1

Nov 28, 2017

v0.12.0

Oct 28, 2017

Changes in this version

type GenesisDoc

+ AppOptions interface{}

+ type SignedHeader struct

+ Commit *Commit

+ Header *Header

v0.11.1

Oct 10, 2017

v0.11.0

Sep 22, 2017

Changes in this version

+ type BlockGossipParams struct

+ BlockPartSizeBytes int

+ func DefaultBlockGossipParams() BlockGossipParams

+ type BlockSizeParams struct

+ MaxBytes int

+ MaxGas int

+ MaxTxs int

+ func DefaultBlockSizeParams() BlockSizeParams

+ type ConsensusParams struct

+ func DefaultConsensusParams() *ConsensusParams

+ func (params *ConsensusParams) Validate() error

type DefaultSigner

+ PrivKey crypto.PrivKey

type GenesisDoc

+ ConsensusParams *ConsensusParams

+ func (genDoc *GenesisDoc) ValidateAndComplete() error

type GenesisValidator

+ Power int64

type PrivValidator

+ GetPubKey func() crypto.PubKey

+ type PrivValidatorFS struct

+ Address data.Bytes

+ LastHeight int

+ LastRound int

+ LastSignBytes data.Bytes

+ LastSignature crypto.Signature

+ LastStep int8

+ PrivKey crypto.PrivKey

+ PubKey crypto.PubKey

+ func GenPrivValidatorFS(filePath string) *PrivValidatorFS

+ func LoadOrGenPrivValidatorFS(filePath string) *PrivValidatorFS

+ func LoadPrivValidatorFS(filePath string) *PrivValidatorFS

+ func LoadPrivValidatorFSWithSigner(filePath string, signerFunc func(PrivValidator) Signer) *PrivValidatorFS

+ func (privVal *PrivValidatorFS) Reset()

+ func (privVal *PrivValidatorFS) Save()

+ func (privVal *PrivValidatorFS) SignHeartbeat(chainID string, heartbeat *Heartbeat) error

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

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

+ func (privVal *PrivValidatorFS) String() string

+ func (pv *PrivValidatorFS) GetAddress() data.Bytes

+ func (pv *PrivValidatorFS) GetPubKey() crypto.PubKey

+ type TxSizeParams struct

+ MaxBytes int

+ MaxGas int

+ func DefaultTxSizeParams() TxSizeParams

v0.10.5

Nov 1, 2017

v0.10.4

Sep 5, 2017

v0.10.3

Aug 10, 2017

Changes in this version

+ const EventDataTypeProposalHeartbeat

+ var EventDataNameProposalHeartbeat = "proposer_heartbeat"

+ func EventStringProposalHeartbeat() string

+ func FireEventProposalHeartbeat(fireable events.Fireable, rs EventDataProposalHeartbeat)

+ type CanonicalJSONHeartbeat struct

+ Height int

+ Round int

+ Sequence int

+ ValidatorAddress data.Bytes

+ ValidatorIndex int

+ func CanonicalHeartbeat(heartbeat *Heartbeat) CanonicalJSONHeartbeat

+ type CanonicalJSONOnceHeartbeat struct

+ ChainID string

+ Heartbeat CanonicalJSONHeartbeat

+ type EventDataProposalHeartbeat struct

+ Heartbeat *Heartbeat

+ func (_ EventDataProposalHeartbeat) AssertIsTMEventData()

+ type Heartbeat struct

+ Height int

+ Round int

+ Sequence int

+ Signature crypto.Signature

+ ValidatorAddress data.Bytes

+ ValidatorIndex int

+ func (heartbeat *Heartbeat) Copy() *Heartbeat

+ func (heartbeat *Heartbeat) String() string

+ func (heartbeat *Heartbeat) WriteSignBytes(chainID string, w io.Writer, n *int, err *error)

type Mempool

+ EnableTxsAvailable func()

+ TxsAvailable func() <-chan int

type MockMempool

+ func (m MockMempool) EnableTxsAvailable()

+ func (m MockMempool) TxsAvailable() <-chan int

type PrivValidator

+ func (privVal *PrivValidator) SignHeartbeat(chainID string, heartbeat *Heartbeat) error

v0.10.2

Jul 10, 2017

v0.10.1

Jun 28, 2017

Changes in this version

type GenesisDoc

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

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

v0.10.0

Jun 3, 2017

Changes in this version

+ const DefaultBlockPartSize

+ var EventDataNameNewBlock = "new_block"

+ var EventDataNameNewBlockHeader = "new_block_header"

+ var EventDataNameRoundState = "round_state"

+ var EventDataNameTx = "tx"

+ var EventDataNameVote = "vote"

type DefaultSigner

+ func (ds *DefaultSigner) PubKey() crypto.PubKey

type Signer

+ PubKey func() crypto.PubKey

type TMEventData

+ func (tmr *TMEventData) UnmarshalJSON(data []byte) (err error)

+ func (tmr TMEventData) Empty() bool

+ func (tmr TMEventData) MarshalJSON() ([]byte, error)

+ func (tmr TMEventData) Unwrap() TMEventDataInner

+ type TMEventDataInner interface

type Tx

+ func (tx Tx) String() string

v0.10.0-rc2

May 29, 2017

v0.10.0-rc1

May 18, 2017

v0.9.2

Apr 26, 2017

v0.9.1

Apr 21, 2017

Changes in this version

type EventDataTx

+ Height int

+ type TxProof struct

+ Data Tx

+ Index int

+ Proof merkle.SimpleProof

+ RootHash []byte

+ Total int

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

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

+ type TxResult struct

+ Height uint64

+ Index uint32

+ Result abci.ResponseDeliverTx

+ Tx Tx

type Txs

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

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

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

v0.9.0

Mar 6, 2017

Changes in this version

type BlockMeta

+ BlockID BlockID

+ type BlockStore interface

+ SaveBlock func(block *Block, blockParts *PartSet, seenCommit *Commit)

+ type BlockStoreRPC interface

+ Height func() int

+ LoadBlock func(height int) *Block

+ LoadBlockCommit func(height int) *Commit

+ LoadBlockMeta func(height int) *BlockMeta

+ LoadBlockPart func(height int, index int) *Part

+ LoadSeenCommit func(height int) *Commit

+ type Mempool interface

+ CheckTx func(Tx, func(*abci.Response)) error

+ Flush func()

+ Lock func()

+ Reap func(int) Txs

+ Size func() int

+ Unlock func()

+ Update func(height int, txs Txs)

+ type MockMempool struct

+ func (m MockMempool) CheckTx(tx Tx, cb func(*abci.Response)) error

+ func (m MockMempool) Flush()

+ func (m MockMempool) Lock()

+ func (m MockMempool) Reap(n int) Txs

+ func (m MockMempool) Size() int

+ func (m MockMempool) Unlock()

+ func (m MockMempool) Update(height int, txs Txs)

type ValidatorSet

+ func (valSet *ValidatorSet) FromBytes(b []byte)

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

+ func (valSet *ValidatorSet) ToBytes() []byte

+ func (valSet *ValidatorSet) VerifyCommitAny(chainID string, blockID BlockID, height int, commit *Commit) error

v0.8.0

Jan 13, 2017

Changes in this version

+ var ErrVoteInvalidValidatorAddress = errors.New("Invalid round vote validator address")

+ var ErrVoteInvalidValidatorIndex = errors.New("Invalid round vote validator index")

+ var TM2PB = tm2pb

+ func IsVoteTypeValid(type_ byte) bool

+ func MakeBlock(height int, chainID string, txs []Tx, commit *Commit, prevBlockID BlockID, ...) (*Block, *PartSet)

+ type BlockID struct

+ Hash []byte

+ PartsHeader PartSetHeader

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

+ func (blockID BlockID) IsZero() bool

+ func (blockID BlockID) Key() string

+ func (blockID BlockID) String() string

+ func (blockID BlockID) WriteSignBytes(w io.Writer, n *int, err *error)

+ type CanonicalJSONBlockID struct

+ Hash []byte

+ PartsHeader CanonicalJSONPartSetHeader

+ func CanonicalBlockID(blockID BlockID) CanonicalJSONBlockID

+ type CanonicalJSONOnceProposal struct

+ ChainID string

+ Proposal CanonicalJSONProposal

+ type CanonicalJSONOnceVote struct

+ ChainID string

+ Vote CanonicalJSONVote

+ type CanonicalJSONPartSetHeader struct

+ Hash []byte

+ Total int

+ func CanonicalPartSetHeader(psh PartSetHeader) CanonicalJSONPartSetHeader

+ type CanonicalJSONProposal struct

+ BlockPartsHeader CanonicalJSONPartSetHeader

+ Height int

+ POLBlockID CanonicalJSONBlockID

+ POLRound int

+ Round int

+ func CanonicalProposal(proposal *Proposal) CanonicalJSONProposal

+ type CanonicalJSONVote struct

+ BlockID CanonicalJSONBlockID

+ Height int

+ Round int

+ Type byte

+ func CanonicalVote(vote *Vote) CanonicalJSONVote

type Commit

+ BlockID BlockID

+ type ErrVoteConflictingVotes struct

+ VoteA *Vote

+ VoteB *Vote

+ func (err *ErrVoteConflictingVotes) Error() string

type EventDataTx

+ Data []byte

type Header

+ LastBlockID BlockID

type PrivValidator

+ func (privVal *PrivValidator) GetAddress() []byte

type Proposal

+ POLBlockID BlockID

type Validator

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

type Vote

+ BlockID BlockID

+ ValidatorAddress []byte

+ ValidatorIndex int

type VoteSet

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

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

+ func (voteSet *VoteSet) HasAll() bool

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

v0.7.4

Dec 14, 2016

v0.7.3

Oct 21, 2016

Changes in this version

+ func AddListenerForEvent(evsw EventSwitch, id, event string, cb func(data TMEventData))

+ func FireEventCompleteProposal(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventLock(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventNewBlock(fireable events.Fireable, block EventDataNewBlock)

+ func FireEventNewBlockHeader(fireable events.Fireable, header EventDataNewBlockHeader)

+ func FireEventNewRound(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventNewRoundStep(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventPolka(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventRelock(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventTimeoutPropose(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventTimeoutWait(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventTx(fireable events.Fireable, tx EventDataTx)

+ func FireEventUnlock(fireable events.Fireable, rs EventDataRoundState)

+ func FireEventVote(fireable events.Fireable, vote EventDataVote)

+ type EventCache interface

+ Flush func()

+ func NewEventCache(evsw EventSwitch) EventCache

type EventDataTx

+ Code tmsp.CodeType

+ type EventSwitch interface

+ func NewEventSwitch() EventSwitch

+ type Eventable interface

+ SetEventSwitch func(EventSwitch)

+ type Fireable interface

type TMEventData

+ AssertIsTMEventData func()

v0.7.2

Sep 11, 2016

v0.7.1

Sep 11, 2016

Changes in this version

type PrivValidator

+ LastSignBytes []byte

+ LastSignature crypto.Signature

+ func (privVal *PrivValidator) Reset()

v0.7.0

Aug 7, 2016

Changes in this version

+ const EventDataTypeFork

+ const EventDataTypeNewBlock

+ const EventDataTypeNewBlockHeader

+ const EventDataTypeRoundState

+ const EventDataTypeTx

+ const EventDataTypeVote

+ const MaxBlockSize

+ const VoteTypePrecommit

+ const VoteTypePrevote

+ 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 ErrVoteInvalidAccount = errors.New("Invalid round vote account")

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

+ var ErrVoteInvalidSignature = errors.New("Invalid round vote signature")

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

+ var GenDocKey = []byte("GenDocKey")

+ var PeerMempoolChKey = "MempoolReactor.peerMempoolCh"

+ var PeerStateKey = "ConsensusReactor.peerState"

+ var ValidatorCodec = validatorCodec

+ func EventStringBond() string

+ func EventStringCompleteProposal() string

+ func EventStringDupeout() string

+ func EventStringFork() string

+ func EventStringLock() string

+ func EventStringNewBlock() string

+ func EventStringNewBlockHeader() string

+ func EventStringNewRound() string

+ func EventStringNewRoundStep() string

+ func EventStringPolka() string

+ func EventStringRebond() string

+ func EventStringRelock() string

+ func EventStringTimeoutPropose() string

+ func EventStringTimeoutWait() string

+ func EventStringTx(tx Tx) string

+ func EventStringUnbond() string

+ func EventStringUnlock() string

+ func EventStringVote() string

+ func HashSignBytes(chainID string, o Signable) []byte

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

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

+ func SignBytes(chainID string, o Signable) []byte

+ type Block struct

+ LastCommit *Commit

+ func (b *Block) FillHeader()

+ func (b *Block) Hash() []byte

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

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

+ func (b *Block) String() string

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

+ func (b *Block) StringShort() string

+ func (b *Block) ValidateBasic(chainID string, lastBlockHeight int, lastBlockHash []byte, ...) error

+ type BlockMeta struct

+ Hash []byte

+ Header *Header

+ PartsHeader PartSetHeader

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

+ type Commit struct

+ Precommits []*Vote

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

+ func (commit *Commit) FirstPrecommit() *Vote

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

+ func (commit *Commit) Hash() []byte

+ func (commit *Commit) Height() int

+ func (commit *Commit) IsCommit() bool

+ func (commit *Commit) Round() int

+ func (commit *Commit) Size() int

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

+ func (commit *Commit) Type() byte

+ func (commit *Commit) ValidateBasic() error

+ type Data struct

+ Txs Txs

+ func (data *Data) Hash() []byte

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

+ type DefaultSigner struct

+ func NewDefaultSigner(priv crypto.PrivKey) *DefaultSigner

+ func (ds *DefaultSigner) Sign(msg []byte) crypto.Signature

+ type ErrVoteConflictingSignature struct

+ VoteA *Vote

+ VoteB *Vote

+ func (err *ErrVoteConflictingSignature) Error() string

+ type EventDataNewBlock struct

+ Block *Block

+ func (_ EventDataNewBlock) AssertIsTMEventData()

+ type EventDataNewBlockHeader struct

+ Header *Header

+ func (_ EventDataNewBlockHeader) AssertIsTMEventData()

+ type EventDataRoundState struct

+ Height int

+ Round int

+ RoundState interface{}

+ Step string

+ func (_ EventDataRoundState) AssertIsTMEventData()

+ type EventDataTx struct

+ Error string

+ Log string

+ Result []byte

+ Tx Tx

+ func (_ EventDataTx) AssertIsTMEventData()

+ type EventDataVote struct

+ Address []byte

+ Index int

+ Vote *Vote

+ func (_ EventDataVote) AssertIsTMEventData()

+ type GenesisDoc struct

+ AppHash []byte

+ ChainID string

+ GenesisTime time.Time

+ Validators []GenesisValidator

+ func GenesisDocFromJSON(jsonBlob []byte) (genState *GenesisDoc)

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

+ type GenesisValidator struct

+ Amount int64

+ Name string

+ PubKey crypto.PubKey

+ type Header struct

+ AppHash []byte

+ ChainID string

+ DataHash []byte

+ Height int

+ LastBlockHash []byte

+ LastBlockParts PartSetHeader

+ LastCommitHash []byte

+ NumTxs int

+ Time time.Time

+ ValidatorsHash []byte

+ func (h *Header) Hash() []byte

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

+ type Part struct

+ Bytes []byte

+ Index int

+ Proof merkle.SimpleProof

+ func (part *Part) Hash() []byte

+ func (part *Part) String() string

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

+ type PartSet struct

+ func NewPartSetFromData(data []byte) *PartSet

+ func NewPartSetFromHeader(header PartSetHeader) *PartSet

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

+ func (ps *PartSet) BitArray() *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) StringShort() string

+ func (ps *PartSet) Total() int

+ type PartSetHeader struct

+ Hash []byte

+ Total int

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

+ func (psh PartSetHeader) IsZero() bool

+ func (psh PartSetHeader) String() string

+ func (psh PartSetHeader) WriteSignBytes(w io.Writer, n *int, err *error)

+ type PartSetReader struct

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

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

+ type PrivValidator struct

+ Address []byte

+ LastHeight int

+ LastRound int

+ LastStep int8

+ PrivKey crypto.PrivKey

+ PubKey crypto.PubKey

+ func GenPrivValidator() *PrivValidator

+ func LoadOrGenPrivValidator(filePath string) *PrivValidator

+ func LoadPrivValidator(filePath string) *PrivValidator

+ func (privVal *PrivValidator) Save()

+ func (privVal *PrivValidator) SetFile(filePath string)

+ func (privVal *PrivValidator) SetSigner(s Signer)

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

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

+ func (privVal *PrivValidator) String() string

+ 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

+ BlockPartsHeader PartSetHeader

+ Height int

+ POLRound int

+ Round int

+ Signature crypto.SignatureEd25519

+ func NewProposal(height int, round int, blockPartsHeader PartSetHeader, polRound int) *Proposal

+ func (p *Proposal) String() string

+ func (p *Proposal) WriteSignBytes(chainID string, w io.Writer, n *int, err *error)

+ type Signable interface

+ WriteSignBytes func(chainID string, w io.Writer, n *int, err *error)

+ type Signer interface

+ Sign func(msg []byte) crypto.Signature

+ type TMEventData interface

+ type Tx []byte

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

+ type Txs []Tx

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

+ type Validator struct

+ Accum int64

+ Address []byte

+ LastCommitHeight int

+ PubKey crypto.PubKey

+ VotingPower int64

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

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

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

+ func (v *Validator) String() string

+ type ValidatorSet struct

+ Validators []*Validator

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

+ func (valSet *ValidatorSet) Add(val *Validator) (added bool)

+ func (valSet *ValidatorSet) Copy() *ValidatorSet

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

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

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

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

+ func (valSet *ValidatorSet) IncrementAccum(times int)

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

+ func (valSet *ValidatorSet) Proposer() (proposer *Validator)

+ func (valSet *ValidatorSet) Remove(address []byte) (val *Validator, removed bool)

+ func (valSet *ValidatorSet) Size() int

+ func (valSet *ValidatorSet) String() string

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

+ func (valSet *ValidatorSet) TotalVotingPower() int64

+ func (valSet *ValidatorSet) Update(val *Validator) (updated bool)

+ func (valSet *ValidatorSet) VerifyCommit(chainID string, hash []byte, parts PartSetHeader, height int, commit *Commit) error

+ type ValidatorsByAddress []*Validator

+ func (vs ValidatorsByAddress) Len() int

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

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

+ type Vote struct

+ BlockHash []byte

+ BlockPartsHeader PartSetHeader

+ Height int

+ Round int

+ Signature crypto.SignatureEd25519

+ Type byte

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

+ func (vote *Vote) String() string

+ func (vote *Vote) WriteSignBytes(chainID string, w io.Writer, n *int, err *error)

+ type VoteSet struct

+ func NewVoteSet(chainID string, height int, round int, type_ byte, valSet *ValidatorSet) *VoteSet

+ func (voteSet *VoteSet) AddByAddress(address []byte, vote *Vote) (added bool, index int, err error)

+ func (voteSet *VoteSet) AddByIndex(valIndex int, vote *Vote) (added bool, address []byte, err error)

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

+ func (voteSet *VoteSet) ChainID() string

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

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

+ func (voteSet *VoteSet) HasTwoThirdsAny() bool

+ func (voteSet *VoteSet) HasTwoThirdsMajority() bool

+ func (voteSet *VoteSet) Height() int

+ func (voteSet *VoteSet) IsCommit() bool

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

+ func (voteSet *VoteSet) Round() int

+ 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() (hash []byte, parts PartSetHeader, ok bool)

+ func (voteSet *VoteSet) Type() byte

+ type VoteSetReader interface

+ BitArray func() *BitArray

+ GetByIndex func(int) *Vote

+ Height func() int

+ IsCommit func() bool

+ Round func() int

+ Size func() int

+ Type func() byte

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