dispatcher

Documentation

Index

• type Dispatcher
  • func (d *Dispatcher) AddTask(task tasks.Task)
  • func (d *Dispatcher) Status(taskId int) int
  • func (d *Dispatcher) Wait()
• type DispatcherBuilder
  • func NewBuilder() *DispatcherBuilder
  • func (db *DispatcherBuilder) Build() (Dispatcher, error)
  • func (db *DispatcherBuilder) WithConsole() *DispatcherBuilder
  • func (db *DispatcherBuilder) WithLogfile(filename string) *DispatcherBuilder
  • func (db *DispatcherBuilder) WithWorkerNumber(count int) *DispatcherBuilder
• type Memory
  • func NewMemory() *Memory
  • func (m *Memory) AddTask(task tasks.Task)
  • func (m *Memory) EndWorker()
  • func (m *Memory) ForwardTask(task tasks.Task)
  • func (m *Memory) SetStatus(taskId, taskSubId, status int)
  • func (m *Memory) StartWorker()
  • func (m *Memory) Status(taskId int) int
  • func (m *Memory) WaitForTasks()
  • func (m *Memory) WaitForWorkers()
• type Observer
  • func NewObserver(memory *Memory, ctx context.Context) *Observer
  • func (o *Observer) Log(result tasks.Result)
  • func (o *Observer) Start()
  • func (o *Observer) WithConsole()
  • func (o *Observer) WithTrace(filename string) error
• type Worker
  • func NewWorker(memory *Memory, ctx context.Context) *Worker
  • func (w *Worker) Start()

Types

type Dispatcher

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

func (*Dispatcher) AddTask

func (d *Dispatcher) AddTask(task tasks.Task)

func (*Dispatcher) Status

func (d *Dispatcher) Status(taskId int) int

func (*Dispatcher) Wait

func (d *Dispatcher) Wait()

type DispatcherBuilder

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

func NewBuilder

func NewBuilder() *DispatcherBuilder

func (*DispatcherBuilder) Build

func (db *DispatcherBuilder) Build() (Dispatcher, error)

func (*DispatcherBuilder) WithConsole

func (db *DispatcherBuilder) WithConsole() *DispatcherBuilder

func (*DispatcherBuilder) WithLogfile

func (db *DispatcherBuilder) WithLogfile(filename string) *DispatcherBuilder

func (*DispatcherBuilder) WithWorkerNumber

func (db *DispatcherBuilder) WithWorkerNumber(count int) *DispatcherBuilder

type Memory

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

func NewMemory

func NewMemory() *Memory

func (*Memory) AddTask

func (m *Memory) AddTask(task tasks.Task)

func (*Memory) EndWorker

func (m *Memory) EndWorker()

func (*Memory) ForwardTask

func (m *Memory) ForwardTask(task tasks.Task)

func (*Memory) SetStatus

func (m *Memory) SetStatus(taskId, taskSubId, status int)

func (*Memory) StartWorker

func (m *Memory) StartWorker()

func (*Memory) Status

func (m *Memory) Status(taskId int) int

func (*Memory) WaitForTasks

func (m *Memory) WaitForTasks()

func (*Memory) WaitForWorkers

func (m *Memory) WaitForWorkers()

type Observer

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

func NewObserver

func NewObserver(memory *Memory, ctx context.Context) *Observer

func (*Observer) Log

func (o *Observer) Log(result tasks.Result)

func (*Observer) Start

func (o *Observer) Start()

func (*Observer) WithConsole

func (o *Observer) WithConsole()

func (*Observer) WithTrace

func (o *Observer) WithTrace(filename string) error

type Worker

type Worker struct {
	ID int
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(memory *Memory, ctx context.Context) *Worker

func (*Worker) Start

func (w *Worker) Start()