mempool

Documentation

Index

• type MemPool
  • func NewMemPoolService(cfg *cfg.Config, cs *chain.ChainService) *MemPool
  • func (mp *MemPool) AfterStart()
  • func (mp *MemPool) BeforeStart()
  • func (mp *MemPool) BeforeStop()
  • func (mp *MemPool) Receive(context actor.Context)
  • func (mp *MemPool) Size() (int, int)
  • func (mp *MemPool) Statistics() *map[string]interface{}
• type TxVerifier
  • func NewTxVerifier(p *MemPool) *TxVerifier
  • func (s *TxVerifier) Receive(context actor.Context)

Types

type MemPool

type MemPool struct {
	*component.BaseComponent

	sync.RWMutex
	// contains filtered or unexported fields
}

MemPool is main structure of mempool service

func NewMemPoolService

func NewMemPoolService(cfg *cfg.Config, cs *chain.ChainService) *MemPool

NewMemPoolService create and return new MemPool

func (*MemPool) AfterStart

func (mp *MemPool) AfterStart()

func (*MemPool) BeforeStart

func (mp *MemPool) BeforeStart()

BeforeStart runs mempool servivce

func (*MemPool) BeforeStop

func (mp *MemPool) BeforeStop()

BeforeStop handles clean-up for mempool service

func (*MemPool) Receive

func (mp *MemPool) Receive(context actor.Context)

Receive handles requested messages from other services

func (*MemPool) Size

func (mp *MemPool) Size() (int, int)

Size returns current maintaining number of transactions and number of orphan transaction

func (*MemPool) Statistics

func (mp *MemPool) Statistics() *map[string]interface{}

type TxVerifier

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

func NewTxVerifier

func NewTxVerifier(p *MemPool) *TxVerifier

func (*TxVerifier) Receive

func (s *TxVerifier) Receive(context actor.Context)

Receive actor message