nomadmeta

Documentation

Index

• type Processor
  • func NewJobScalingPolicies(logger zerolog.Logger, nomad *api.Client) (backend.PolicyBackend, *Processor)
  • func (pr *Processor) GetUpdateChannel() chan interface{}
  • func (pr *Processor) Run()

Types

type Processor

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

func NewJobScalingPolicies

func NewJobScalingPolicies(logger zerolog.Logger, nomad *api.Client) (backend.PolicyBackend, *Processor)

NewJobScalingPolicies produces a new policy backend and processor. The policy backend is just the memory backend. The processor is used to handle job watcher updates, where the job is inspected for its status, and then any Sherpa meta parameters pulled out and validated.

func (*Processor) GetUpdateChannel

func (pr *Processor) GetUpdateChannel() chan interface{}

func (*Processor) Run

func (pr *Processor) Run()