gate

README

gate

Registers a Garden worker on an interval to a given ATC endpoint.

Documentation

Index

• func NewHeartbeater(logger lager.Logger, interval time.Duration, gardenClient garden.Client, ...) ifrit.Runner
• type Drainer
  • func NewDrainer(logger lager.Logger, client garden.Client) *Drainer
  • func (d *Drainer) Drain() error

Functions

func NewHeartbeater

func NewHeartbeater(
	logger lager.Logger,
	interval time.Duration,
	gardenClient garden.Client,
	atcEndpoint *rata.RequestGenerator,
	worker atc.Worker,
) ifrit.Runner

Types

type Drainer

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

func NewDrainer

func NewDrainer(
	logger lager.Logger,
	client garden.Client,
) *Drainer

func (*Drainer) Drain

func (d *Drainer) Drain() error