jobsupervisor

Documentation

Index

• func NewDummyJobSupervisor() *dummyJobSupervisor
• func NewDummyNatsJobSupervisor(mbusHandler boshhandler.Handler) *dummyNatsJobSupervisor
• func NewMonitJobSupervisor(fs boshsys.FileSystem, runner boshsys.CmdRunner, client boshmonit.Client, ...) (m monitJobSupervisor)
• type JobFailureHandler
• type JobSupervisor
• type MonitReloadOptions
• type Provider
  • func NewProvider(platform boshplatform.Platform, client boshmonit.Client, logger boshlog.Logger, ...) (p Provider)
  • func (p Provider) Get(name string) (supervisor JobSupervisor, err error)

Functions

func NewDummyJobSupervisor

func NewDummyJobSupervisor() *dummyJobSupervisor

func NewDummyNatsJobSupervisor

func NewDummyNatsJobSupervisor(mbusHandler boshhandler.Handler) *dummyNatsJobSupervisor

func NewMonitJobSupervisor

func NewMonitJobSupervisor(
	fs boshsys.FileSystem,
	runner boshsys.CmdRunner,
	client boshmonit.Client,
	logger boshlog.Logger,
	dirProvider boshdir.Provider,
	jobFailuresServerPort int,
	reloadOptions MonitReloadOptions,
) (m monitJobSupervisor)

Types

type JobFailureHandler

type JobFailureHandler func(boshalert.MonitAlert) error

type JobSupervisor

type JobSupervisor interface {
	Reload() error

	// Actions taken on all services
	Start() error
	Stop() error

	// Start and Stop should still function after Unmonitor.
	// Calling Start after Unmonitor should re-monitor all jobs.
	// Calling Stop after Unmonitor should not re-monitor all jobs.
	// (Monit complies to above requirements.)
	Unmonitor() error

	Status() string

	// Job management
	AddJob(jobName string, jobIndex int, configPath string) error
	RemoveAllJobs() error

	MonitorJobFailures(handler JobFailureHandler) error
}

type MonitReloadOptions

type MonitReloadOptions struct {
	// Number of times `monit reload` will be executed
	MaxTries int

	// Number of times monit incarnation will be checked
	// for difference after executing `monit reload`
	MaxCheckTries int

	// Length of time between checking for incarnation difference
	DelayBetweenCheckTries time.Duration
}

type Provider

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

func NewProvider

func NewProvider(
	platform boshplatform.Platform,
	client boshmonit.Client,
	logger boshlog.Logger,
	dirProvider boshdir.Provider,
	handler boshhandler.Handler,
) (p Provider)

func (Provider) Get

func (p Provider) Get(name string) (supervisor JobSupervisor, err error)