just setting some backup state..

Author: jdhollen

enterprise/server/cmd/cache_proxy/BUILD

@@ -21,6 +21,7 @@ go_library(
         "//enterprise/server/content_addressable_storage_server_proxy",
         "//enterprise/server/hit_tracker_client",
         "//enterprise/server/remoteauth",
+        "//enterprise/server/routing/operators",
         "//enterprise/server/routing/routing_action_cache_client",
         "//enterprise/server/routing/routing_byte_stream_client",
         "//enterprise/server/routing/routing_capabilities_client",

enterprise/server/cmd/cache_proxy/cache_proxy.go

@@ -17,6 +17,7 @@ import (
 	"github.com/buildbuddy-io/buildbuddy/enterprise/server/content_addressable_storage_server_proxy"
 	"github.com/buildbuddy-io/buildbuddy/enterprise/server/hit_tracker_client"
 	"github.com/buildbuddy-io/buildbuddy/enterprise/server/remoteauth"
+	"github.com/buildbuddy-io/buildbuddy/enterprise/server/routing/operators"
 	"github.com/buildbuddy-io/buildbuddy/enterprise/server/routing/routing_action_cache_client"
 	"github.com/buildbuddy-io/buildbuddy/enterprise/server/routing/routing_byte_stream_client"
 	"github.com/buildbuddy-io/buildbuddy/enterprise/server/routing/routing_capabilities_client"
@@ -232,6 +233,21 @@ func registerGRPCServices(grpcServer *grpc.Server, env *real_environment.RealEnv
 			log.Fatalf("Error initializing routing service: %s", err.Error())
 		}
 
+		casCopyOperator, err := operators.NewCopyOperator(env)
+		if err != nil {
+			log.Fatalf("Error initializing CAS migration logic: %s", err.Error())
+		}
+
+		findMissingOperator, err := operators.NewFindMissingOperator(env)
+		if err != nil {
+			log.Fatalf("Error initializing CAS migration logic: %s", err.Error())
+		}
+
+		readOperator, err := operators.NewReadOperator(env)
+		if err != nil {
+			log.Fatalf("Error initializing CAS migration validation logic: %s", err.Error())
+		}
+
 		ac, err := routing_action_cache_client.New(env)
 		if err != nil {
 			log.Fatalf("Error initializing routing action cache client: %s", err.Error())
@@ -244,13 +260,13 @@ func registerGRPCServices(grpcServer *grpc.Server, env *real_environment.RealEnv
 		}
 		env.SetCapabilitiesClient(cap)
 
-		bs, err := routing_byte_stream_client.New(env)
+		bs, err := routing_byte_stream_client.New(env, casCopyOperator, readOperator)
 		if err != nil {
 			log.Fatalf("Error initializing routing bytestream client: %s", err.Error())
 		}
 		env.SetByteStreamClient(bs)
 
-		cas, err := routing_content_addressable_storage_client.New(env)
+		cas, err := routing_content_addressable_storage_client.New(env, casCopyOperator, readOperator, findMissingOperator)
 		if err != nil {
 			log.Fatalf("Error initializing routing CAS client: %s", err.Error())
 		}

enterprise/server/routing/operators/BUILD

@@ -0,0 +1,18 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "operators",
+    srcs = ["operators.go"],
+    importpath = "github.com/buildbuddy-io/buildbuddy/enterprise/server/routing/operators",
+    visibility = ["//visibility:public"],
+    deps = [
+        "//enterprise/server/batch_operator",
+        "//proto:remote_execution_go_proto",
+        "//server/environment",
+        "//server/interfaces",
+        "//server/remote_cache/digest",
+        "//server/util/status",
+        "//server/util/usageutil",
+        "@org_golang_google_genproto_googleapis_bytestream//:bytestream",
+    ],
+)