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
}
}