service_registry

type GatewayRegistry interface {
	// platform's ServiceRegistry methods
	AddServices(locations ...platform_registry.ServiceLocation)
	AddService(location platform_registry.ServiceLocation)
	GetServiceAddress(service string) (string, error)
	GetServicePort(service string) (int, error)
	GetServiceProxyAliases(service string) (map[string]int, error)
	ListAllServices() []string

	// Gateway specific methods
	//
	// GetCloudConnection Creates and returns a new GRPC service connection to the service.
	// GetCloudConnection always creates a new connection & it's responsibility of the caller to close it.
	GetCloudConnection(service string) (*grpc.ClientConn, error)
	// GetCloudConnectionFromServiceConfig returns a connection to the cloud
	// using a specific control_proxy service config map. This map must contain the cloud_address
	// and local_port params
	// Input: serviceConfig - ConfigMap containing cloud_address and local_port and optional proxy_cloud_connections,
	// 		  cloud_port, rootca_cert, gateway_cert/key fields if direct cloud connection is needed
	//        service - name of cloud service to connect to
	// Output: *grpc.ClientConn with connection to cloud service error if it exists
	GetCloudConnectionFromServiceConfig(controlProxyConfig *config.ConfigMap, service string) (*grpc.ClientConn, error)
	// GetSharedCloudConnection returns a new GRPC service connection to the service in the cloud for a gateway
	// either directly or via control proxy
	// GetSharedCloudConnection will return an existing cached cloud connection if it's available and healthy,
	// if not - it'll try to create, cache and return a new cloud connection
	GetSharedCloudConnection(service string) (*grpc.ClientConn, error)
	// GetSharedCloudConnectionFromServiceConfig returns a connection to the cloud
	// using a specific control_proxy service config map. This map must contain the cloud_address
	// and local_port params
	// GetSharedCloudConnectionFromServiceConfig will return an existing cached cloud connection if it's available and
	// healthy, if not - it'll try to create, cache and return a new cloud connection
	GetSharedCloudConnectionFromServiceConfig(controlProxyConfig *config.ConfigMap, service string) (*grpc.ClientConn, error)
	// GetClientConnection provides a gRPC connection to a service on the address addr.
	CleanupSharedCloudConnection(service string) bool

	// GetConnection provides a gRPC connection to a service in the registry.
	GetConnection(service string) (*grpc.ClientConn, error)
	GetConnectionImpl(ctx context.Context, service string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
}

type ProxiedRegistry platform_registry.ServiceRegistry