notification

Documentation

Index

• type MRDataConn
• type NotificationServer
  • func (ns *NotificationServer) GetNewBlockNotificationChannel() chan []byte
  • func (ns *NotificationServer) Start(chain *chain.Chain) (err error)
  • func (ns *NotificationServer) Stop()
• type Peer
  • func (p *Peer) Disconnect(reason p2p.DiscReason)
  • func (p *Peer) IsNotificationEnabled() bool
  • func (p *Peer) NotifyNewBlock(headerHash []byte) error
  • func (p *Peer) ReadMsg() (msg *notification.NotificationMessage, err error)
  • func (p *Peer) Send(msg *notification.NotificationMessage) error

Types

type MRDataConn

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

type NotificationServer

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

func (*NotificationServer) GetNewBlockNotificationChannel

func (ns *NotificationServer) GetNewBlockNotificationChannel() chan []byte

func (*NotificationServer) Start

func (ns *NotificationServer) Start(chain *chain.Chain) (err error)

func (*NotificationServer) Stop

func (ns *NotificationServer) Stop()

type Peer

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

func (*Peer) Disconnect

func (p *Peer) Disconnect(reason p2p.DiscReason)

func (*Peer) IsNotificationEnabled

func (p *Peer) IsNotificationEnabled() bool

func (*Peer) NotifyNewBlock

func (p *Peer) NotifyNewBlock(headerHash []byte) error

func (*Peer) ReadMsg

func (p *Peer) ReadMsg() (msg *notification.NotificationMessage, err error)

func (*Peer) Send

func (p *Peer) Send(msg *notification.NotificationMessage) error