Documentation ¶
Index ¶
Constants ¶
View Source
const ( HeartbeatStatusUnhealthy = iota HeartbeatStatusLanded HeartbeatStatusGoneAway HeartbeatStatusHealthy )
View Source
const ( SweepContainers = "sweep-containers" SweepVolumes = "sweep-volumes" )
View Source
const ( ReportContainers = "report-containers" ReportVolumes = "report-volumes" ResourceActionMissing = "resource-type-missing" )
Variables ¶
This section is empty.
Functions ¶
func NewHeartbeater ¶
func NewHeartbeater( logger lager.Logger, logLevel lager.LogLevel, clock clock.Clock, interval time.Duration, cprInterval time.Duration, gardenClient garden.Client, baggageclaimClient baggageclaim.Client, atcEndpointPicker EndpointPicker, tokenGenerator TokenGenerator, worker atc.Worker, clientWriter io.Writer, ) ifrit.Runner
Types ¶
type Deleter ¶
type Deleter struct { ATCEndpoint *rata.RequestGenerator TokenGenerator TokenGenerator }
type EndpointPicker ¶
type EndpointPicker interface {
Pick() *rata.RequestGenerator
}
func NewRandomATCEndpointPicker ¶
func NewRandomATCEndpointPicker(atcURLFlags []flag.URL) EndpointPicker
type HeartbeatStatus ¶
type HeartbeatStatus int
type Lander ¶
type Lander struct { ATCEndpoint *rata.RequestGenerator TokenGenerator TokenGenerator }
type Retirer ¶
type Retirer struct { ATCEndpoint *rata.RequestGenerator TokenGenerator TokenGenerator }
type Sweeper ¶
type Sweeper struct { ATCEndpoint *rata.RequestGenerator TokenGenerator TokenGenerator }
type TokenGenerator ¶
type TokenGenerator interface { GenerateSystemToken() (string, error) GenerateTeamToken(teamName string) (string, error) }
func NewTokenGenerator ¶
func NewTokenGenerator(signingKey *rsa.PrivateKey) TokenGenerator
type WorkerStatus ¶
type WorkerStatus struct { ATCEndpoint *rata.RequestGenerator TokenGenerator TokenGenerator ContainerHandles []string VolumeHandles []string }
func (*WorkerStatus) WorkerStatus ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.