Documentation ¶
Index ¶
- Constants
- Variables
- type Beacon
- func (beacon *Beacon) DeleteWorker(signals <-chan os.Signal, ready chan<- struct{}) error
- func (beacon *Beacon) DisableKeepAlive()
- func (beacon *Beacon) LandWorker(signals <-chan os.Signal, ready chan<- struct{}) error
- func (beacon *Beacon) Register(signals <-chan os.Signal, ready chan<- struct{}) error
- func (beacon *Beacon) ReportContainers(gardenClient garden.Client) error
- func (beacon *Beacon) ReportVolumes() error
- func (beacon *Beacon) RetireWorker(signals <-chan os.Signal, ready chan<- struct{}) error
- func (beacon *Beacon) SweepContainers(gardenClient garden.Client) error
- func (beacon *Beacon) SweepVolumes() error
- type BeaconClient
- type Client
- type Closeable
- type Config
- type FileFlag
- type IPFlag
- type RegistrationMode
- type Session
Constants ¶
View Source
const (
ReaperPort = "7799"
)
Variables ¶
View Source
var ErrFailedToReachAnyTSA = errors.New("failed to connect to TSA")
Functions ¶
This section is empty.
Types ¶
type Beacon ¶
type Beacon struct { Logger lager.Logger Worker atc.Worker Client Client RegistrationMode RegistrationMode KeepAlive bool GardenAddr string GardenClient garden.Client BaggageclaimAddr string }
func (*Beacon) DeleteWorker ¶
func (*Beacon) DisableKeepAlive ¶
func (beacon *Beacon) DisableKeepAlive()
func (*Beacon) LandWorker ¶
func (*Beacon) ReportContainers ¶
func (*Beacon) ReportVolumes ¶
func (*Beacon) RetireWorker ¶
RetireWorker sends a message via the TSA to retire the worker
func (*Beacon) SweepContainers ¶
func (*Beacon) SweepVolumes ¶
type BeaconClient ¶
type BeaconClient interface { Register(signals <-chan os.Signal, ready chan<- struct{}) error RetireWorker(signals <-chan os.Signal, ready chan<- struct{}) error SweepContainers(garden.Client) error ReportContainers(garden.Client) error SweepVolumes() error ReportVolumes() error LandWorker(signals <-chan os.Signal, ready chan<- struct{}) error DeleteWorker(signals <-chan os.Signal, ready chan<- struct{}) error DisableKeepAlive() }
type Client ¶
type Config ¶
type Config struct { TSAConfig tsa.Config `group:"TSA Configuration" namespace:"tsa"` GardenForwardAddr string `long:"garden-forward-addr" description:"Garden address to forward through SSH to the TSA."` BaggageclaimForwardAddr string `long:"baggageclaim-forward-addr" description:"Baggageclaim address to forward through SSH to the TSA."` RegistrationMode RegistrationMode `long:"registration-mode" default:"forward" choice:"forward" choice:"direct"` }
type IPFlag ¶
func (*IPFlag) UnmarshalFlag ¶
type RegistrationMode ¶
type RegistrationMode string
const ( Direct RegistrationMode = "direct" Forward RegistrationMode = "forward" )
Source Files ¶
Click to show internal directories.
Click to hide internal directories.