handler

func NewAWSInterruptChecker ¶

func NewAWSInterruptChecker() InterruptChecker

func NewAzureInterruptChecker ¶

func NewAzureInterruptChecker() InterruptChecker

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() InterruptChecker

NewGCPChecker checks for gcp spot interrupt event from metadata server.

func NewSpotHandler ¶

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