pool

Documentation

Index

• type HandlerFunc
• type Job
  • func MakeJobs(n int, process ProcessorFunc, handle HandlerFunc) []Job
  • func NewJob(process ProcessorFunc, handler HandlerFunc) Job
• type Pool
  • func NewPool(jobs []Job, workers int) Pool
  • func (p *Pool) Run(ctx context.Context)
• type ProcessorFunc

Types

type HandlerFunc

type HandlerFunc func(interface{}, error)

type Job

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

func MakeJobs

func MakeJobs(n int, process ProcessorFunc, handle HandlerFunc) []Job

func NewJob

func NewJob(process ProcessorFunc, handler HandlerFunc) Job

type Pool

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

func NewPool

func NewPool(jobs []Job, workers int) Pool

func (*Pool) Run

func (p *Pool) Run(ctx context.Context)

type ProcessorFunc

type ProcessorFunc func() (interface{}, error)