Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

service

package

Go to main page

Versions in this module

v0

v0.6.4

Sep 9, 2024

Changes in this version

type ManagerContext

+ DeregisterTargetTypes []string

v0.6.3

Jan 10, 2024

v0.6.2

Nov 15, 2023

Changes in this version

+ const ActiveGoroutinesMetric

+ const AverageDurationSecondsMetric

+ const DeregisteringInstancesCountMetric

+ const DrainingInstancesCountMetric

+ const EventLevelNormal

+ const EventLevelWarning

+ const EventMessageInstanceDeregisterFailed

+ const EventMessageInstanceDeregisterSucceeded

+ const EventMessageLifecycleHookFailed

+ const EventMessageLifecycleHookProcessed

+ const EventMessageLifecycleHookReceived

+ const EventMessageNodeDeleteFailed

+ const EventMessageNodeDeleteSucceeded

+ const EventMessageNodeDrainFailed

+ const EventMessageNodeDrainSucceeded

+ const EventMessageTargetDeregisterFailed

+ const EventMessageTargetDeregisterSucceeded

+ const EventReasonInstanceDeregisterFailed

+ const EventReasonInstanceDeregisterSucceeded

+ const EventReasonLifecycleHookFailed

+ const EventReasonLifecycleHookProcessed

+ const EventReasonLifecycleHookReceived

+ const EventReasonNodeDeleteFailed

+ const EventReasonNodeDeleteSucceeded

+ const EventReasonNodeDrainFailed

+ const EventReasonNodeDrainSucceeded

+ const EventReasonTargetDeregisterFailed

+ const EventReasonTargetDeregisterSucceeded

+ const FailedEventsTotalMetric

+ const FailedLBDeregisterTotalMetric

+ const FailedNodeDeleteTotalMetric

+ const FailedNodeDrainTotalMetric

+ const RejectedEventsTotalMetric

+ const SuccessfulEventsTotalMetric

+ const SuccessfulLBDeregisterTotalMetric

+ const SuccessfulNodeDeleteTotalMetric

+ const SuccessfulNodeDrainTotalMetric

+ const TerminatingInstancesCountMetric

+ var AbandonAction = "ABANDON"

+ var AlphaExcludeLabelKey = "alpha.service-controller.kubernetes.io/exclude-balancer"

+ var AlphaExcludeLabelValue = "true"

+ var ContinueAction = "CONTINUE"

+ var EventLevels = map[EventReason]string

+ var EventName = "lifecycle-manager.%v"

+ var EventNamespace = "default"

+ var ExcludeLabelKey = "node.kubernetes.io/exclude-from-external-load-balancers"

+ var ExcludeLabelValue = "true"

+ var InProgressAnnotationKey = "lifecycle-manager.keikoproj.io/in-progress"

+ var IterationJitterRangeSeconds = 1.5

+ var MetricsEndpoint = "/metrics"

+ var MetricsNamespace = "lifecycle_manager"

+ var MetricsPort = ":8080"

+ var NodeAgeCacheTTL = 90

+ var QueueNameAnnotationKey = "lifecycle-manager.keikoproj.io/queue-name"

+ var TerminationEventName = "autoscaling:EC2_INSTANCE_TERMINATING"

+ var ThreadJitterRangeSeconds = 30.0

+ var WaiterMaxAttempts uint32 = 120

+ var WaiterMaxDelay time.Duration = 90 * time.Second

+ var WaiterMinDelay time.Duration = 10 * time.Second

+ type Authenticator struct

+ ELBClient elbiface.ELBAPI

+ ELBv2Client elbv2iface.ELBV2API

+ KubernetesClient kubernetes.Interface

+ SQSClient sqsiface.SQSAPI

+ ScalingGroupClient autoscalingiface.AutoScalingAPI

+ type DeregistrationError struct

+ Error error

+ Instances []string

+ Target string

+ Type TargetType

+ type Deregistrator struct

+ func (d *Deregistrator) AddClassicDeregistration(val int)

+ func (d *Deregistrator) AddTargetGroupDeregistration(val int)

