Set managed-by: pulumi label on all created resources (#418)

pkg/await/await.go

@@ -20,6 +20,7 @@ import (
 
 	"github.com/golang/glog"
 	"github.com/pulumi/pulumi-kubernetes/pkg/clients"
+	"github.com/pulumi/pulumi-kubernetes/pkg/metadata"
 	"github.com/pulumi/pulumi-kubernetes/pkg/openapi"
 	"github.com/pulumi/pulumi-kubernetes/pkg/retry"
 	"github.com/pulumi/pulumi/pkg/diag"
@@ -108,6 +109,9 @@ func Creation(c CreateConfig) (*unstructured.Unstructured, error) {
 				}
 			}
 
+			// Set a "managed-by: pulumi" label on all created k8s resources.
+			metadata.SetManagedByLabel(c.Inputs)
+
 			outputs, err = client.Create(c.Inputs, metav1.CreateOptions{})
 			if err != nil {
 				_ = c.Host.LogStatus(c.Context, diag.Info, c.URN, fmt.Sprintf(

pkg/metadata/labels.go

@@ -0,0 +1,32 @@
+// Copyright 2016-2019, Pulumi Corporation.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package metadata
+
+import (
+	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+)
+
+func SetLabel(obj *unstructured.Unstructured, key, value string) {
+	labels := obj.GetLabels()
+	if labels == nil {
+		labels = map[string]string{}
+	}
+	labels[key] = value
+	obj.SetLabels(labels)
+}
+
+func SetManagedByLabel(obj *unstructured.Unstructured) {
+	SetLabel(obj, "app.kubernetes.io/managed-by", "pulumi")
+}