notifymgr

Documentation

Index

• type NotifyMgr
  • func (ntmgr *NotifyMgr) AddRebroadcastInventory(newTxs []*types.TxDesc)
  • func (ntmgr *NotifyMgr) AnnounceNewTransactions(newTxs []*types.TxDesc, filters []peer.ID)
  • func (ntmgr *NotifyMgr) BroadcastMessage(data interface{})
  • func (ntmgr *NotifyMgr) RelayInventory(data interface{}, filters []peer.ID)
  • func (ntmgr *NotifyMgr) TransactionConfirmed(tx *types.Tx)

Types

type NotifyMgr

type NotifyMgr struct {
	Server    *p2p.Service
	RpcServer *rpc.RpcServer
}

NotifyMgr manage message announce & relay & notification between mempool, websocket, gbt long pull and rpc server.

func (*NotifyMgr) AddRebroadcastInventory

func (ntmgr *NotifyMgr) AddRebroadcastInventory(newTxs []*types.TxDesc)

func (*NotifyMgr) AnnounceNewTransactions

func (ntmgr *NotifyMgr) AnnounceNewTransactions(newTxs []*types.TxDesc, filters []peer.ID)

AnnounceNewTransactions generates and relays inventory vectors and notifies both websocket and getblocktemplate long poll clients of the passed transactions. This function should be called whenever new transactions are added to the mempool.

func (*NotifyMgr) BroadcastMessage

func (ntmgr *NotifyMgr) BroadcastMessage(data interface{})

func (*NotifyMgr) RelayInventory

func (ntmgr *NotifyMgr) RelayInventory(data interface{}, filters []peer.ID)

RelayInventory relays the passed inventory vector to all connected peers that are not already known to have it.

func (*NotifyMgr) TransactionConfirmed

func (ntmgr *NotifyMgr) TransactionConfirmed(tx *types.Tx)

Transaction has one confirmation on the main chain. Now we can mark it as no longer needing rebroadcasting.