txpool

Documentation

Index

• type Config
  • func DefaultConfig() *Config
  • func (conf *Config) BasicCheck() error
• type MockTxPool
  • func MockingTxPool() *MockTxPool
  • func (m *MockTxPool) AppendTx(trx *tx.Tx) error
  • func (m *MockTxPool) AppendTxAndBroadcast(trx *tx.Tx) error
  • func (m *MockTxPool) HasTx(id tx.ID) bool
  • func (m *MockTxPool) PendingTx(id tx.ID) *tx.Tx
  • func (m *MockTxPool) PrepareBlockTransactions() block.Txs
  • func (m *MockTxPool) QueryTx(id tx.ID) *tx.Tx
  • func (m *MockTxPool) RemoveTx(_ hash.Hash)
  • func (m *MockTxPool) SetNewSandboxAndRecheck(_ sandbox.Sandbox)
  • func (m *MockTxPool) Size() int
  • func (m *MockTxPool) String() string
• type Reader
• type TxPool
  • func NewTxPool(conf *Config, broadcastCh chan message.Message) TxPool

Types

type Config

type Config struct {
	MaxSize int `toml:"max_size"`
}

func DefaultConfig

func DefaultConfig() *Config

func (*Config) BasicCheck

func (conf *Config) BasicCheck() error

BasicCheck performs basic checks on the configuration.

type MockTxPool

type MockTxPool struct {
	Txs []*tx.Tx
}

MockTxPool is a testing mock.

func MockingTxPool

func MockingTxPool() *MockTxPool

func (*MockTxPool) AppendTx

func (m *MockTxPool) AppendTx(trx *tx.Tx) error

func (*MockTxPool) AppendTxAndBroadcast

func (m *MockTxPool) AppendTxAndBroadcast(trx *tx.Tx) error

func (*MockTxPool) HasTx

func (m *MockTxPool) HasTx(id tx.ID) bool

func (*MockTxPool) PendingTx

func (m *MockTxPool) PendingTx(id tx.ID) *tx.Tx

func (*MockTxPool) PrepareBlockTransactions

func (m *MockTxPool) PrepareBlockTransactions() block.Txs

func (*MockTxPool) QueryTx

func (m *MockTxPool) QueryTx(id tx.ID) *tx.Tx

func (*MockTxPool) RemoveTx

func (m *MockTxPool) RemoveTx(_ hash.Hash)

func (*MockTxPool) SetNewSandboxAndRecheck

func (m *MockTxPool) SetNewSandboxAndRecheck(_ sandbox.Sandbox)

func (*MockTxPool) Size

func (m *MockTxPool) Size() int

func (*MockTxPool) String

func (m *MockTxPool) String() string

type Reader

type Reader interface {
	PrepareBlockTransactions() block.Txs
	PendingTx(id tx.ID) *tx.Tx
	HasTx(id tx.ID) bool
	Size() int
}

type TxPool

type TxPool interface {
	Reader

	SetNewSandboxAndRecheck(sb sandbox.Sandbox)
	AppendTxAndBroadcast(trx *tx.Tx) error
	AppendTx(tx *tx.Tx) error
	RemoveTx(id tx.ID)
}

func NewTxPool

func NewTxPool(conf *Config, broadcastCh chan message.Message) TxPool