Sampe kube-harness test

basic_test.go

func TestConsistentAllRequestsAnswered(t *testing.T) {
	t.Parallel()

	test := kube.NewTest(t).Setup()
	defer test.Close()

	// Create a deploymenent from a manifest file and wait for all replicas to be ready.
	service := test.CreateDeploymentFromFile(test.Namespace, "service-deploy.yaml")
	test.WaitForDeploymentReady(service, 1*time.Minute)

	// Query /info on each pod of the deployment and check the results
	for _, pod := range test.ListPodsFromDeployment(service).Items {
		stats := ServiceStats{}
		test.PodProxyGetJSON(&pod, "", "/info", &stats)
		// Check stats
		...
	}
}