| 201 | } |
| 202 | |
| 203 | func (d *Dataplane) parseLoadBalancingPolicy(dataPlaneConfig config.DataPlaneConfig) load_balancing.LoadBalancingPolicy { |
| 204 | switch dataPlaneConfig.LoadBalancingPolicy { |
| 205 | case "random": |
| 206 | return load_balancing.LOAD_BALANCING_RANDOM |
| 207 | case "round-robin": |
| 208 | return load_balancing.LOAD_BALANCING_ROUND_ROBIN |
| 209 | case "least-processed": |
| 210 | return load_balancing.LOAD_BALANCING_LEAST_PROCESSED |
| 211 | case "knative": |
| 212 | return load_balancing.LOAD_BALANCING_KNATIVE |
| 213 | default: |
| 214 | logrus.Error("Failed to parse policy, default policy is random") |
| 215 | return load_balancing.LOAD_BALANCING_RANDOM |
| 216 | } |
| 217 | } |
| 218 | |
| 219 | func (d *Dataplane) syncDeploymentCache(cpApi *proto.CpiInterfaceClient, deployments *function_metadata.Deployments) error { |
| 220 | resp, err := (*cpApi).ListServices(context.Background(), &emptypb.Empty{}) |