tx

package

v0.1.0 Latest Latest Go to latest Published: Aug 12, 2019 License: GPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var ErrPoolCapacityExceeded = errors.New("pool capacity exceeded")

This section is empty.

type Pool interface {
	Enqueue(Transaction) error
	Dequeue() (Transaction, bool)
	Remove(tx Transaction) bool
}

func FIFOPool(cap int) Pool

FIFOPool is a First-In, First-Out transaction pool that is thread safe.

type Transaction []byte

func (tx *Transaction) Read(r io.Reader) error

func (tx Transaction) Write(w io.Writer) error

type Transactions []Transaction

func (txs *Transactions) Read(r io.Reader) error

func (txs Transactions) Write(w io.Writer) error