func CanRead()

in pubsub/src/configmap/configmap.go [10:26]


func CanRead() error {
	config, err := rest.InClusterConfig()
	if err != nil {
		log.Fatal(err.Error())
	}
	// creates the clientset
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		log.Fatal(err.Error())
	}
	_, err = clientset.CoreV1().ConfigMaps("default").Get("fleetiqconfig", metav1.GetOptions{})
	if err != nil {
		return err
	} else {
		return nil
	}
}