worker

Documentation

Index

• type ChannelQueue
  • func NewChannelQueue(buffer int) *ChannelQueue
  • func (q *ChannelQueue) Channel() chan Task
  • func (q *ChannelQueue) Close() error
  • func (q *ChannelQueue) Submit(task Task) error
• type Pool
  • func NewPool(backlog, size int) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) GetWorker(id string) *Worker
  • func (p *Pool) Resize(n int)
  • func (p *Pool) Submit(task Task) (err error)
  • func (p *Pool) Wait()
• type Queue
• type Task
• type Worker
  • func NewWorker(id string) *Worker
  • func (w Worker) Close() error
  • func (w *Worker) Id() string
  • func (w *Worker) Kill(force bool) error
  • func (w *Worker) Run(tasks chan Task, kill chan bool, wg sync.WaitGroup)
  • func (w *Worker) Write(input io.Reader) (int64, error)

Types

type ChannelQueue

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

func NewChannelQueue

func NewChannelQueue(buffer int) *ChannelQueue

func (*ChannelQueue) Channel

func (q *ChannelQueue) Channel() chan Task

func (*ChannelQueue) Close

func (q *ChannelQueue) Close() error

func (*ChannelQueue) Submit

func (q *ChannelQueue) Submit(task Task) error

type Pool

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

Pool ...

func NewPool

func NewPool(backlog, size int) *Pool

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) GetWorker

func (p *Pool) GetWorker(id string) *Worker

func (*Pool) Resize

func (p *Pool) Resize(n int)

func (*Pool) Submit

func (p *Pool) Submit(task Task) (err error)

func (*Pool) Wait

func (p *Pool) Wait()

type Queue

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

type Task

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()
}

Task ...

type Worker

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

func NewWorker

func NewWorker(id string) *Worker

func (Worker) Close

func (w Worker) Close() error

func (*Worker) Id

func (w *Worker) Id() string

func (*Worker) Kill

func (w *Worker) Kill(force bool) error

func (*Worker) Run

func (w *Worker) Run(tasks chan Task, kill chan bool, wg sync.WaitGroup)

func (*Worker) Write

func (w *Worker) Write(input io.Reader) (int64, error)