shadow

package

v0.0.0-...-7949e55 Latest Latest Go to latest Published: Jun 30, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gernest/meshd

Links

Open Source Insights

Documentation ¶

Index ¶

func BuildUnresolvablePort() corev1.ServicePort
func Name(namespace, name string) (string, error)
type Manager
type PortMapper
type PortStateTable

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BuildUnresolvablePort ¶

func BuildUnresolvablePort() corev1.ServicePort

BuildUnresolvablePort builds a service port with a fake port. This fake port can be used as a placeholder when a service doesn't have any compatible ports.

func Name ¶

func Name(namespace, name string) (string, error)

Name returns the shadow service name corresponding to the given service namespace and name.

Types ¶

func (*Manager) CleanupShadowServicePorts ¶

func (s *Manager) CleanupShadowServicePorts(log logr.Logger, svc, shadowSvc *corev1.Service, trafficType string)

CleanupShadowServicePorts unmap ports that have changed since the last update of the service.

func (*Manager) GetServicePorts ¶

func (s *Manager) GetServicePorts(log logr.Logger, svc *corev1.Service, trafficType string) []corev1.ServicePort

GetServicePorts returns the ports of the given user service, mapped with port opened on the proxy.

func (*Manager) LoadPortMapping ¶

func (s *Manager) LoadPortMapping(log logr.Logger, shadowSvcs []*corev1.Service) error

LoadPortMapping loads the port mapping of existing shadow services into the different port mappers.

func (*Manager) LoadShadowServicePorts ¶

func (s *Manager) LoadShadowServicePorts(log logr.Logger, shadowSvc *corev1.Service, trafficType string)

LoadShadowServicePorts loads the port mapping of the given shadow service into the different port mappers.

func (*Manager) UnmapPort ¶

func (s *Manager) UnmapPort(log logr.Logger, namespace, name, trafficType string, port int32) error

UnmapPort releases the port on the proxy associated with the given port. This released port can then be remapped later on. Port releasing is delegated to the different port mappers, following the given traffic type.

type PortMapper ¶

type PortMapper interface {
	Find(namespace, name string, port int32) (int32, bool)
	Add(namespace, name string, port int32) (int32, error)
	Set(namespace, name string, port, targetPort int32) error
	Remove(namespace, name string, port int32) (int32, bool)
}

PortMapper is capable of storing and retrieving a port mapping for a given service.

type PortStateTable ¶

type PortStateTable struct {
	TCP PortMapper
	UDP PortMapper
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL