common

package

v1.15.22 Latest Latest Go to latest Published: Feb 12, 2024 License: MIT Imports: 7 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/Azure/azure-container-networking

Documentation ¶

Index ¶

Variables
func GetContainerPortList(podObj *corev1.Pod) []corev1.ContainerPort
func IsSystemNs(nsObj *corev1.Namespace) bool
type Cache
type GenericCache
type Input
type InputType
- func GetInputType(input string) InputType
type LabelAppendOperation
type Namespace
- func NewNs(name string) *Namespace
type NpmPod
- func NewNpmPod(podObj *corev1.Pod) *NpmPod

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrSetNotExist      = errors.New("set does not exists")
	ErrInvalidIPAddress = errors.New("invalid ipaddress, no equivalent pod found")
	ErrInvalidInput     = errors.New("invalid input")
	ErrSetType          = errors.New("invalid set type")
)

error type

Functions ¶

func GetContainerPortList ¶

func GetContainerPortList(podObj *corev1.Pod) []corev1.ContainerPort

func IsSystemNs ¶

func IsSystemNs(nsObj *corev1.Namespace) bool

Types ¶

type Cache ¶

type Cache struct {
	NodeName string
	NsMap    map[string]*Namespace
	PodMap   map[string]*NpmPod
	SetMap   map[string]string
	ListMap  map[string]string // not used in NPMV2
}

func (*Cache) GetListMap ¶

func (c *Cache) GetListMap() map[string]string

func (*Cache) GetNamespaceLabel ¶

func (c *Cache) GetNamespaceLabel(namespace, labelkey string) string

func (*Cache) GetPod ¶

func (c *Cache) GetPod(input *Input) (*NpmPod, error)

func (*Cache) GetSetMap ¶

func (c *Cache) GetSetMap() map[string]string

type GenericCache ¶

type GenericCache interface {
	GetPod(*Input) (*NpmPod, error)
	GetNamespaceLabel(namespace string, key string) string
	GetListMap() map[string]string
	GetSetMap() map[string]string
}

type Input ¶

type Input struct {
	Content string
	Type    InputType
}

type InputType ¶

type InputType int32

InputType indicates allowed typle for source and destination input

const (
	// IPADDRS indicates the IP Address input type, example: 10.0.0.1
	IPADDRS InputType = 0
	// NSPODNAME indicates the podname input type, example: x/a
	NSPODNAME InputType = 1
	// EXTERNAL indicates the external input type
	EXTERNAL InputType = 2
)

func GetInputType ¶

func GetInputType(input string) InputType

GetInputType returns the type of the input for GetNetworkTuple.

type LabelAppendOperation ¶

type LabelAppendOperation bool

const (
	ClearExistingLabels    LabelAppendOperation = true
	AppendToExistingLabels LabelAppendOperation = false
)

type Namespace ¶

type Namespace struct {
	Name      string
	LabelsMap map[string]string // Namespace labels
}

func NewNs ¶

func NewNs(name string) *Namespace

newNS constructs a new namespace object.

func (*Namespace) AppendLabels ¶

func (nsObj *Namespace) AppendLabels(newm map[string]string, clear LabelAppendOperation)

func (*Namespace) GetNamespaceObjFromNsObj ¶

func (nsObj *Namespace) GetNamespaceObjFromNsObj() *corev1.Namespace

func (*Namespace) RemoveLabelsWithKey ¶

func (nsObj *Namespace) RemoveLabelsWithKey(key string)

type NpmPod ¶

type NpmPod struct {
	Name           string
	Namespace      string
	PodIP          string
	Labels         map[string]string
	ContainerPorts []corev1.ContainerPort
	Phase          corev1.PodPhase
}

func NewNpmPod ¶

func NewNpmPod(podObj *corev1.Pod) *NpmPod

func (*NpmPod) AppendContainerPorts ¶

func (n *NpmPod) AppendContainerPorts(podObj *corev1.Pod)

func (*NpmPod) AppendLabels ¶

func (n *NpmPod) AppendLabels(newPod map[string]string, clear LabelAppendOperation)

func (*NpmPod) IP ¶

func (n *NpmPod) IP() string

func (*NpmPod) NamespaceString ¶

func (n *NpmPod) NamespaceString() string

func (*NpmPod) NoUpdate ¶

func (n *NpmPod) NoUpdate(podObj *corev1.Pod) bool

noUpdate evaluates whether NpmPod is required to be update given podObj.

func (*NpmPod) RemoveContainerPorts ¶

func (n *NpmPod) RemoveContainerPorts()

func (*NpmPod) RemoveLabelsWithKey ¶

func (n *NpmPod) RemoveLabelsWithKey(key string)

func (*NpmPod) UpdateNpmPodAttributes ¶

func (n *NpmPod) UpdateNpmPodAttributes(podObj *corev1.Pod)

This function can be expanded to other attribs if needed

Source Files ¶

View all Source files

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