drainevent

Documentation

Index

• Constants
• func MonitorForScheduledEvents(drainChan chan<- DrainEvent, cancelChan chan<- DrainEvent, ...) error
• func MonitorForSpotITNEvents(drainChan chan<- DrainEvent, cancelChan chan<- DrainEvent, ...) error
• type DrainEvent
  • func (e *DrainEvent) TimeUntilEvent() time.Duration

Constants

const (
	// ScheduledEventKind is a const to define a scheduled event kind of drainable event
	ScheduledEventKind = "SCHEDULED_EVENT"
)

const (
	// SpotITNKind is a const to define a Spot ITN kind of drainable event
	SpotITNKind = "SPOT_ITN"
)

Functions

func MonitorForScheduledEvents

func MonitorForScheduledEvents(drainChan chan<- DrainEvent, cancelChan chan<- DrainEvent, imds *ec2metadata.Service) error

MonitorForScheduledEvents continuously monitors metadata for scheduled events and sends drain events to the passed in channel

func MonitorForSpotITNEvents

func MonitorForSpotITNEvents(drainChan chan<- DrainEvent, cancelChan chan<- DrainEvent, imds *ec2metadata.Service) error

MonitorForSpotITNEvents continuously monitors metadata for spot ITNs and sends drain events to the passed in channel

Types

type DrainEvent

type DrainEvent struct {
	EventID      string
	Kind         string
	Description  string
	State        string
	StartTime    time.Time
	EndTime      time.Time
	Drained      bool
	PreDrainTask preDrainTask `json:"-"`
}

DrainEvent gives more context of the drainable event

func (*DrainEvent) TimeUntilEvent

func (e *DrainEvent) TimeUntilEvent() time.Duration

TimeUntilEvent returns the duration until the event start time