mempool

package
v2.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 20, 2024 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL