txpool

Documentation

Index

• type AppendError
  • func (e AppendError) Error() string
• type Config
  • func DefaultConfig() *Config
  • func (conf *Config) BasicCheck() error
• type ConfigError
  • func (e ConfigError) Error() string
• type MockTxPool
  • func MockingTxPool() *MockTxPool
  • func (m *MockTxPool) AppendTx(trx *tx.Tx) error
  • func (m *MockTxPool) AppendTxAndBroadcast(trx *tx.Tx) error
  • func (*MockTxPool) EstimatedFee(_ amount.Amount, _ payload.Type) amount.Amount
  • 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 (*MockTxPool) RemoveTx(_ hash.Hash)
  • func (*MockTxPool) SetNewSandboxAndRecheck(_ sandbox.Sandbox)
  • func (m *MockTxPool) Size() int
  • func (*MockTxPool) String() string
• type Reader
• type TxPool
  • func NewTxPool(conf *Config, broadcastCh chan message.Message) TxPool

Types

type AppendError

type AppendError struct {
	Err error
}

AppendError is returned when the txPool configuration is invalid.

func (AppendError) Error

func (e AppendError) Error() string

type Config

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

func DefaultConfig

func DefaultConfig() *Config

func (*Config) BasicCheck

func (conf *Config) BasicCheck() error

BasicCheck performs basic checks on the configuration.

type ConfigError

type ConfigError struct {
	Reason string
}

ConfigError is returned when the txPool configuration is invalid.

func (ConfigError) Error

func (e ConfigError) Error() string

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) EstimatedFee

func (*MockTxPool) EstimatedFee(_ amount.Amount, _ payload.Type) amount.Amount

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 (*MockTxPool) RemoveTx(_ hash.Hash)

func (*MockTxPool) SetNewSandboxAndRecheck

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

func (*MockTxPool) Size

func (m *MockTxPool) Size() int

func (*MockTxPool) String

func (*MockTxPool) String() string

type Reader

type Reader interface {
	PrepareBlockTransactions() block.Txs
	PendingTx(id tx.ID) *tx.Tx
	HasTx(id tx.ID) bool
	Size() int
	EstimatedFee(amt amount.Amount, payloadType payload.Type) amount.Amount
}

type TxPool

type TxPool interface {
	Reader

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

func NewTxPool

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