Merge branch 'klapkov-routing_info'

Author: mariash

client.go

@@ -169,6 +169,9 @@ type ExternalDesiredLRPClient interface {
 	// Returns all DesiredLRPSchedulingInfos that match the given DesiredLRPFilter
 	DesiredLRPSchedulingInfos(lager.Logger, string, models.DesiredLRPFilter) ([]*models.DesiredLRPSchedulingInfo, error)
 
+	// Returns all DesiredLRPRoutingInfos that match the given DesiredLRPFilter
+	DesiredLRPRoutingInfos(lager.Logger, string, models.DesiredLRPFilter) ([]*models.DesiredLRP, error)
+
 	// Creates the given DesiredLRP and its corresponding ActualLRPs
 	DesireLRP(lager.Logger, string, *models.DesiredLRP) error
 
@@ -600,6 +603,19 @@ func (c *client) DesiredLRPSchedulingInfos(logger lager.Logger, traceID string,
 	return response.DesiredLrpSchedulingInfos, response.Error.ToError()
 }
 
+func (c *client) DesiredLRPRoutingInfos(logger lager.Logger, traceID string, filter models.DesiredLRPFilter) ([]*models.DesiredLRP, error) {
+	request := models.DesiredLRPsRequest{
+		ProcessGuids: filter.ProcessGuids,
+	}
+	response := models.DesiredLRPsResponse{}
+	err := c.doRequest(logger, traceID, DesiredLRPRoutingInfosRoute_r0, nil, nil, &request, &response)
+	if err != nil {
+		return nil, err
+	}
+
+	return response.DesiredLrps, response.Error.ToError()
+}
+
 func (c *client) doDesiredLRPLifecycleRequest(logger lager.Logger, traceID string, route string, request proto.Message) error {
 	response := models.DesiredLRPLifecycleResponse{}
 	err := c.doRequest(logger, traceID, route, nil, nil, request, &response)

db/dbfakes/fake_db.go

@@ -14,6 +14,7 @@ type DesiredLRPDB interface {
 	DesiredLRPByProcessGuid(ctx context.Context, logger lager.Logger, processGuid string) (*models.DesiredLRP, error)
 
 	DesiredLRPSchedulingInfos(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRPSchedulingInfo, error)
+	DesiredLRPRoutingInfos(ctx context.Context, logger lager.Logger, filter models.DesiredLRPFilter) ([]*models.DesiredLRP, error)
 
 	DesireLRP(ctx context.Context, logger lager.Logger, desiredLRP *models.DesiredLRP) error
 	UpdateDesiredLRP(ctx context.Context, logger lager.Logger, processGuid string, update *models.DesiredLRPUpdate) (beforeDesiredLRP *models.DesiredLRP, err error)