rebalancerecommendation

Documentation

Index

• Constants
• type RebalanceRecommendationMonitor
  • func NewRebalanceRecommendationMonitor(imds *ec2metadata.Service, interruptionChan chan<- monitor.InterruptionEvent, ...) RebalanceRecommendationMonitor
  • func (m RebalanceRecommendationMonitor) Kind() string
  • func (m RebalanceRecommendationMonitor) Monitor() error

Constants

const (
	// RebalanceRecommendationKind is a const to define a Rebalance Recommendation kind of event
	RebalanceRecommendationKind = "REBALANCE_RECOMMENDATION"
)

Types

type RebalanceRecommendationMonitor

type RebalanceRecommendationMonitor struct {
	IMDS             *ec2metadata.Service
	InterruptionChan chan<- monitor.InterruptionEvent
	NodeName         string
}

RebalanceRecommendationMonitor is a struct definition which facilitates monitoring of rebalance recommendations from IMDS

func NewRebalanceRecommendationMonitor

func NewRebalanceRecommendationMonitor(imds *ec2metadata.Service, interruptionChan chan<- monitor.InterruptionEvent, nodeName string) RebalanceRecommendationMonitor

NewRebalanceRecommendationMonitor creates an instance of a rebalance recoomendation IMDS monitor

func (RebalanceRecommendationMonitor) Kind

func (m RebalanceRecommendationMonitor) Kind() string

Kind denotes the kind of event that is processed

func (RebalanceRecommendationMonitor) Monitor

func (m RebalanceRecommendationMonitor) Monitor() error

Monitor continuously monitors metadata for rebalance recommendations and sends interruption events to the passed in channel