GO-2025-3684: Cosmos EVM Allows Partial Precompile State Writes in github.com/cosmos/evm

queue

package

v0.7.0-beta.0 Latest Latest Go to latest Published: Apr 27, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var ErrQueueFull = errors.New("queue full")

This section is empty.

type Queue[Tx any] struct {
	// contains filtered or unexported fields
}

Queue asynchronously inserts batches of txs in FIFO order.

func New[Tx any](insert func(txs []*Tx) []error, maxSize int) *Queue[Tx]

New creates a new queue.

func (iq *Queue[Tx]) Close()

Close stops the main loop of the queue.

func (iq *Queue[Tx]) Push(tx *Tx) <-chan error

Push enqueues a Tx's to eventually be inserted. Returns a channel that will have an error pushed to it if an error occurs inserting the Tx.