node

Documentation

Index

• func ProtocolAndAddress(listenAddr string) (string, string)
• func RedirectHandler(next http.Handler) http.Handler
• func SetEventSwitch(evsw types.EventSwitch, eventables ...types.Eventable)
• type Node
  • func NewNode(config *cfg.Config, logger log.Logger) *Node
  • func NewNodeDefault(config *cfg.Config, logger log.Logger) *Node
  • func (n *Node) AddListener(l p2p.Listener)
  • func (n *Node) ConfigureRPC()
  • func (n *Node) DialSeeds(seeds []string) error
  • func (n *Node) EventSwitch() types.EventSwitch
  • func (n *Node) NodeInfo() *p2p.NodeInfo
  • func (n *Node) OnStart() error
  • func (n *Node) OnStop()
  • func (n *Node) RunForever()
  • func (n *Node) Switch() *p2p.Switch
• type NodeGreeting
• type NodeID
• type PrivNodeID
  • func (pnid *PrivNodeID) SignGreeting() *SignedNodeGreeting
• type SignedNodeGreeting

Functions

func ProtocolAndAddress

func ProtocolAndAddress(listenAddr string) (string, string)

Defaults to tcp

func RedirectHandler

func RedirectHandler(next http.Handler) http.Handler

func SetEventSwitch

func SetEventSwitch(evsw types.EventSwitch, eventables ...types.Eventable)

Add the event switch to reactors, mempool, etc.

Types

type Node

type Node struct {
	cmn.BaseService
	// contains filtered or unexported fields
}

func NewNode

func NewNode(config *cfg.Config, logger log.Logger) *Node

func NewNodeDefault

func NewNodeDefault(config *cfg.Config, logger log.Logger) *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) ConfigureRPC

func (n *Node) ConfigureRPC()

ConfigureRPC sets all variables in rpccore so they will serve rpc calls from this node

func (*Node) DialSeeds

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

func (*Node) EventSwitch

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

func (*Node) NodeInfo

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

func (*Node) OnStart

func (n *Node) OnStart() error

func (*Node) OnStop

func (n *Node) OnStop()

func (*Node) RunForever

func (n *Node) RunForever()

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
}