cluster/identd/kubenat/pods_test.go

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)
	}
}