Import changes.

  - b16f226c6c36b64dd1216c6a69e38aeb7dd4f499

GitOrigin-RevId: b16f226c6c36b64dd1216c6a69e38aeb7dd4f499

Author: Aalyria Technologies, Inc

agent/enactment_service.go

@@ -31,7 +31,6 @@ import (
 	"aalyria.com/spacetime/agent/internal/channels"
 	"aalyria.com/spacetime/agent/internal/loggable"
 	"aalyria.com/spacetime/agent/internal/task"
-	apipb "aalyria.com/spacetime/api/common"
 	schedpb "aalyria.com/spacetime/api/scheduling/v1alpha"
 )
 
@@ -43,11 +42,10 @@ const attemptedUpdateKeepAliveTimeout = 1 * time.Minute
 func OK() *status.Status { return status.New(codes.OK, "") }
 
 type enactmentService struct {
-	sc        schedpb.SchedulingClient
-	ed        enactment.Driver
-	clock     clockwork.Clock
-	initState *apipb.ControlPlaneState
-	nodeID    string
+	sc     schedpb.SchedulingClient
+	ed     enactment.Driver
+	clock  clockwork.Clock
+	nodeID string
 
 	scheduleManipulationToken string
 	schedMgr                  *scheduleManager
@@ -63,7 +61,6 @@ func (nc *nodeController) newEnactmentService(sc schedpb.SchedulingClient, ed en
 		sc:                        sc,
 		clock:                     nc.clock,
 		nodeID:                    nc.id,
-		initState:                 nc.initState,
 		scheduleManipulationToken: manipToken,
 		schedMgr:                  newScheduleManager(),
 		reqsFromController:        make(chan *schedpb.ReceiveRequestsMessageFromController),

agent/internal/configpb/BUILD

@@ -21,7 +21,6 @@ proto_library(
     name = "configpb_proto",
     srcs = ["config.proto"],
     deps = [
-        "//api/common:common_proto",
         "@protobuf//:any_proto",
         "@protobuf//:duration_proto",
         "@protobuf//:empty_proto",
@@ -32,7 +31,4 @@ go_proto_library(
     name = "configpb_go_proto",
     importpath = "aalyria.com/spacetime/agent/internal/configpb",
     proto = ":configpb_proto",
-    deps = [
-        "//api/common:common_go_proto",
-    ],
 )

agent/internal/configpb/config.proto

@@ -21,7 +21,6 @@ package aalyria.spacetime.agent.cmd.agent;
 import "google/protobuf/duration.proto";
 import "google/protobuf/empty.proto";
 import "google/protobuf/any.proto";
-import "api/common/control.proto";
 
 option go_package = "aalyria.com/spacetime/agent/internal/configpb";
 
@@ -155,9 +154,7 @@ message SdnAgent {
 
     oneof type {
       // Use an external command to process enactments. The command will
-      // receive a ScheduledControlUpdate message over standard input. The
-      // command may optionally write a new ControlPlaneState message to
-      // standard out.
+      // receive a CreateEntryRequest message over standard input.
       ExternalCommand external_command = 2;
 
       // Use the Linux-only netlink APIs to process enactments.
@@ -219,7 +216,7 @@ message ObservabilityParams {
   string otel_collector_endpoint = 1;
   // Whether to connect to the OTEL gRPC collector over a plaintext (insecure)
   // connection. Corresponds to the "WithInsecure" exporter option
-  // https://pkg.go.dev/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc#WithInsecure 
+  // https://pkg.go.dev/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc#WithInsecure
   bool use_insecure_connection_for_otel_collector = 4;
 
   // Channelz is a gRPC introspection service that can aid in debugging and