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 TxList
  • func NewTxList(acc []byte, st *types.State) *TxList
  • func (tl *TxList) Empty() bool
  • func (tl *TxList) FilterByState(st *types.State) (int, []types.Transaction)
  • func (tl *TxList) Get() []types.Transaction
  • func (tl *TxList) GetAccount() []byte
  • func (tl *TxList) GetAll() []types.Transaction
  • func (tl *TxList) GetLastModifiedTime() time.Time
  • func (tl *TxList) Len() int
  • func (tl *TxList) Put(tx types.Transaction) (int, error)
• 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()

Start runs mempool servivce

func (*MemPool) BeforeStop

func (mp *MemPool) BeforeStop()

Stop 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 TxList

type TxList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

TxList is internal struct for transactions per account

func NewTxList

func NewTxList(acc []byte, st *types.State) *TxList

NewTxList creates new TxList with given State

func (*TxList) Empty

func (tl *TxList) Empty() bool

Empty check TxList is empty including orphan

func (*TxList) FilterByState

func (tl *TxList) FilterByState(st *types.State) (int, []types.Transaction)

SetMinNonce sets new minimum nonce for TxList evict on some transactions is possible due to minimum nonce

func (*TxList) Get

func (tl *TxList) Get() []types.Transaction

Get returns processible transactions

func (*TxList) GetAccount

func (tl *TxList) GetAccount() []byte

func (*TxList) GetAll

func (tl *TxList) GetAll() []types.Transaction

GetAll returns all transactions including orphans

func (*TxList) GetLastModifiedTime

func (tl *TxList) GetLastModifiedTime() time.Time

func (*TxList) Len

func (tl *TxList) Len() int

Len returns number of transactios which are ready to be processed

func (*TxList) Put

func (tl *TxList) Put(tx types.Transaction) (int, error)

Put inserts transaction into TxList if transaction is processible, it is appended to list if not, transaction is managed as orphan

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