mempool

Documentation

Overview

Package mempool provides a Pool implementation that keeps all pending transactions in memory.

It is used in tests to avoid needing a database and is not safe for concurrent access.

Index

• type MemPool
  • func New() *MemPool
  • func (m *MemPool) Dump(context.Context) ([]*bc.Tx, error)
  • func (m *MemPool) Insert(ctx context.Context, tx *bc.Tx) error

Types

type MemPool

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

MemPool satisfies the protocol.Pool interface.

func New

func New() *MemPool

New returns a new MemPool.

func (*MemPool) Dump

func (m *MemPool) Dump(context.Context) ([]*bc.Tx, error)

Dump returns all pending transactions in the pool and empties the pool.

func (*MemPool) Insert

func (m *MemPool) Insert(ctx context.Context, tx *bc.Tx) error

Insert adds a new pending tx to the pending tx pool.