agent

Documentation

Index

• Variables
• 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 Bootstrap
  • func NewBootstrap(platform boshplatform.Platform, dirProvider boshdir.Provider, ...) Bootstrap
• type Heartbeat
• type StartManager

Variables

var (
	HeartbeatRetryInterval = 1 * time.Second
)

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,
	heartbeatInterval time.Duration,
	settingsService boshsettings.Service,
	uuidGenerator boshuuid.Generator,
	timeService clock.Clock,
	startManager StartManager,
) Agent

func (Agent) Run

func (a Agent) Run() error

type Bootstrap

type Bootstrap interface {
	Run() error
}

func NewBootstrap

func NewBootstrap(
	platform boshplatform.Platform,
	dirProvider boshdir.Provider,
	settingsService boshsettings.Service,
	specService applyspec.V1Service,
	logger boshlog.Logger,
) Bootstrap

type Heartbeat

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

type StartManager

type StartManager interface {
	CanStart() bool
	RegisterStart() error
}