Sync Namespace meta

Author: lippserd

cmd/icinga-kubernetes/main.go

@@ -76,6 +76,12 @@ func main() {
 		).Run(ctx)
 	})
 
+	g.Go(func() error {
+		return sync.NewSync(
+			db, schema.NewNamespace, informers.Core().V1().Namespaces().Informer(), logs.GetChildLogger("Namespaces"),
+		).Run(ctx)
+	})
+
 	if err := g.Wait(); err != nil {
 		logging.Fatal(errors.Wrap(err, "can't sync"))
 	}

pkg/schema/namespace.go

@@ -0,0 +1,18 @@
+package schema
+
+import (
+	"github.com/icinga/icinga-kubernetes/pkg/contracts"
+	kmetav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+type Namespace struct {
+	kmetaWithoutNamespace
+}
+
+func NewNamespace() contracts.Resource {
+	return &Namespace{}
+}
+
+func (n *Namespace) Obtain(kobject kmetav1.Object) {
+	n.kmetaWithoutNamespace.Obtain(kobject)
+}

schema/mysql/schema.sql

@@ -7,3 +7,13 @@ CREATE TABLE node (
   created bigint unsigned NOT NULL,
   PRIMARY KEY (id)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
+
+CREATE TABLE namespace (
+  id binary(20) NOT NULL,
+  canonical_name varchar(63) COLLATE utf8mb4_unicode_ci NOT NULL,
+  name varchar(63) COLLATE utf8mb4_unicode_ci NOT NULL,
+  uid varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
+  resource_version varchar(255) NOT NULL,
+  created bigint unsigned NOT NULL,
+  PRIMARY KEY (id)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;