Documentation
¶
Index ¶
- Constants
- Variables
- type AckRes
- type AckStatus
- type BlockGetter
- type BlockResultsStorer
- type BlockStore
- type BlockStorer
- type CommitInfo
- type ConsensusReset
- type DiscoveryRequest
- type DiscoveryResponse
- type Hash
- type HexBytes
- type MemPool
- type NamedTx
- type NodeStatus
- type QualifiedBlock
- type RawGetter
- type Role
- type Signature
- type TxGetter
- type VoteInfo
Constants ¶
View Source
const HashLen = types.HashLen
Variables ¶
View Source
var ( HashBytes = types.HashBytes ErrTxNotFound = errors.New("tx not available") ErrTxAlreadyExists = errors.New("transaction already exists") ErrBlkNotFound = errors.New("block not available") ErrStillProcessing = errors.New("block still being executed") ErrNoResponse = errors.New("stream closed without response") )
View Source
var ErrNotFound = types.ErrNotFound
Functions ¶
This section is empty.
Types ¶
type AckRes ¶
type AckRes struct {
ACK bool
Height int64
BlkHash Hash
AppHash *Hash
// Signature
PubKeyType crypto.KeyType
PubKey []byte // crypto.PublicKey
Signature []byte
}
func (AckRes) MarshalBinary ¶
func (*AckRes) UnmarshalBinary ¶
type BlockGetter ¶
type BlockResultsStorer ¶
type BlockStore ¶
type BlockStore interface {
BlockGetter
BlockStorer
TxGetter
BlockResultsStorer
Best() (height int64, blkHash, appHash Hash, stamp time.Time)
PreFetch(Hash) (bool, func()) // should be app level instead (TODO: remove)
Close() error
}
type BlockStorer ¶
type BlockStorer interface {
Store(*types.Block, *CommitInfo) error
}
type CommitInfo ¶
type CommitInfo struct {
AppHash Hash
Votes []*VoteInfo
ParamUpdates types.ParamUpdates
}
CommitInfo includes the information about the commit of the block. Such as the signatures of the validators aggreeing to the block.
func (*CommitInfo) MarshalBinary ¶
func (ci *CommitInfo) MarshalBinary() ([]byte, error)
func (*CommitInfo) UnmarshalBinary ¶
func (ci *CommitInfo) UnmarshalBinary(data []byte) error
type ConsensusReset ¶
func (ConsensusReset) Bytes ¶
func (cr ConsensusReset) Bytes() []byte
func (ConsensusReset) MarshalBinary ¶
func (cr ConsensusReset) MarshalBinary() ([]byte, error)
func (ConsensusReset) String ¶
func (cr ConsensusReset) String() string
func (*ConsensusReset) UnmarshalBinary ¶
func (cr *ConsensusReset) UnmarshalBinary(data []byte) error
type DiscoveryRequest ¶
type DiscoveryRequest struct{}
func (DiscoveryRequest) String ¶
func (dr DiscoveryRequest) String() string
type DiscoveryResponse ¶
type DiscoveryResponse struct {
BestHeight int64
}
func (DiscoveryResponse) Bytes ¶
func (dr DiscoveryResponse) Bytes() []byte
func (DiscoveryResponse) MarshalBinary ¶
func (dr DiscoveryResponse) MarshalBinary() ([]byte, error)
func (DiscoveryResponse) String ¶
func (dr DiscoveryResponse) String() string
func (*DiscoveryResponse) UnmarshalBinary ¶
func (dr *DiscoveryResponse) UnmarshalBinary(data []byte) error
type NamedTx ¶
type NamedTx struct {
Hash Hash
Tx *types.Transaction
}
type NodeStatus ¶
type NodeStatus struct {
Role string `json:"role"`
CatchingUp bool `json:"catching_up"`
CommittedHeader *types.BlockHeader `json:"committed_header"`
CommitInfo *CommitInfo `json:"commit_info"`
Params *types.NetworkParameters `json:"params"`
}
type QualifiedBlock ¶
type Signature ¶
type Signature struct {
PubKeyType crypto.KeyType
PubKey []byte // public key of the validator
Data []byte
}
type VoteInfo ¶
type VoteInfo struct {
// VoteSignature is the signature of the blkHash + nack | blkHash + ack + appHash
Signature Signature
// Ack is set to true if the validator agrees with the block
// in terms of the AppHash, ValidatorSet, MerkleRoot of Txs etc.
AckStatus AckStatus
// AppHash is optional, it set only if the AckStatus is AckStatusDivereged.
// AppHash is implied to be the AppHash in the CommitInfo if the AckStatus is AckStatusAgree.
// AppHash is nil if the AckStatus is AckStatusDisagree.
AppHash *Hash
}
func (*VoteInfo) MarshalBinary ¶
func (*VoteInfo) UnmarshalBinary ¶
Click to show internal directories.
Click to hide internal directories.