worker

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

type Pool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Queue interface {
	Submit(task Task) error
	Channel() chan Task
	Close() error
}

type Task interface {
	Enqueue() error
	Start(worker string) error
	Stop() error
	Kill(force bool) error
	Killed() bool
	Close() error
	Write(input io.Reader) (int64, error)
	Execute() error
	Error(err error) error
	Wait()
}

type Worker struct {
	sync.RWMutex
	// contains filtered or unexported fields
}