protocol

Documentation

Index

• type Manager
  • func NewManager(cfg *config.Config, domain domain.Domain, netAdapter *netadapter.NetAdapter, ...) (*Manager, error)
  • func (m *Manager) AddBlock(block *externalapi.DomainBlock) error
  • func (m *Manager) AddTransaction(tx *externalapi.DomainTransaction) error
  • func (m *Manager) Close()
  • func (m *Manager) IBDPeer() *peerpkg.Peer
  • func (m *Manager) IsIBDRunning() bool
  • func (m *Manager) Peers() []*peerpkg.Peer
  • func (m *Manager) SetOnBlockAddedToDAGHandler(onBlockAddedToDAGHandler flowcontext.OnBlockAddedToDAGHandler)
  • func (m *Manager) SetOnPruningPointUTXOSetOverrideHandler(...)
  • func (m *Manager) SetOnTransactionAddedToMempoolHandler(...)
  • func (m *Manager) ShouldMine() (bool, error)

Types

type Manager

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

Manager manages the p2p protocol

func NewManager

func NewManager(cfg *config.Config, domain domain.Domain, netAdapter *netadapter.NetAdapter, addressManager *addressmanager.AddressManager,
	connectionManager *connmanager.ConnectionManager) (*Manager, error)

NewManager creates a new instance of the p2p protocol manager

func (*Manager) AddBlock

func (m *Manager) AddBlock(block *externalapi.DomainBlock) error

AddBlock adds the given block to the DAG and propagates it.

func (*Manager) AddTransaction

func (m *Manager) AddTransaction(tx *externalapi.DomainTransaction) error

AddTransaction adds transaction to the mempool and propagates it.

func (*Manager) Close

func (m *Manager) Close()

Close closes the protocol manager and waits until all p2p flows finish.

func (*Manager) IBDPeer

func (m *Manager) IBDPeer() *peerpkg.Peer

IBDPeer returns the current IBD peer or null if the node is not in IBD

func (*Manager) IsIBDRunning

func (m *Manager) IsIBDRunning() bool

IsIBDRunning returns true if IBD is currently marked as running

func (*Manager) Peers

func (m *Manager) Peers() []*peerpkg.Peer

Peers returns the currently active peers

func (*Manager) SetOnBlockAddedToDAGHandler

func (m *Manager) SetOnBlockAddedToDAGHandler(onBlockAddedToDAGHandler flowcontext.OnBlockAddedToDAGHandler)

SetOnBlockAddedToDAGHandler sets the onBlockAddedToDAG handler

func (*Manager) SetOnPruningPointUTXOSetOverrideHandler

func (m *Manager) SetOnPruningPointUTXOSetOverrideHandler(onPruningPointUTXOSetOverrideHandler flowcontext.OnPruningPointUTXOSetOverrideHandler)

SetOnPruningPointUTXOSetOverrideHandler sets the OnPruningPointUTXOSetOverride handler

func (*Manager) SetOnTransactionAddedToMempoolHandler

func (m *Manager) SetOnTransactionAddedToMempoolHandler(onTransactionAddedToMempoolHandler flowcontext.OnTransactionAddedToMempoolHandler)

SetOnTransactionAddedToMempoolHandler sets the onTransactionAddedToMempool handler

func (*Manager) ShouldMine

func (m *Manager) ShouldMine() (bool, error)

ShouldMine returns whether it's ok to use block template from this node for mining purposes.