util

Documentation

Overview

Copyright 2018 Microsoft. All rights reserved. MIT License

Copyright 2018 Microsoft. All rights reserved. MIT License

Index

• Constants
• Variables
• func AppendMap(base, new map[string]string) map[string]string
• func CompareK8sVer(firstVer *version.Info, secondVer *version.Info) int
• func Exists(filePath string) bool
• func GetClusterID(nodeName string) string
• func GetHashedName(name string) string
• func GetNsIpsetName(k, v string) string
• func Hash(s string) string
• func IsNewNwPolicyVer(ver *version.Info) (bool, error)
• func SetIsNewNwPolicyVerFlag(ver *version.Info) error
• func UniqueStrSlice(s []string) []string

Constants

const (
	KubeSystemFlag             string = "kube-system"
	KubePodTemplateHashFlag    string = "pod-template-hash"
	KubeAllPodsFlag            string = "all-pod"
	KubeAllNamespacesFlag      string = "all-namespace"
	KubeAppFlag                string = "k8s-app"
	KubeProxyFlag              string = "kube-proxy"
	KubePodStatusFailedFlag    string = "Failed"
	KubePodStatusSucceededFlag string = "Succeeded"
	KubePodStatusUnknownFlag   string = "Unknown"
)

kubernetes related constants.

const (
	Iptables                         string = "iptables"
	Ip6tables                        string = "ip6tables"
	IptablesSave                     string = "iptables-save"
	IptablesRestore                  string = "iptables-restore"
	IptablesConfigFile               string = "/var/log/iptables.conf"
	IptablesTestConfigFile           string = "/var/log/iptables-test.conf"
	IptablesLockFile                 string = "/run/xtables.lock"
	IptablesChainCreationFlag        string = "-N"
	IptablesInsertionFlag            string = "-I"
	IptablesAppendFlag               string = "-A"
	IptablesDeletionFlag             string = "-D"
	IptablesFlushFlag                string = "-F"
	IptablesCheckFlag                string = "-C"
	IptablesDestroyFlag              string = "-X"
	IptablesJumpFlag                 string = "-j"
	IptablesWaitFlag                 string = "-w"
	IptablesAccept                   string = "ACCEPT"
	IptablesReject                   string = "REJECT"
	IptablesDrop                     string = "DROP"
	IptablesSrcFlag                  string = "src"
	IptablesDstFlag                  string = "dst"
	IptablesProtFlag                 string = "-p"
	IptablesSFlag                    string = "-s"
	IptablesDFlag                    string = "-d"
	IptablesDstPortFlag              string = "--dport"
	IptablesMatchFlag                string = "-m"
	IptablesSetFlag                  string = "set"
	IptablesMatchSetFlag             string = "--match-set"
	IptablesStateFlag                string = "state"
	IptablesMatchStateFlag           string = "--state"
	IptablesMultiportFlag            string = "multiport"
	IptablesMultiDestportFlag        string = "--dports"
	IptablesRelatedState             string = "RELATED"
	IptablesEstablishedState         string = "ESTABLISHED"
	IptablesFilterTable              string = "filter"
	IptablesAzureChain               string = "AZURE-NPM"
	IptablesAzureIngressPortChain    string = "AZURE-NPM-INGRESS-PORT"
	IptablesAzureIngressFromChain    string = "AZURE-NPM-INGRESS-FROM"
	IptablesAzureIngressFromNsChain  string = "AZURE-NPM-INGRESS-FROM-NS"
	IptablesAzureIngressFromPodChain string = "AZURE-NPM-INGRESS-FROM-POD"
	IptablesAzureEgressPortChain     string = "AZURE-NPM-EGRESS-PORT"
	IptablesAzureEgressToChain       string = "AZURE-NPM-EGRESS-TO"
	IptablesAzureEgressToNsChain     string = "AZURE-NPM-EGRESS-TO-NS"
	IptablesAzureEgressToPodChain    string = "AZURE-NPM-EGRESS-TO-POD"
	IptablesAzureTargetSetsChain     string = "AZURE-NPM-TARGET-SETS"
	IptablesForwardChain             string = "FORWARD"
	IptablesInputChain               string = "INPUT"
)

iptables related constants.

const (
	Ipset               string = "ipset"
	IpsetSaveFlag       string = "save"
	IpsetRestoreFlag    string = "restore"
	IpsetConfigFile     string = "/var/log/ipset.conf"
	IpsetTestConfigFile string = "/var/log/ipset-test.conf"
	IpsetCreationFlag   string = "-N"
	IpsetAppendFlag     string = "-A"
	IpsetDeletionFlag   string = "-D"
	IpsetFlushFlag      string = "-F"
	IpsetDestroyFlag    string = "-X"

	IpsetExistFlag string = "-exist"
	IpsetFileFlag  string = "-file"

	IpsetSetListFlag string = "setlist"
	IpsetNetHashFlag string = "nethash"

	AzureNpmFlag   string = "azure-npm"
	AzureNpmPrefix string = "azure-npm-"
)

ipset related constants.

const (
	AddNamespaceEvent    string = "Add Namespace"
	UpdateNamespaceEvent string = "Update Namespace"
	DeleteNamespaceEvent string = "Delete Namespace"

	AddPodEvent    string = "Add Pod"
	UpdatePodEvent string = "Update Pod"
	DeletePodEvent string = "Delete Pod"

	AddNetworkPolicyEvent    string = "Add network policy"
	UpdateNetworkPolicyEvent string = "Update network policy"
	DeleteNetworkPolicyEvent string = "Delete network policy"
)

NPM telemetry constants.

Variables

var IsNewNwPolicyVerFlag = false

IsNewNwPolicyVerFlag indicates if the current kubernetes version is newer than 1.11 or not

Functions

func AppendMap

func AppendMap(base, new map[string]string) map[string]string

AppendMap appends new to base.

func CompareK8sVer

func CompareK8sVer(firstVer *version.Info, secondVer *version.Info) int

CompareK8sVer compares two k8s versions. returns -1, 0, 1 if firstVer smaller, equals, bigger than secondVer respectively. returns -2 for error.

func Exists

func Exists(filePath string) bool

Exists reports whether the named file or directory exists.

func GetClusterID

func GetClusterID(nodeName string) string

GetClusterID retrieves cluster ID through node name. (Azure-specific)

func GetHashedName

func GetHashedName(name string) string

GetHashedName returns hashed ipset name.

func GetNsIpsetName

func GetNsIpsetName(k, v string) string

GetNsIpsetName returns ipset name from namespaceSelector.

func Hash

func Hash(s string) string

Hash hashes a string to another string with length <= 32.

func IsNewNwPolicyVer

func IsNewNwPolicyVer(ver *version.Info) (bool, error)

IsNewNwPolicyVer checks if the current k8s version >= 1.11, if so, then the networkPolicy should support 'AND' between namespaceSelector & podSelector.

func SetIsNewNwPolicyVerFlag

func SetIsNewNwPolicyVerFlag(ver *version.Info) error

SetIsNewNwPolicyVerFlag sets IsNewNwPolicyVerFlag variable depending on version.

func UniqueStrSlice

func UniqueStrSlice(s []string) []string

UniqueStrSlice removes duplicate elements from the input string.