network

Jan 29, 2024

Changes in this version

+ func APIInt(api string) int

+ func GetAllLocalIPs() ([]string, error)

+ func HashInt(s string, low, high int) int

+ func ToPort(app string, svc string, api string) int

Jan 21, 2024

Changes in this version

+ func ExtractEndpointEnvironmentVariables(ctx context.Context, nets []*runtimev0.NetworkMapping) ([]string, error)

+ func ExtractRestRoutesEnvironmentVariables(ctx context.Context, nets []*runtimev0.NetworkMapping) ([]string, error)

Jan 18, 2024

Changes in this version

+ type MappingInstance struct

+ Address string

+ Port int

+ func Instance(mappings []*runtimev0.NetworkMapping) (*MappingInstance, error)

Jan 4, 2024

Changes in this version

+ func LocalizeMapping(mapping *runtimev1.NetworkMapping, local string) *runtimev1.NetworkMapping

+ func LocalizeMappings(nm []*runtimev1.NetworkMapping, local string) []*runtimev1.NetworkMapping

Dec 29, 2023

Changes in this version

+ func MappingAsString(mapping *runtimev1.NetworkMapping) string

+ type MappingSummary struct

+ Count int

+ Mappings []string

+ func MakeNetworkMappingSummary(mappings []*runtimev1.NetworkMapping) MappingSummary

Dec 15, 2023

Changes in this version

+ func ToDNS(e *basev1.Endpoint) string

type ServiceManager

+ func NewServiceDNSManager(ctx context.Context, identity *basev1.ServiceIdentity, ...) (*ServiceManager, error)

Nov 29, 2023

Changes in this version

+ func ToDns(e *basev1.Endpoint) string

Nov 25, 2023

Changes in this version

+ func ConvertToEnvironmentVariables(nets []*runtimev1.NetworkMapping) ([]string, error)

+ func GetFreePorts(n int) ([]int, error)

+ func ToEndpoint(endpoint *corev1.Endpoint) *configurations.Endpoint

+ func ToUnique(endpoint *corev1.Endpoint) string

+ type Address struct

+ Host string

+ Port int

+ type ApplicationEndpoint struct

+ Application string

+ Endpoint *corev1.Endpoint

+ Namespace string

+ PortBinding string

+ Service string

+ func (e ApplicationEndpoint) Clone() ApplicationEndpoint

+ func (e ApplicationEndpoint) Unique() string

+ type ApplicationEndpointInstance struct

+ ApplicationEndpoint ApplicationEndpoint

+ Host string

+ Port int

+ func (m *ApplicationEndpointInstance) Address() string

+ func (m *ApplicationEndpointInstance) Name() string

+ func (m *ApplicationEndpointInstance) StringPort() string

+ type ApplicationEndpointInstances struct

+ ApplicationEndpointInstances []*ApplicationEndpointInstance

+ func (pm *ApplicationEndpointInstances) Address(endpoint *corev1.Endpoint) *Address

+ func (pm *ApplicationEndpointInstances) First() *ApplicationEndpointInstance

+ type DNS struct

+ func (r DNS) Reserve(_ string, es []ApplicationEndpoint) (*ApplicationEndpointInstances, error)

+ type FixedStrategy struct

+ func (r FixedStrategy) Reserve(host string, endpoints []ApplicationEndpoint) (*ApplicationEndpointInstances, error)

+ type RandomStrategy struct

+ func (r RandomStrategy) Reserve(host string, endpoints []ApplicationEndpoint) (*ApplicationEndpointInstances, error)

+ type ServiceManager struct

+ func NewServiceDnsManager(ctx context.Context, identity *servicev1.ServiceIdentity, ...) (*ServiceManager, error)

+ func NewServiceManager(identity *servicev1.ServiceIdentity, endpoints ...*corev1.Endpoint) *ServiceManager

+ func NewServicePortManager(ctx context.Context, identity *servicev1.ServiceIdentity, ...) (*ServiceManager, error)

+ func (pm *ServiceManager) ApplicationEndpointInstance(endpoint *corev1.Endpoint) (*ApplicationEndpointInstance, error)

+ func (pm *ServiceManager) ApplicationEndpointInstances() []*ApplicationEndpointInstance

+ func (pm *ServiceManager) Bind(endpoint *corev1.Endpoint, portBinding string) error

+ func (pm *ServiceManager) Expose(endpoint *corev1.Endpoint) error

+ func (pm *ServiceManager) NetworkMapping() ([]*runtimev1.NetworkMapping, error)

+ func (pm *ServiceManager) Port(endpoint *corev1.Endpoint) (int, error)

+ func (pm *ServiceManager) Reserve() error

+ type Strategy interface

+ Reserve func(host string, endpoints []ApplicationEndpoint) (*ApplicationEndpointInstances, error)