handler

Documentation

Index

• Constants
• type MetadataChecker
  • func NewAWSInterruptChecker() MetadataChecker
  • func NewAzureInterruptChecker() MetadataChecker
  • func NewGCPChecker() MetadataChecker
• type SpotHandler
  • func NewSpotHandler(log logrus.FieldLogger, castClient castai.Client, ...) *SpotHandler
  • func (g *SpotHandler) Run(ctx context.Context) error

Constants

const CastNodeIDLabel = "provisioner.cast.ai/node-id"

Types

type MetadataChecker

type MetadataChecker interface {
	CheckInterrupt(ctx context.Context) (bool, error)
	CheckRebalanceRecommendation(ctx context.Context) (bool, error)
}

func NewAWSInterruptChecker

func NewAWSInterruptChecker() MetadataChecker

func NewAzureInterruptChecker

func NewAzureInterruptChecker() MetadataChecker

NewAzureInterruptChecker checks for azure spot interrupt event from metadata server. See https://docs.microsoft.com/en-us/azure/virtual-machines/linux/scheduled-events#endpoint-discovery

func NewGCPChecker

func NewGCPChecker() MetadataChecker

NewGCPChecker checks for gcp spot interrupt event from metadata server.

type SpotHandler

type SpotHandler struct {
	// contains filtered or unexported fields
}

func NewSpotHandler

func NewSpotHandler(
	log logrus.FieldLogger,
	castClient castai.Client,
	clientset kubernetes.Interface,
	metadataChecker MetadataChecker,
	pollWaitInterval time.Duration,
	nodeName string,
) *SpotHandler

func (*SpotHandler) Run

func (g *SpotHandler) Run(ctx context.Context) error