queue

Documentation

Index

• type Queue
  • func New(o QueueOpts) *Queue
  • func (q *Queue) Process()
  • func (q *Queue) Push(block uint64)
  • func (q *Queue) Size() int
  • func (q *Queue) Stop()
• type QueueOpts

Types

type Queue

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

func New

func New(o QueueOpts) *Queue

func (*Queue) Process

func (q *Queue) Process()

func (*Queue) Push

func (q *Queue) Push(block uint64)

func (*Queue) Size

func (q *Queue) Size() int

func (*Queue) Stop

func (q *Queue) Stop()

type QueueOpts

type QueueOpts struct {
	QueueSize int
	Logg      *slog.Logger
	Processor *processor.Processor
	Pool      *pond.WorkerPool
}