pooler

Documentation

Index

• type Operator
  • func NewOperator(f operatorFunc) Operator
• type Pooler
  • func NewPooler(client *client.Client, log logger.Logger, ctx context.Context, ...) *Pooler
  • func (p *Pooler) Run(source string)
  • func (p *Pooler) Scheduler(ticker *time.Ticker)

Types

type Operator

type Operator interface {
	Exec() error
}

Operator interface

func NewOperator

func NewOperator(f operatorFunc) Operator

NewOperator initializes a new operation based on a given work function.

type Pooler

type Pooler struct {
	sync.Mutex
	sync.Once
	// contains filtered or unexported fields
}

Pooler is a worker group that runs a number of operations at concurrency mode depended on operations count.

func NewPooler

func NewPooler(client *client.Client, log logger.Logger, ctx context.Context, cancel context.CancelFunc) *Pooler

NewPooler initializes a new pool with the given operations at the given concurrency.

func (*Pooler) Run

func (p *Pooler) Run(source string)

run all work within the pool and block until it's finished.

func (*Pooler) Scheduler

func (p *Pooler) Scheduler(ticker *time.Ticker)

Scheduler for Pooler worker