utils

Documentation

Index

• func AuthenticateInCluster() (*kubernetes.Clientset, dynamic.Interface, error)
• func AuthenticateOutOfCluster() (*kubernetes.Clientset, dynamic.Interface, error)
• func GetDOClient() *godo.Client
• func RecycleStuckNodes(client *godo.Client, stuckedNodes []NodeInfos)
• func RecyleNode(params ...interface{}) interface{}
• func RunWorkers(workerCount int, endMessage string, arrayParamIndex int, job Job, ...)
• func WatchNodes(clientSet *kubernetes.Clientset, dynClient dynamic.Interface, ...)
• type Job
• type NodeInfos
  • func GetKubeStuckNodesInfos(clientSet *kubernetes.Clientset, minutesDelay time.Duration) []NodeInfos

Functions

func AuthenticateInCluster

func AuthenticateInCluster() (*kubernetes.Clientset, dynamic.Interface, error)

func AuthenticateOutOfCluster

func AuthenticateOutOfCluster() (*kubernetes.Clientset, dynamic.Interface, error)

func GetDOClient

func GetDOClient() *godo.Client

func RecycleStuckNodes

func RecycleStuckNodes(client *godo.Client, stuckedNodes []NodeInfos)

func RecyleNode

func RecyleNode(params ...interface{}) interface{}

func RunWorkers

func RunWorkers(workerCount int, endMessage string, arrayParamIndex int, job Job, params ...interface{})

* CAREFUL : the arrayParamIndex should have the same value that the index of the element used in params

func WatchNodes

func WatchNodes(clientSet *kubernetes.Clientset, dynClient dynamic.Interface, DOclient *godo.Client, creationDelay time.Duration)

Types

type Job

type Job func(elems ...interface{}) interface{}

type NodeInfos

type NodeInfos struct {
	ClusterId string
	PoolId    string
	NodeId    string
}

func GetKubeStuckNodesInfos

func GetKubeStuckNodesInfos(clientSet *kubernetes.Clientset, minutesDelay time.Duration) []NodeInfos