node

Jun 30, 2021

Changes in this version

+ func DefaultDBProvider(ctx *DBContext) (dbm.DB, error)

+ func LoadStateFromDBOrGenesisDocProvider(stateDB dbm.DB, genesisDocProvider GenesisDocProvider) (sm.State, *types.GenesisDoc, error)

+ func ParseMisbehaviors(str string) (map[int64]cs.Misbehavior, error)

+ type DBContext struct

+ Config *cfg.Config

+ ID string

+ type DBProvider func(*DBContext) (dbm.DB, error)

+ type FilePV struct

+ Key FilePVKey

+ LastSignState FilePVLastSignState

+ func GenFilePV(keyFilePath, stateFilePath string) *FilePV

+ func LoadFilePV(keyFilePath, stateFilePath string) *FilePV

+ func LoadFilePVEmptyState(keyFilePath, stateFilePath string) *FilePV

+ func LoadOrGenFilePV(keyFilePath, stateFilePath string) *FilePV

+ func (pv *FilePV) GetAddress() types.Address

+ func (pv *FilePV) GetPubKey() (crypto.PubKey, error)

+ func (pv *FilePV) Reset()

+ func (pv *FilePV) Save()

+ func (pv *FilePV) SignProposal(chainID string, proposal *tmproto.Proposal) error

+ func (pv *FilePV) SignVote(chainID string, vote *tmproto.Vote) error

+ func (pv *FilePV) String() string

+ type FilePVKey struct

+ Address types.Address

+ PrivKey crypto.PrivKey

+ PubKey crypto.PubKey

+ func (pvKey FilePVKey) Save()

+ type FilePVLastSignState struct

+ Height int64

+ Round int32

+ SignBytes tmbytes.HexBytes

+ Signature []byte

+ Step int8

+ func (lss *FilePVLastSignState) CheckHRS(height int64, round int32, step int8) (bool, error)

+ func (lss *FilePVLastSignState) Save()

+ type GenesisDocProvider func() (*types.GenesisDoc, error)

+ func DefaultGenesisDocProviderFunc(config *cfg.Config) GenesisDocProvider

+ type MetricsProvider func(chainID string) (*consensus.Metrics, *p2p.Metrics, *mempl.Metrics, *sm.Metrics)

+ func DefaultMetricsProvider(config *cfg.InstrumentationConfig) MetricsProvider

+ type Node struct

+ func DefaultNewNode(config *cfg.Config, logger log.Logger, misbehaviors map[int64]cs.Misbehavior) (*Node, error)

+ func NewNode(config *cfg.Config, privValidator types.PrivValidator, nodeKey *p2p.NodeKey, ...) (*Node, error)

+ func (n *Node) BlockStore() *store.BlockStore

+ func (n *Node) Config() *cfg.Config

+ func (n *Node) ConfigureRPC() error

+ func (n *Node) ConsensusReactor() *cs.Reactor

+ func (n *Node) ConsensusState() *cs.State

+ func (n *Node) EventBus() *types.EventBus

+ func (n *Node) EvidencePool() *evidence.Pool

+ func (n *Node) GenesisDoc() *types.GenesisDoc

+ func (n *Node) IsListening() bool

+ func (n *Node) Listeners() []string

+ func (n *Node) Mempool() mempl.Mempool

+ func (n *Node) MempoolReactor() *mempl.Reactor

+ func (n *Node) NodeInfo() p2p.NodeInfo

+ func (n *Node) OnStart() error

+ func (n *Node) OnStop()

+ func (n *Node) PEXReactor() *pex.Reactor

+ func (n *Node) PrivValidator() types.PrivValidator

+ func (n *Node) ProxyApp() proxy.AppConns

+ func (n *Node) Switch() *p2p.Switch

+ type Option func(*Node)

+ func CustomReactors(reactors map[string]p2p.Reactor) Option

+ func CustomReactorsAsConstructors(reactors map[string]func(n *Node) p2p.Reactor) Option

+ func StateProvider(stateProvider statesync.StateProvider) Option

+ type Provider func(*cfg.Config, log.Logger) (*Node, error)