func()

in kubernetes/k8skeystore/kubernetes_keystore.go [62:86]

• 25 lines of code
• 6 McCabe index (conditional complexity)

func (kr *KubernetesKeystoresRegistry) GetKeystore(event bus.Event) keystore.Keystore {
	namespace := ""
	if val, ok := event["kubernetes"]; ok {
		kubernetesMeta, ok := val.(mapstr.M)
		if !ok {
			kr.logger.Debugf("Unexpected type for kubernetes: %v", kubernetesMeta)
			return nil
		}
		ns, err := kubernetesMeta.GetValue("namespace")
		if err != nil {
			kr.logger.Debugf("Cannot retrieve kubernetes namespace from event: %s", event)
			return nil
		}
		namespace, ok = ns.(string)
		if !ok {
			return nil
		}
	}
	if namespace != "" {
		k8sKeystore, _ := Factoryk8s(namespace, kr.client, kr.logger)
		return k8sKeystore
	}
	kr.logger.Debugf("Cannot retrieve kubernetes namespace from event: %s", event)
	return nil
}