Remove TODO

cluster/kubernetes/policies_test.go

@@ -9,7 +9,6 @@ import (
 
 	"github.com/weaveworks/flux"
 	"github.com/weaveworks/flux/policy"
-	"github.com/weaveworks/flux/test"
 )
 
 func TestUpdatePolicies(t *testing.T) {
@@ -180,7 +179,7 @@ func TestUpdatePolicies(t *testing.T) {
 			caseIn := templToString(t, annotationsTemplate, c.in)
 			caseOut := templToString(t, annotationsTemplate, c.out)
 			resourceID := flux.MustParseResourceID("default:deployment/nginx")
-			out, err := (&Manifests{test.ConstNamespacer("default")}).UpdateWorkloadPolicies([]byte(caseIn), resourceID, c.update)
+			out, err := (&Manifests{ConstNamespacer("default")}).UpdateWorkloadPolicies([]byte(caseIn), resourceID, c.update)
 			assert.Equal(t, c.wantErr, err != nil, "unexpected error value: %s", err)
 			if !c.wantErr {
 				assert.Equal(t, string(out), caseOut)

release/releaser_test.go

@@ -21,7 +21,6 @@ import (
 	registryMock "github.com/weaveworks/flux/registry/mock"
 	"github.com/weaveworks/flux/resource"
 	"github.com/weaveworks/flux/resourcestore"
-	"github.com/weaveworks/flux/test"
 	"github.com/weaveworks/flux/update"
 )
 
@@ -139,7 +138,7 @@ var (
 			},
 		},
 	}
-	mockManifests = &kubernetes.Manifests{Namespacer: test.ConstNamespacer("default")}
+	mockManifests = &kubernetes.Manifests{Namespacer: kubernetes.ConstNamespacer("default")}
 )
 
 func mockCluster(running ...cluster.Workload) *cluster.Mock {
@@ -1085,7 +1084,7 @@ func Test_BadRelease(t *testing.T) {
 	checkout2, cleanup2 := setup(t)
 	defer cleanup2()
 
-	manifests := &badManifests{Manifests: kubernetes.Manifests{test.ConstNamespacer("default")}}
+	manifests := &badManifests{Manifests: kubernetes.Manifests{kubernetes.ConstNamespacer("default")}}
 	ctx = &ReleaseContext{
 		cluster:       mCluster,
 		resourceStore: NewCheckoutManagerOrFail(t, manifests, checkout2),

resourcestore/checkoutmanager.go

@@ -26,7 +26,6 @@ type checkoutManager struct {
 	policyTranslator cluster.PolicyTranslator
 	resourceStores   []updatableResourceStore
 	cache            *resourceMaps
-	// TODO(fons): Do we really need locking? Can the checkout be shared across threads?
 	sync.RWMutex
 }
 

resourcestore/configfilemanager_test.go

@@ -12,7 +12,6 @@ import (
 	"github.com/weaveworks/flux/cluster/kubernetes"
 	"github.com/weaveworks/flux/image"
 	"github.com/weaveworks/flux/policy"
-	"github.com/weaveworks/flux/test"
 )
 
 const deploymentConfigFile = `---
@@ -40,7 +39,7 @@ updaters:
 `
 
 func TestConfigFileManager(t *testing.T) {
-	mockManifests := &kubernetes.Manifests{test.ConstNamespacer("default")}
+	mockManifests := &kubernetes.Manifests{kubernetes.ConstNamespacer("default")}
 	var cf ConfigFile
 	err := yaml.Unmarshal([]byte(deploymentConfigFile), &cf)
 	cf.RootDirectory = os.TempDir()