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 (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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultConf ¶
Types ¶
type Node ¶
type Node struct {
Angine *gemmill.Angine
AngineTune *gemmill.Tunes
Application gtypes.Application
GenesisDoc *gtypes.GenesisDoc
// contains filtered or unexported fields
}
func (*Node) ExecAdminTx ¶
func (nd *Node) ExecAdminTx(app *vm.AdminDBApp, tx []byte) error
func (*Node) HealthStatus ¶
func (*Node) PrivValidator ¶
func (n *Node) PrivValidator() *gtypes.PrivValidator
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
Source Files
Click to show internal directories.
Click to hide internal directories.