core

Documentation

Index

• func DefaultConf() *viper.Viper
• func RunNode(config *viper.Viper, runtime, appName string)
• func RunNodeRet(config *viper.Viper, runtime, appName string) error
• type Node
  • func NewNode(conf *viper.Viper, runtime, appName string) (*Node, error)
  • func (nd *Node) ExecAdminTx(app *vm.AdminDBApp, tx []byte) error
  • func (n *Node) HealthStatus() int
  • func (n *Node) IsRunning() bool
  • func (n *Node) NodeInfo() *p2p.NodeInfo
  • func (n *Node) PrivValidator() *gtypes.PrivValidator
  • func (n *Node) Start() error
  • func (n *Node) StartRPC() ([]net.Listener, error)
  • func (n *Node) Stop()
• type RPCNode

Functions

func DefaultConf

func DefaultConf() *viper.Viper

func RunNode

func RunNode(config *viper.Viper, runtime, appName string)

func RunNodeRet

func RunNodeRet(config *viper.Viper, runtime, appName string) error

Types

type Node

type Node struct {
	Angine      *gemmill.Angine
	AngineTune  *gemmill.Tunes
	Application gtypes.Application
	GenesisDoc  *gtypes.GenesisDoc
	// contains filtered or unexported fields
}

func NewNode

func NewNode(conf *viper.Viper, runtime, appName string) (*Node, error)

func (*Node) ExecAdminTx

func (nd *Node) ExecAdminTx(app *vm.AdminDBApp, tx []byte) error

func (*Node) HealthStatus

func (n *Node) HealthStatus() int

func (*Node) IsRunning

func (n *Node) IsRunning() bool

func (*Node) NodeInfo

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

func (*Node) PrivValidator

func (n *Node) PrivValidator() *gtypes.PrivValidator

func (*Node) Start

func (n *Node) Start() error

Call Start() after adding the listeners.

func (*Node) StartRPC

func (n *Node) StartRPC() ([]net.Listener, error)

func (*Node) Stop

func (n *Node) Stop()

type RPCNode

type RPCNode interface {
	// GetShard(string) (*ShardNode, error)
	Height() int
	GetBlock(height int) (*gtypes.Block, *gtypes.BlockMeta, error)
	BroadcastTx(tx []byte) error
	BroadcastTxCommit(tx []byte) error
	FlushMempool()
	GetValidators() (int, []*gtypes.Validator)
	GetP2PNetInfo() (bool, []string, []*gtypes.Peer)
	GetNumPeers() int
	GetConsensusStateInfo() (string, []string)
	GetNumUnconfirmedTxs() int
	GetUnconfirmedTxs() []gtypes.Tx
	IsNodeValidator(pub crypto.PubKey) bool
	GetBlacklist() []string
}

RPCNode define the node's abilities provided for rpc calls