k8s

Documentation

Index

• Variables
• func LoggingContext(ctx context.Context, component string, masterUrl string, kubeconfigPath string) context.Context

Variables

var K8sClientWrapper = func(masterUrl string, kubeconfigPath string) kubernetes.Interface {

	k8sConfig, err := k8sclientcmd.BuildConfigFromFlags(masterUrl, kubeconfigPath)
	if err != nil {
		log.Fatalf("Failed To Build Kubernetes Config: %v", err)
	}

	return kubernetes.NewForConfigOrDie(k8sConfig)
}

K8sClientWrapper Used To Facilitate Unit Testing

Functions

func LoggingContext

func LoggingContext(ctx context.Context, component string, masterUrl string, kubeconfigPath string) context.Context

Initialize The Specified Context With A K8S Client & Logger (ConfigMap Watcher)

Note - This logic represents a stepping stone on our path towards alignment with the Knative eventing-contrib implementations.

The Channel / Dispatcher are not "injected controllers" in the knative-eventing injection framework, but still want to
leverage that implementation as much as possible to ease future refactoring.  This will allow us to use the default
knative-eventing logging configuration and dynamic updating.  To that end, we are setting up a basic context ourselves
that mirrors what the injection framework would have created.