node

Documentation

Index

• func GetProxyApp(addr, transport string, hash []byte) (proxyAppConn proxy.AppConn)
• func RunNode(config cfg.Config)
• func RunReplay(config cfg.Config)
• func RunReplayConsole(config cfg.Config)
• func SetEventSwitch(evsw *events.EventSwitch, eventables ...events.Eventable)
• type Node
  • func NewNode(config cfg.Config, privValidator *types.PrivValidator, ...) *Node
  • func (n *Node) AddListener(l p2p.Listener)
  • func (n *Node) BlockStore() *bc.BlockStore
  • func (n *Node) ConsensusReactor() *consensus.ConsensusReactor
  • func (n *Node) ConsensusState() *consensus.ConsensusState
  • func (n *Node) DialSeeds(seeds []string)
  • func (n *Node) EventSwitch() *events.EventSwitch
  • func (n *Node) MempoolReactor() *mempl.MempoolReactor
  • func (n *Node) NodeInfo() *p2p.NodeInfo
  • func (n *Node) PrivValidator() *types.PrivValidator
  • func (n *Node) Start() error
  • func (n *Node) StartRPC() ([]net.Listener, error)
  • func (n *Node) Stop()
  • func (n *Node) Switch() *p2p.Switch
• type NodeGreeting
• type NodeID
• type PrivNodeID
  • func (pnid *PrivNodeID) SignGreeting() *SignedNodeGreeting
• type SignedNodeGreeting

Functions

func GetProxyApp

func GetProxyApp(addr, transport string, hash []byte) (proxyAppConn proxy.AppConn)

Get a connection to the proxyAppConn addr. Check the current hash, and panic if it doesn't match.

func RunNode

func RunNode(config cfg.Config)

Users wishing to use an external signer for their validators should fork tendermint/tendermint and implement RunNode to load their custom priv validator and call NewNode(privVal, getProxyFunc)

func RunReplay

func RunReplay(config cfg.Config)

func RunReplayConsole

func RunReplayConsole(config cfg.Config)

func SetEventSwitch

func SetEventSwitch(evsw *events.EventSwitch, eventables ...events.Eventable)

Add the event switch to reactors, mempool, etc.

Types

type Node

type Node struct {
	// contains filtered or unexported fields
}

func NewNode

func NewNode(config cfg.Config, privValidator *types.PrivValidator, getProxyApp func(proxyAddr, transport string, appHash []byte) proxy.AppConn) *Node

func (*Node) AddListener

func (n *Node) AddListener(l p2p.Listener)

Add a Listener to accept inbound peer connections. Add listeners before starting the Node. The first listener is the primary listener (in NodeInfo)

func (*Node) BlockStore

func (n *Node) BlockStore() *bc.BlockStore

func (*Node) ConsensusReactor

func (n *Node) ConsensusReactor() *consensus.ConsensusReactor

func (*Node) ConsensusState

func (n *Node) ConsensusState() *consensus.ConsensusState

func (*Node) DialSeeds

func (n *Node) DialSeeds(seeds []string)

func (*Node) EventSwitch

func (n *Node) EventSwitch() *events.EventSwitch

func (*Node) MempoolReactor

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

func (*Node) NodeInfo

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

func (*Node) PrivValidator

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

XXX: for convenience

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()

func (*Node) Switch

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

type NodeGreeting

type NodeGreeting struct {
	NodeID
	Version string
	ChainID string
	Message string
	Time    time.Time
}

type NodeID

type NodeID struct {
	Name   string
	PubKey crypto.PubKey
}

type PrivNodeID

type PrivNodeID struct {
	NodeID
	PrivKey crypto.PrivKey
}

func (*PrivNodeID) SignGreeting

func (pnid *PrivNodeID) SignGreeting() *SignedNodeGreeting

type SignedNodeGreeting

type SignedNodeGreeting struct {
	NodeGreeting
	Signature crypto.Signature
}