k8sutils

Documentation

Index

• func CreateKubeClientSet(kubeconfig string) (*kubernetes.Clientset, error)
• func GetStats(ctx context.Context, volumePath string) (int64, int64, int64, int64, int64, int64, error)
• func LeaderElection(clientset *kubernetes.Clientset, lockName string, namespace string, ...)

Functions

func CreateKubeClientSet

func CreateKubeClientSet(kubeconfig string) (*kubernetes.Clientset, error)

CreateKubeClientSet - Returns kubeclient set

func GetStats

func GetStats(ctx context.Context, volumePath string) (int64, int64, int64, int64, int64, int64, error)

GetStats - Returns the stats for the volume mounted on given volume path

func LeaderElection

func LeaderElection(clientset *kubernetes.Clientset, lockName string, namespace string,
	leaderElectionRenewDeadline, leaderElectionLeaseDuration, leaderElectionRetryPeriod time.Duration, runFunc func(ctx context.Context),
)

LeaderElection - Initialize leader election