cluster/identd/kubenat: implement
This is a library to find pod information for a given TCP 4-tuple.
Change-Id: I254983e579e3aaa04c0c5491851f4af94a3f4249
diff --git a/cluster/identd/kubenat/pods_test.go b/cluster/identd/kubenat/pods_test.go
new file mode 100644
index 0000000..3fd26a3
--- /dev/null
+++ b/cluster/identd/kubenat/pods_test.go
@@ -0,0 +1,42 @@
+package kubenat
+
+import (
+ "context"
+ "flag"
+ "net"
+ "testing"
+
+ "github.com/golang/glog"
+)
+
+func TestPodWorker(t *testing.T) {
+ t.Skip("needs containerd running on host and unhardcoded test data")
+ flag.Set("logtostderr", "true")
+
+ r := &Resolver{
+ criPath: "/tmp/containerd.sock",
+ podInfoC: make(chan *podInfoReq),
+ }
+
+ ctx, ctxC := context.WithCancel(context.Background())
+ defer ctxC()
+
+ go func() {
+ err := r.runPodWorker(ctx)
+ if err != nil && err != ctx.Err() {
+ glog.Errorf("runPodWorker: %v", err)
+ }
+ }()
+
+ res, err := r.getPodInfo(ctx, net.IPv4(10, 10, 26, 23))
+ if err != nil {
+ t.Fatalf("got err: %v", err)
+ }
+ if res == nil {
+ t.Fatalf("got nil pod response")
+ }
+
+ if want, got := "matrix", res.namespace; want != got {
+ t.Errorf("namespace: got %q, wanted %q", want, got)
+ }
+}