Sync Pod meta

Author: lippserd

cmd/icinga-kubernetes/main.go

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

pkg/schema/pod.go

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

schema/mysql/schema.sql

@@ -17,3 +17,14 @@ CREATE TABLE namespace (
   created bigint unsigned NOT NULL,
   PRIMARY KEY (id)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin;
+
+CREATE TABLE pod (
+  id binary(20) NOT NULL,
+  canonical_name varchar(317) COLLATE utf8mb4_unicode_ci NOT NULL COMMENT 'namespace/name',
+  namespace varchar(63) COLLATE utf8mb4_unicode_ci NOT NULL,
+  name varchar(253) 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;