network

package
v0.1.134 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 28, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const Localhost = "localhost"

Variables

This section is empty.

Functions

func APIInt 

func APIInt(api string) int

func Container 

func Container(endpoint *basev0.Endpoint, port uint16) *basev0.NetworkInstance

func ContainerInstance added in v0.1.69 

func ContainerInstance(instance *basev0.NetworkInstance) *basev0.NetworkInstance

func DNS added in v0.1.69 

func DNS(_ *resources.ServiceIdentity, 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 GetPidUsingPort(port int) (string, error)

func HashInt 

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

func IsPortAvailable 

func IsPortAvailable(port int) bool

func KillProcess added in v0.1.64 

func KillProcess(pid string) error

func KillProcessUsingPort added in v0.1.64 

func KillProcessUsingPort(port int) error

func Native 

func Native(endpoint *basev0.Endpoint, port uint16) *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, ws, mod, svc, name, api string) uint16

Types

type DNSManager 

type DNSManager interface {
	GetDNS(ctx context.Context, svc *resources.ServiceIdentity, endpointName string) (*basev0.DNS, error)
}

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,
	env *resources.Environment,
	workspace *resources.Workspace,
	service *resources.ServiceIdentity,
	endpoints []*basev0.Endpoint) ([]*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, env *resources.Environment, workspace *resources.Workspace, service *resources.ServiceIdentity) (string, error)

func (*DeployManager) KubernetesService added in v0.1.73 

func (m *DeployManager) KubernetesService(service *resources.ServiceIdentity, 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, env *resources.Environment, workspace *resources.Workspace, service *resources.ServiceIdentity, endpoints []*basev0.Endpoint) ([]*basev0.NetworkMapping, error)
	GetNamespace(ctx context.Context, env *resources.Environment, workspace *resources.Workspace, service *resources.ServiceIdentity) (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,
	env *resources.Environment,
	workspace *resources.Workspace,
	service *resources.ServiceIdentity,
	endpoints []*basev0.Endpoint) ([]*basev0.NetworkMapping, error)

GenerateNetworkMappings generates network mappings for a service endpoints

func (*RuntimeManager) GetFreePort added in v0.1.89 

func (m *RuntimeManager) GetFreePort() uint16

GetFreePort returns the next free port after lastRandomPort

func (*RuntimeManager) GetNamespace added in v0.1.69 

func (m *RuntimeManager) GetNamespace(context.Context, *resources.Environment, *resources.Workspace, *resources.ServiceIdentity) (string, error)

func (*RuntimeManager) SetLoadBalancer added in v0.1.76 

func (m *RuntimeManager) SetLoadBalancer(string)

func (*RuntimeManager) WithTemporaryPorts added in v0.1.89 

func (m *RuntimeManager) WithTemporaryPorts()

WithTemporaryPorts will use random ports instead of "named" ports

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.