feat: Implement per-route options forwarding in route-emitter

routehandlers/handler_test.go

@@ -1076,6 +1076,7 @@ var _ = Describe("Handler", func() {
 						Hostnames:       []string{hostname1},
 						Port:            8080,
 						RouteServiceUrl: "https://rs.example.com",
+						Options:         json.RawMessage(`{"lb_algo":"least-connection"}`),
 					},
 				}.RoutingInfo()
 

routingtable/endpoint.go

@@ -1,6 +1,7 @@
 package routingtable
 
 import (
+	"encoding/json"
 	"fmt"
 
 	"code.cloudfoundry.org/bbs/models"
@@ -141,6 +142,7 @@ type Route struct {
 	LogGUID          string
 	Protocol         string
 	MetricTags       map[string]*models.MetricTagValue
+	Options          json.RawMessage
 }
 
 type routeHash struct {

routingtable/registry_message.go

@@ -1,6 +1,7 @@
 package routingtable
 
 import (
+	"encoding/json"
 	"fmt"
 	"strconv"
 
@@ -22,6 +23,7 @@ type RegistryMessage struct {
 	EndpointUpdatedAtNs  int64             `json:"endpoint_updated_at_ns,omitempty" hash:"ignore"`
 	Tags                 map[string]string `json:"tags,omitempty" hash:"ignore"`
 	AvailabilityZone     string            `json:"availability_zone,omitempty" hash:"ignore"`
+	Options              json.RawMessage   `json:"options,omitempty" hash:"ignore"`
 }
 
 func RegistryMessageFor(endpoint Endpoint, route Route, emitEndpointUpdatedAt bool) RegistryMessage {
@@ -50,6 +52,7 @@ func RegistryMessageFor(endpoint Endpoint, route Route, emitEndpointUpdatedAt bo
 		PrivateInstanceIndex: index,
 		ServerCertDomainSAN:  endpoint.InstanceGUID,
 		RouteServiceUrl:      route.RouteServiceUrl,
+		Options:              route.Options,
 	}
 }
 

routingtable/registry_message_test.go

@@ -120,6 +120,34 @@ var _ = Describe("RegistryMessage", func() {
 				Expect(message).To(Equal(expectedMessage))
 			})
 		})
+
+		Context("when a route option is provided", func() {
+			BeforeEach(func() {
+				expectedMessage.Options = json.RawMessage(`{"lb_algo":"least-connection"}`)
+				expectedJSON = `{
+				"host": "1.1.1.1",
+				"port": 61001,
+				"uris": ["host-1.example.com"],
+				"app" : "app-guid",
+				"private_instance_id": "instance-guid",
+				"server_cert_domain_san": "instance-guid",
+				"private_instance_index": "0",
+				"route_service_url": "https://hello.com",
+				"endpoint_updated_at_ns": 1000,
+				"tags": {"component":"route-emitter", "doo": "0", "foo": "bar", "goo": "instance-guid"},
+				"availability_zone": "some-zone",
+				"options": {"lb_algo":"least-connection"}
+			}`
+			})
+
+			It("correctly marshals the route option", func() {
+				message := routingtable.RegistryMessage{}
+
+				err := json.Unmarshal([]byte(expectedJSON), &message)
+				Expect(err).NotTo(HaveOccurred())
+				Expect(message).To(Equal(expectedMessage))
+			})
+		})
 	})
 
 	Describe("RegistryMessageFor", func() {
@@ -182,6 +210,18 @@ var _ = Describe("RegistryMessage", func() {
 				Expect(message).To(Equal(expectedMessage))
 			})
 		})
+
+		Context("when route options are provided", func() {
+			BeforeEach(func() {
+				route.Options = json.RawMessage(`{"lb_algo":"least-connection"}`)
+				expectedMessage.Options = json.RawMessage(`{"lb_algo":"least-connection"}`)
+			})
+
+			It("creates a valid message when route options are provided", func() {
+				message := routingtable.RegistryMessageFor(endpoint, route, true)
+				Expect(message).To(Equal(expectedMessage))
+			})
+		})
 	})
 
 	Describe("InternalAddressRegistryMessageFor", func() {

routingtable/routingtable.go

@@ -444,6 +444,7 @@ func httpRoutesFrom(lrp *models.DesiredLRP) map[RoutingKey][]routeMapping {
 				IsolationSegment: route.IsolationSegment,
 				MetricTags:       lrp.MetricTags,
 				Protocol:         route.Protocol,
+				Options:          route.Options,
 			}
 			routes = append(routes, route)
 		}