node

Documentation

Index

• type MemPool
  • func NewMemPool() 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
• type NodeService
  • func New(config NodeConfig) (NodeService, error)
• type TxConfirmedEvent
  • func (t TxConfirmedEvent) TxID() string
  • func (t TxConfirmedEvent) Type() TxEventType
• type TxEvent
• type TxEventType
• type TxUnConfirmedEvent
  • func (t TxUnConfirmedEvent) TxID() string
  • func (t TxUnConfirmedEvent) Type() TxEventType

Types

type MemPool

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

func NewMemPool

func NewMemPool() MemPool

func (*MemPool) AddSubscriber

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

func (*MemPool) AddTx

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

func (*MemPool) CheckTxConfirmed

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

func (*MemPool) GetMemPool

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

func (*MemPool) Start

func (m *MemPool) Start()

func (*MemPool) Stop

func (m *MemPool) Stop()

type NodeConfig

type NodeConfig struct {
	Network        string
	UserAgent      string
	FiltersDB      repository.FilterRepository
	BlockHeadersDB repository.BlockHeaderRepository
}

type NodeService

type NodeService interface {
	Start(initialOutboundPeerAddr string) error
	Stop() error
	AddOutboundPeer(peer.Peer) error
	SendTransaction(txhex string) error
	GetChainTip() (*block.Header, error)
}

func New

func New(config NodeConfig) (NodeService, error)

New returns a new Node.

type TxConfirmedEvent

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

func (TxConfirmedEvent) TxID

func (t TxConfirmedEvent) TxID() string

func (TxConfirmedEvent) Type

func (t TxConfirmedEvent) Type() TxEventType

type TxEvent

type TxEvent interface {
	Type() TxEventType
	TxID() string
}

type TxEventType

type TxEventType int

const (
	TxConfirmed TxEventType = iota
	TxUnConfirmed
)

type TxUnConfirmedEvent

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

func (TxUnConfirmedEvent) TxID

func (t TxUnConfirmedEvent) TxID() string

func (TxUnConfirmedEvent) Type

func (t TxUnConfirmedEvent) Type() TxEventType