worker

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2021 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Run

func Run(runOpts RunOpts)

Types

type ExperimentWorker

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

func NewExperimentWorker

func NewExperimentWorker(id string, solver solver.Service) *ExperimentWorker

func (*ExperimentWorker) Process

func (w *ExperimentWorker) Process(experimentID solver.ExperimentID)

func (*ExperimentWorker) Run

func (w *ExperimentWorker) Run(queue chan solver.ExperimentID, done chan struct{})

type RunOpts

type RunOpts struct {
	Solver           solver.Service
	AmqpChannel      *amqp.Channel
	ExperimentsQueue amqp.Queue
	SolutionsQueue   amqp.Queue
}

type SolutionWorker

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

func NewSolutionWorker

func NewSolutionWorker(id string, solver solver.Service) *SolutionWorker

func (*SolutionWorker) Process

func (w *SolutionWorker) Process(solutionID solver.SolutionID)

func (*SolutionWorker) Run

func (w *SolutionWorker) Run(queue chan solver.SolutionID, done chan struct{})

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL