network

package
v0.1.150 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2025 License: MIT Imports: 14 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 FixedStrategy 

type FixedStrategy struct {
}

type KubernetesService added in v0.1.65 

type KubernetesService struct {
	Namespace string
	Name      string
	Port      uint16
	*resources.ServiceIdentity
}

type Pairing added in v0.1.139 

type Pairing struct {
	Local  *basev0.NetworkMapping
	Remote *basev0.NetworkMapping
}

type RemoteManager added in v0.1.139 

type RemoteManager struct {
	// contains filtered or unexported fields
}

func NewRemoteManager added in v0.1.139 

func NewRemoteManager(_ context.Context, dnsManager DNSManager) (*RemoteManager, error)

func (*RemoteManager) Expose added in v0.1.139 

func (m *RemoteManager) Expose(ctx context.Context,
	env *resources.Environment,
	workspace *resources.Workspace,
	service *resources.ServiceIdentity,
	endpoints []*basev0.Endpoint,
	localNetworkMappings []*basev0.NetworkMapping,
	output wool.LogProcessorWithSource) error

func (*RemoteManager) GenerateNetworkMappings added in v0.1.139 

func (m *RemoteManager) 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 (*RemoteManager) GetKubernetesService added in v0.1.139 

func (m *RemoteManager) GetKubernetesService(ctx context.Context, identity *resources.ServiceIdentity, hostname string, port uint16) (*KubernetesService, error)

func (*RemoteManager) GetNamespace added in v0.1.139 

func (m *RemoteManager) GetNamespace(_ context.Context, env *resources.Environment, workspace *resources.Workspace, service *resources.ServiceIdentity) (string, error)

func (*RemoteManager) KubernetesService added in v0.1.139 

func (m *RemoteManager) KubernetesService(service *resources.ServiceIdentity, endpoint *basev0.Endpoint, namespace string, port uint16) *basev0.NetworkInstance

func (*RemoteManager) StartPairing added in v0.1.139 

func (m *RemoteManager) StartPairing(ctx context.Context, _ *resources.Environment, _ *resources.Workspace, service *resources.ServiceIdentity, pairing *Pairing, output wool.LogProcessorWithSource) 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) 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.