Serge Bazanski | 6b649f8 | 2021-05-24 15:09:25 +0200 | [diff] [blame] | 1 | package kubenat |
| 2 | |
| 3 | import ( |
| 4 | "context" |
| 5 | "flag" |
| 6 | "net" |
| 7 | "testing" |
| 8 | |
| 9 | "github.com/golang/glog" |
| 10 | ) |
| 11 | |
| 12 | func TestPodWorker(t *testing.T) { |
| 13 | t.Skip("needs containerd running on host and unhardcoded test data") |
| 14 | flag.Set("logtostderr", "true") |
| 15 | |
| 16 | r := &Resolver{ |
| 17 | criPath: "/tmp/containerd.sock", |
| 18 | podInfoC: make(chan *podInfoReq), |
| 19 | } |
| 20 | |
| 21 | ctx, ctxC := context.WithCancel(context.Background()) |
| 22 | defer ctxC() |
| 23 | |
| 24 | go func() { |
| 25 | err := r.runPodWorker(ctx) |
| 26 | if err != nil && err != ctx.Err() { |
| 27 | glog.Errorf("runPodWorker: %v", err) |
| 28 | } |
| 29 | }() |
| 30 | |
| 31 | res, err := r.getPodInfo(ctx, net.IPv4(10, 10, 26, 23)) |
| 32 | if err != nil { |
| 33 | t.Fatalf("got err: %v", err) |
| 34 | } |
| 35 | if res == nil { |
| 36 | t.Fatalf("got nil pod response") |
| 37 | } |
| 38 | |
| 39 | if want, got := "matrix", res.namespace; want != got { |
| 40 | t.Errorf("namespace: got %q, wanted %q", want, got) |
| 41 | } |
| 42 | } |