diff --git a/runtime/kubernetes/kubernetes.go b/runtime/kubernetes/kubernetes.go index f9272239..088f519c 100644 --- a/runtime/kubernetes/kubernetes.go +++ b/runtime/kubernetes/kubernetes.go @@ -36,11 +36,19 @@ type kubernetes struct { func (k *kubernetes) namespaceExists(name string) (bool, error) { // populate the cache if k.namespaces == nil { + if logger.V(logger.DebugLevel, logger.DefaultLogger) { + logger.Debugf("Populating namespace cache") + } + namespaceList := new(client.NamespaceList) resource := &client.Resource{Kind: "namespace", Value: namespaceList} if err := k.client.List(resource); err != nil { return false, err } + + if logger.V(logger.DebugLevel, logger.DefaultLogger) { + logger.Debugf("Popualted namespace cache successfully with %v items", len(namespaceList.Items)) + } k.namespaces = namespaceList.Items } @@ -418,9 +426,15 @@ func (k *kubernetes) Create(s *runtime.Service, opts ...runtime.CreateOption) er if namespace != "default" { if exist, err := k.namespaceExists(namespace); err == nil && !exist { if err := k.createNamespace(namespace); err != nil { + if logger.V(logger.WarnLevel, logger.DefaultLogger) { + logger.Warnf("Error creating namespacr %v: %v", namespace, err) + } return err } } else if err != nil { + if logger.V(logger.WarnLevel, logger.DefaultLogger) { + logger.Warnf("Error checking namespace %v exists: %v", namespace, err) + } return err } }