pool

package
v0.0.0-...-c317427 Latest Latest
Warning

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

Go to latest
Published: Apr 9, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Logger logger.Logger
	Size   int
	Model  model.Model
	BusCh  chan<- *message.Message
}

Config AFAIRE.

type Pool

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

Pool AFAIRE.

func New

func New(cfg *Config) (*Pool, error)

New AFAIRE.

func (Pool) AddRunner

func (p Pool) AddRunner(nsRunner model.JobRunner) error

AddRunner AFAIRE.

func (*Pool) Resize

func (p *Pool) Resize(size int)

Resize AFAIRE.

func (*Pool) Start

func (p *Pool) Start()

Start AFAIRE.

func (*Pool) Stop

func (p *Pool) Stop()

Stop AFAIRE.

Jump to

Keyboard shortcuts

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