swarm

Documentation

Index

• Constants
• func NewExecutor(s delegatedStorage, p workerProvider, m workerManager) *executor
• func NewState(keySet []config.Job, setName string) *state
• func NewWorkerPool(cmp assigner, not delegated) *pool
• type Event
• type State

Constants

const DefaultWorkerFrequency = time.Second * 5

Functions

func NewExecutor

func NewExecutor(s delegatedStorage, p workerProvider, m workerManager) *executor

func NewState

func NewState(keySet []config.Job, setName string) *state

NewState holds workload assignations in the workers pool

func NewWorkerPool

func NewWorkerPool(cmp assigner, not delegated) *pool

NewWorkerPool instantiates workers pool

Types

type Event

type Event interface {
	Time() time.Time
	String() string
}

type State

type State string

const (
	NeedsRefresh       State = "needs refresh"
	WaitingAssignation State = "waiting config"
	Syncing            State = "syncing"
)