+ type EventLevel string

+ type EventReason string

+ type LifecycleEvent struct

+ AccountID string

+ AutoScalingGroupName string

+ EC2InstanceID string

+ LifecycleActionToken string

+ LifecycleHookName string

+ LifecycleTransition string

+ RequestID string

+ func (e *LifecycleEvent) SetDeregisterCompleted(val bool)

+ func (e *LifecycleEvent) SetDrainCompleted(val bool)

+ func (e *LifecycleEvent) SetEventCompleted(val bool)

+ func (e *LifecycleEvent) SetEventTimeStarted(t time.Time)

+ func (e *LifecycleEvent) SetHeartbeatInterval(interval int64)

+ func (e *LifecycleEvent) SetMessage(message *sqs.Message)

+ func (e *LifecycleEvent) SetNodeDeleted(val bool)

+ func (e *LifecycleEvent) SetQueueURL(url string)

+ func (e *LifecycleEvent) SetReceiptHandle(receipt string)

+ func (e *LifecycleEvent) SetReferencedNode(node v1.Node)

+ type Manager struct

+ func New(auth Authenticator, ctx ManagerContext) *Manager

+ func (m *Manager) AddTargetByInstance(key interface{}, add *Target)

+ func (m *Manager) DeregisterTargets(targets []*Target, d *Deregistrator)

+ func (m *Manager) GetTargetInstanceIds(key interface{}) []string

+ func (m *Manager) GetTargetMapping(key interface{}) map[string]int64

+ func (m *Manager) LoadTargets(key interface{}) []*Target

+ func (m *Manager) NewTarget(targetId, instanceId string, port int64, targetType TargetType) *Target

+ func (m *Manager) RemoveTargetByInstance(key interface{}, instanceID string)

+ func (m *Manager) SetTargets(key interface{}, targets []*Target)

+ func (mgr *Manager) AddEvent(event *LifecycleEvent)

+ func (mgr *Manager) CompleteEvent(event *LifecycleEvent)

+ func (mgr *Manager) EventInQueue(e *LifecycleEvent) bool

+ func (mgr *Manager) FailEvent(err error, event *LifecycleEvent, abandon bool)

+ func (mgr *Manager) Process(event *LifecycleEvent)

+ func (mgr *Manager) RejectEvent(err error, event *LifecycleEvent)

+ func (mgr *Manager) RemoveFromQueue(event *LifecycleEvent)

+ func (mgr *Manager) Start()

+ type ManagerContext struct

+ CacheConfig *cache.Config

+ DrainRetryAttempts uint

+ DrainRetryIntervalSeconds int64

+ DrainTimeoutSeconds int64

+ DrainTimeoutUnknownSeconds int64

+ KubectlLocalPath string

+ MaxDrainConcurrency *semaphore.Weighted

+ MaxTimeToProcessSeconds int64

+ PollingIntervalSeconds int64

+ QueueName string

+ Region string

+ WithDeregister bool

+ type MetricsServer struct

+ Counters map[string]prometheus.Counter

+ Gauges map[string]prometheus.Gauge

+ func (m *MetricsServer) AddCounter(idx string, value float64)

+ func (m *MetricsServer) DecGauge(idx string)

+ func (m *MetricsServer) IncGauge(idx string)

+ func (m *MetricsServer) SetGauge(idx string, value float64)

+ func (m *MetricsServer) Start()

+ type ScanResult struct

+ ActiveLoadBalancers []string

+ ActiveTargetGroups map[string]int64

+ type Target struct

+ InstanceId string

+ Port int64

+ TargetId string

+ Type TargetType

+ type TargetType string

+ const TargetTypeClassicELB

+ const TargetTypeTargetGroup

+ func (t TargetType) String() string

+ type Waiter struct

+ func (w *Waiter) DecClassicWaiter()

+ func (w *Waiter) DecTargetGroupWaiter()

+ func (w *Waiter) IncClassicWaiter()

+ func (w *Waiter) IncTargetGroupWaiter()

+ type WaiterError struct

+ Error error

+ Type TargetType