Method GetProxyServer

internal/data_plane/data_plane.go:159–194

(async bool)

}

func (d *Dataplane) GetProxyServer(async bool) (proxy.Proxy, error) {
	cpApi, err := grpc_helpers.NewControlPlaneConnection(d.config.ControlPlaneAddress)
	if err != nil {
		return nil, err
	}

	err = d.registerDataPlane(cpApi)
	if err != nil {
		return nil, err
	}

	err = d.syncDeploymentCache(&cpApi, d.deployments)
	if err != nil {
		return nil, err
	}

	loadBalancingPolicy := d.parseLoadBalancingPolicy(d.config)

	if !async {
		return proxy.NewProxyingService(
			d.config.PortProxy,
			d.deployments,
			cpApi,
			path.Join(d.config.TraceOutputFolder, "proxy_trace.csv"),
			loadBalancingPolicy,
		), nil
	} else {
		return proxy.NewAsyncProxyingService(
			d.config,
			d.deployments,
			cpApi,
			path.Join(d.config.TraceOutputFolder, "proxy_trace.csv"),
			loadBalancingPolicy,
		), nil
	}
}

func (d *Dataplane) DeregisterControlPlaneConnection() {
	err := grpc_helpers.DeregisterControlPlaneConnection(&d.config)