agent

Documentation

Index

• type ActionDispatcher
  • func NewActionDispatcher(logger boshlog.Logger, taskService boshtask.Service, ...) (dispatcher ActionDispatcher)
• type Agent
  • func New(logger boshlog.Logger, mbusHandler boshhandler.Handler, ...) Agent
  • func (a Agent) Run() error
• type Heartbeat

Types

type ActionDispatcher

type ActionDispatcher interface {
	ResumePreviouslyDispatchedTasks()
	Dispatch(req boshhandler.Request) (resp boshhandler.Response)
}

func NewActionDispatcher

func NewActionDispatcher(
	logger boshlog.Logger,
	taskService boshtask.Service,
	taskManager boshtask.Manager,
	actionFactory boshaction.Factory,
	actionRunner boshaction.Runner,
) (dispatcher ActionDispatcher)

type Agent

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

func New

func New(
	logger boshlog.Logger,
	mbusHandler boshhandler.Handler,
	platform boshplatform.Platform,
	actionDispatcher ActionDispatcher,
	jobSupervisor boshjobsuper.JobSupervisor,
	specService boshas.V1Service,
	syslogServer boshsyslog.Server,
	heartbeatInterval time.Duration,
	settingsService boshsettings.Service,
	uuidGenerator boshuuid.Generator,
	timeService boshtime.Service,
) Agent

func (Agent) Run

func (a Agent) Run() error

type Heartbeat

type Heartbeat struct {
	Job      *string           `json:"job"`
	Index    *int              `json:"index"`
	JobState string            `json:"job_state"`
	Vitals   boshvitals.Vitals `json:"vitals"`
}