Versions in this module Expand all Collapse all v6 v6.4.2 Aug 17, 2020 Changes in this version + const DeleteWorker + const ForwardWorker + const HeartbeatStatusGoneAway + const HeartbeatStatusHealthy + const HeartbeatStatusLanded + const HeartbeatStatusUnhealthy + const LandWorker + const ReportContainers + const ReportVolumes + const ResourceActionMissing + const RetireWorker + const SweepContainers + const SweepVolumes + var ErrAllGatewaysUnreachable = errors.New("all worker SSH gateways unreachable") + var ErrConnectionDrainTimeout = errors.New("timeout draining connections") + func KeepAlive(ctx context.Context, sshClient *ssh.Client, tcpConn *net.TCPConn, ...) + type Client struct + HostKeys []ssh.PublicKey + Hosts []string + PrivateKey *rsa.PrivateKey + Worker atc.Worker + func (client *Client) ContainersToDestroy(ctx context.Context) ([]string, error) + func (client *Client) Delete(ctx context.Context) error + func (client *Client) Land(ctx context.Context) error + func (client *Client) Register(ctx context.Context, opts RegisterOptions) error + func (client *Client) ReportContainers(ctx context.Context, handles []string) error + func (client *Client) ReportVolumes(ctx context.Context, handles []string) error + func (client *Client) Retire(ctx context.Context) error + func (client *Client) VolumesToDestroy(ctx context.Context) ([]string, error) + type Deleter struct + ATCEndpoint *rata.RequestGenerator + HTTPClient *http.Client + func (l *Deleter) Delete(ctx context.Context, worker atc.Worker) error + type EndpointPicker interface + Pick func() *rata.RequestGenerator + func NewRandomATCEndpointPicker(atcURLFlags []flag.URL) EndpointPicker + type Event struct + Type EventType + type EventReader struct + func NewEventReader(src io.Reader) EventReader + func (r EventReader) Next() (Event, error) + type EventType string + const EventTypeHeartbeated + const EventTypeRegistered + type EventWriter struct + func NewEventWriter(dest io.Writer) EventWriter + func (w EventWriter) Heartbeated() error + func (w EventWriter) Registered() error + type HandshakeError struct + Err error + func (err *HandshakeError) Error() string + type HeartbeatStatus int + type Heartbeater struct + func NewHeartbeater(clock clock.Clock, interval time.Duration, cprInterval time.Duration, ...) *Heartbeater + func (heartbeater *Heartbeater) Heartbeat(ctx context.Context) error + type Lander struct + ATCEndpoint *rata.RequestGenerator + HTTPClient *http.Client + func (l *Lander) Land(ctx context.Context, worker atc.Worker) error + type RegisterOptions struct + ConnectionDrainTimeout time.Duration + HeartbeatedFunc func() + LocalBaggageclaimAddr string + LocalBaggageclaimNetwork string + LocalGardenAddr string + LocalGardenNetwork string + RegisteredFunc func() + type Retirer struct + ATCEndpoint *rata.RequestGenerator + HTTPClient *http.Client + func (l *Retirer) Retire(ctx context.Context, worker atc.Worker) error + type Sweeper struct + ATCEndpoint *rata.RequestGenerator + HTTPClient *http.Client + func (l *Sweeper) Sweep(ctx context.Context, worker atc.Worker, resourceAction string) ([]byte, error) + type WorkerStatus struct + ATCEndpoint *rata.RequestGenerator + ContainerHandles []string + HTTPClient *http.Client + VolumeHandles []string + func (l *WorkerStatus) WorkerStatus(ctx context.Context, worker atc.Worker, resourceAction string) error