Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dispatcher

package

Go to main page

Versions in this module

v0

v0.6.2

Mar 19, 2024

v0.6.1

Sep 14, 2023

Changes in this version

type Dispatcher

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

type DispatcherBuilder

+ func NewBuilder() *DispatcherBuilder

+ type Memory struct

+ 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 int, 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

type Worker

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

v0.5.1

Jun 6, 2023

Changes in this version

+ type Dispatcher struct

+ func (d *Dispatcher) AddTask(task models.Task)

+ func (d *Dispatcher) GetStatus(ID int) int

+ func (d *Dispatcher) Wait()

+ type DispatcherBuilder struct

+ func NewDispatcherBuilder(ctx context.Context) *DispatcherBuilder

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

+ func (db *DispatcherBuilder) WithConsole() *DispatcherBuilder

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

+ func (db *DispatcherBuilder) WithMemorySize(size int) *DispatcherBuilder

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

+ type Observer struct

+ func (o *Observer) Log(result models.TaskResult)

+ func (o *Observer) Start()

+ func (o *Observer) WithConsole()

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

+ type SharedMemory struct

+ func (s *SharedMemory) AddTask(task models.Task)

+ func (s *SharedMemory) EndWorker()

+ func (s *SharedMemory) ForwardTask(task models.Task)

+ func (s *SharedMemory) GetStatus(ID int) int

+ func (s *SharedMemory) SetStatus(ID int, status int)

+ func (s *SharedMemory) StartWorker()

+ type Worker struct

+ ID int

+ func (w *Worker) Start()