agent

package
v2.367.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2021 License: Apache-2.0 Imports: 22 Imported by: 24

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	HeartbeatRetryInterval = 1 * time.Second
)

Functions

This section is empty.

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
}

Directories

Path Synopsis
fakes
Code generated by counterfeiter.
Code generated by counterfeiter.
Code generated by counterfeiter.
Code generated by counterfeiter.
bundlecollection/fakes
Code generated by counterfeiter.
Code generated by counterfeiter.
jobs/jobsfakes
Code generated by counterfeiter.
Code generated by counterfeiter.
blobstorefakes
Code generated by counterfeiter.
Code generated by counterfeiter.
blobstore_delegator/blobstore_delegatorfakes
Code generated by counterfeiter.
Code generated by counterfeiter.
httpblobproviderfakes
Code generated by counterfeiter.
Code generated by counterfeiter.
cmd
drain/drainfakes
Code generated by counterfeiter.
Code generated by counterfeiter.
pathenv
Package pathenv returns the OS specific PATH environment variable to use when shelling out to user scripts (e.g pre-start, drain).
Package pathenv returns the OS specific PATH environment variable to use when shelling out to user scripts (e.g pre-start, drain).
scriptfakes
Code generated by counterfeiter.
Code generated by counterfeiter.
tarpathfakes
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL