kms

Documentation

Index

• Constants
• Variables

Constants

const DiagnosticKMS = config.DiagnosticKMS

Variables

var (
	// Exported so that it can be overridden in tests
	MaxRetry      = 12
	RetryInterval = 10 * time.Second
)

var NewProvider = func(ctx context.Context, cfg *config.Settings, clientset ...kubernetes.Interface) diagnostic.Provider {
	var cs kubernetes.Interface
	if len(clientset) > 0 {
		cs = clientset[0]
	} else {

		config, err := rest.InClusterConfig()
		if err != nil {
			kubeconfig := clientcmd.RecommendedHomeFile
			config, err = clientcmd.BuildConfigFromFlags("", kubeconfig)
			if err != nil {
				panic(err.Error())
			}
		}

		cs, err = kubernetes.NewForConfig(config)
		if err != nil {
			panic(err.Error())
		}
	}

	return &checker{
		cfg: cfg,
		logger: logging.NewLogger().
			WithContext(ctx).WithField(logging.OpField, "ksm"),
		clientset: cs,
	}
}