Documentation
¶
Index ¶
- Constants
- func APIInt(api string) int
- func Container(endpoint *basev0.Endpoint, port uint16) *basev0.NetworkInstance
- func ContainerInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
- func DNS(_ *configurations.Service, endpoint *basev0.Endpoint, dns *basev0.DNS) *basev0.NetworkInstance
- func ExternalInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
- func GetPidUsingPort(port int) (string, error)
- func HashInt(s string, low, high int) int
- func IsPortAvailable(port int) bool
- func KillProcess(pid string) error
- func KillProcessUsingPort(port int) error
- func LoadBalanced(_ context.Context, env *configurations.Environment, ...) *basev0.NetworkInstance
- func Native(endpoint *basev0.Endpoint, port uint16) *basev0.NetworkInstance
- func NativeInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
- func PublicDefault(endpoint *basev0.Endpoint, port uint16) *basev0.NetworkInstance
- func PublicInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
- func ToNamedPort(_ context.Context, project string, app string, svc string, name string, ...) uint16
- type DNSManager
- type DeployManager
- func (m *DeployManager) GenerateNetworkMappings(ctx context.Context, service *configurations.Service, ...) ([]*basev0.NetworkMapping, error)
- func (m *DeployManager) GetNamespace(_ context.Context, service *configurations.Service, ...) (string, error)
- func (m *DeployManager) KubernetesService(service *configurations.Service, endpoint *basev0.Endpoint, namespace string, ...) *basev0.NetworkInstance
- type FixedStrategy
- type Manager
- type RuntimeManager
- func (m *RuntimeManager) GenerateNetworkMappings(ctx context.Context, service *configurations.Service, ...) ([]*basev0.NetworkMapping, error)
- func (m *RuntimeManager) GetNamespace(context.Context, *configurations.Service, *configurations.Environment) (string, error)
- func (m *RuntimeManager) SetLoadBalancer(string)
Constants ¶
View Source
const Localhost = "localhost"
Variables ¶
This section is empty.
Functions ¶
func ContainerInstance ¶ added in v0.1.69
func ContainerInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
func DNS ¶ added in v0.1.69
func DNS(_ *configurations.Service, endpoint *basev0.Endpoint, dns *basev0.DNS) *basev0.NetworkInstance
func ExternalInstance ¶ added in v0.1.69
func ExternalInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
func GetPidUsingPort ¶ added in v0.1.64
func IsPortAvailable ¶
func KillProcess ¶ added in v0.1.64
func KillProcessUsingPort ¶ added in v0.1.64
func LoadBalanced ¶ added in v0.1.74
func LoadBalanced(_ context.Context, env *configurations.Environment, service *configurations.Service, endpoint *basev0.Endpoint) *basev0.NetworkInstance
func NativeInstance ¶ added in v0.1.69
func NativeInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
func PublicDefault ¶ added in v0.1.69
func PublicDefault(endpoint *basev0.Endpoint, port uint16) *basev0.NetworkInstance
func PublicInstance ¶ added in v0.1.69
func PublicInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance
func ToNamedPort ¶
func ToNamedPort(_ context.Context, project string, app string, svc string, name string, api string) uint16
ToNamedPort strategy: APP-SVC-API Between 1100(0) and 4999(9) First 11 -> 49: hash app Next 0 -> 9: hash svc Next 0 - 9: hash name Last Digit: API 0: TCP 1: HTTP/ REST 2: gRPC
Types ¶
type DNSManager ¶
type DeployManager ¶ added in v0.1.65
type DeployManager struct {
// contains filtered or unexported fields
}
func NewDeployManager ¶ added in v0.1.65
func NewDeployManager(_ context.Context, dnsManager DNSManager) (*DeployManager, error)
func (*DeployManager) GenerateNetworkMappings ¶ added in v0.1.65
func (m *DeployManager) GenerateNetworkMappings(ctx context.Context, service *configurations.Service, endpoints []*basev0.Endpoint, env *configurations.Environment) ([]*basev0.NetworkMapping, error)
GenerateNetworkMappings generates network mappings for a service endpoints
func (*DeployManager) GetNamespace ¶ added in v0.1.69
func (m *DeployManager) GetNamespace(_ context.Context, service *configurations.Service, env *configurations.Environment) (string, error)
func (*DeployManager) KubernetesService ¶ added in v0.1.73
func (m *DeployManager) KubernetesService(service *configurations.Service, endpoint *basev0.Endpoint, namespace string, port uint16) *basev0.NetworkInstance
type FixedStrategy ¶
type FixedStrategy struct {
}
type Manager ¶ added in v0.1.65
type Manager interface {
GenerateNetworkMappings(ctx context.Context, service *configurations.Service, endpoints []*basev0.Endpoint, env *configurations.Environment) ([]*basev0.NetworkMapping, error)
GetNamespace(ctx context.Context, service *configurations.Service, env *configurations.Environment) (string, error)
}
type RuntimeManager ¶
type RuntimeManager struct {
// contains filtered or unexported fields
}
func NewRuntimeManager ¶ added in v0.1.64
func NewRuntimeManager(_ context.Context, dnsManager DNSManager) (*RuntimeManager, error)
func (*RuntimeManager) GenerateNetworkMappings ¶
func (m *RuntimeManager) GenerateNetworkMappings(ctx context.Context, service *configurations.Service, endpoints []*basev0.Endpoint, _ *configurations.Environment) ([]*basev0.NetworkMapping, error)
GenerateNetworkMappings generates network mappings for a service endpoints
func (*RuntimeManager) GetNamespace ¶ added in v0.1.69
func (m *RuntimeManager) GetNamespace(context.Context, *configurations.Service, *configurations.Environment) (string, error)
func (*RuntimeManager) SetLoadBalancer ¶ added in v0.1.76
func (m *RuntimeManager) SetLoadBalancer(string)
Source Files
Click to show internal directories.
Click to hide internal directories.