worker

Documentation

Index

• Variables
• type Logger
• type Option
  • func WithCapacity(capacity int) Option
  • func WithSubmitTimeout(timeout time.Duration) Option
• type Pool
  • func New(name string, opts ...Option) *Pool
  • func (p *Pool) Release()
  • func (p *Pool) Submit(t Task) error
• type Task

Variables

var (
	ErrSubmitTimeout  = errors.New("exceeded maximum capacity abd submit timeout")
	ErrWorkerReleased = errors.New("worker has released")
)

Types

type Logger

type Logger interface {
	// Printf must have the same semantics as log.Printf.
	Printf(format string, args ...interface{})
}

Logger is used for logging formatted messages.

type Option

type Option func(*Pool)

func WithCapacity

func WithCapacity(capacity int) Option

func WithSubmitTimeout

func WithSubmitTimeout(timeout time.Duration) Option

type Pool

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

func New

func New(name string, opts ...Option) *Pool

func (*Pool) Release

func (p *Pool) Release()

func (*Pool) Submit

func (p *Pool) Submit(t Task) error

type Task

type Task func()