worker

Documentation

Index

• type Job
• type Pool
  • func New(maxWorker int, respCh chan stats.Result, errCh chan error) *Pool

Types

type Job

type Job struct {
	Cfg  *ast.ActionList
	Seed int64
}

type Pool

type Pool struct {
	QueueCh chan Job
	StopCh  chan bool
	// contains filtered or unexported fields
}

func New

func New(maxWorker int, respCh chan stats.Result, errCh chan error) *Pool

New creates a new Pool. Jobs can be sent to new pool by sending to p.QueueCh Closing p.StopCh will cause the pool to stop executing any queued jobs and currently working workers will no longer send back responses