pool

Documentation

Index

• type Pool
  • func New(o PoolOpts) *Pool
  • func (p *Pool) ActiveWorkers() int
  • func (p *Pool) Push(block uint64)
  • func (p *Pool) Size() uint64
  • func (p *Pool) Stop()
• type PoolOpts

Types

type Pool

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

func New

func New(o PoolOpts) *Pool

func (*Pool) ActiveWorkers

func (p *Pool) ActiveWorkers() int

func (*Pool) Push

func (p *Pool) Push(block uint64)

func (*Pool) Size

func (p *Pool) Size() uint64

func (*Pool) Stop

func (p *Pool) Stop()

type PoolOpts

type PoolOpts struct {
	BatchSize   int
	Logg        *slog.Logger
	WorkerCount int
	Processor   *processor.Processor
}