k8s_module

Documentation

Index

• func GetClusterInfo(sd *k8sutils.K8sServiceDiscoveryConfig) ([]*k8sutils.K8sClusterConfig, error)
• func Init()
• func InitQueues()
• func InitServiceDiscoveryConfigAndInformers(cfg *rest.Config, stopCh <-chan struct{})
• func RunControllers(mciCtrl *mciutils.MCIController, siCtrl *serviceimport.ServiceImportController, ...)
• func RunQueues(stopCh <-chan struct{})

Functions

func GetClusterInfo

func GetClusterInfo(sd *k8sutils.K8sServiceDiscoveryConfig) ([]*k8sutils.K8sClusterConfig, error)

func Init

func Init()

func InitQueues

func InitQueues()

func InitServiceDiscoveryConfigAndInformers

func InitServiceDiscoveryConfigAndInformers(cfg *rest.Config, stopCh <-chan struct{})

func RunControllers

func RunControllers(mciCtrl *mciutils.MCIController, siCtrl *serviceimport.ServiceImportController, stopCh <-chan struct{})

func RunQueues

func RunQueues(stopCh <-chan struct{})