pool

Documentation

Index

• type Config
• type JobFunc
• type Pool
  • func NewPool(cfg *Config) *Pool
  • func (p *Pool) RunJobs(ctx context.Context, payloads []interface{}, fn JobFunc) ([]byte, error)
  • func (p *Pool) Shutdown()

Types

type Config

type Config struct {
	MaxWorkers int `yaml:"max_workers"`
	QueueDepth int `yaml:"queue_depth"`
}

type JobFunc

type JobFunc func(ctx context.Context, payload interface{}) ([]byte, error)

type Pool

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

func NewPool

func NewPool(cfg *Config) *Pool

func (*Pool) RunJobs

func (p *Pool) RunJobs(ctx context.Context, payloads []interface{}, fn JobFunc) ([]byte, error)

func (*Pool) Shutdown

func (p *Pool) Shutdown()