node

Jun 15, 2022

Changes in this version

+ type MemPool struct

+ func NewMemPool(logLevel log.Level) MemPool

+ func (m *MemPool) AddSubscriber(id string) <-chan TxEvent

+ func (m *MemPool) AddTx(tx protocol.MsgTx)

+ func (m *MemPool) CheckTxConfirmed(block block.Block)

+ func (m *MemPool) GetMemPool() map[string]transaction.Transaction

+ func (m *MemPool) Start()

+ func (m *MemPool) Stop()

+ type NodeConfig struct

+ BlockHeadersDB repository.BlockHeaderRepository

+ FiltersDB repository.FilterRepository

+ Network string

+ UserAgent string

+ type NodeService interface

+ AddOutboundPeer func(peer.Peer) error

+ GetChainTip func() (*block.Header, error)

+ SendTransaction func(txhex string) error

+ Start func(initialOutboundPeerAddr string) error

+ Stop func() error

+ func New(config NodeConfig) (NodeService, error)

+ type TxConfirmedEvent struct

+ func (t TxConfirmedEvent) TxID() string

+ func (t TxConfirmedEvent) Type() TxEventType

+ type TxEvent interface

+ TxID func() string

+ Type func() TxEventType

+ type TxEventType int

+ const TxConfirmed

+ const TxUnConfirmed

+ type TxUnConfirmedEvent struct

+ func (t TxUnConfirmedEvent) TxID() string

+ func (t TxUnConfirmedEvent) Type() TxEventType