Versions in this module Expand all Collapse all v0 v0.4.0 Mar 25, 2024 v0.3.0 Feb 28, 2024 Changes in this version + var ErrTxBufferFull = errors.New("tx buffer is full") + var ErrTxInBuffer = errors.New("tx already in tx buffer") + var ErrTxIsNil = errors.New("tx is nil") + type Observability interface + Logger func() *slog.Logger + Meter func(name string, opts ...metric.MeterOption) metric.Meter + Tracer func(name string, options ...trace.TracerOption) trace.Tracer + type TxBuffer struct + func New(maxSize uint, hashAlgorithm crypto.Hash, obs Observability) (*TxBuffer, error) + func (buf *TxBuffer) Add(ctx context.Context, tx *types.TransactionOrder) ([]byte, error) + func (buf *TxBuffer) HashAlgorithm() crypto.Hash + func (buf *TxBuffer) Remove(ctx context.Context) (*types.TransactionOrder, error)