kube

Apr 7, 2023

Changes in this version

+ func ReadNetworkPoliciesFromKube(kubeClient *Kubernetes, namespaces []string) ([]*networkingv1.NetworkPolicy, error)

+ func ReadNetworkPoliciesFromPath(policyPath string) ([]*networkingv1.NetworkPolicy, error)

+ func RunReadNetworkPolicyTests()

Jul 12, 2022

Changes in this version

+ const DefaultNamespaceLabel

May 22, 2021

Changes in this version

type IKubernetes

+ GetAllNamespaces func() (*v1.NamespaceList, error)

type MockKubernetes

+ func (m *MockKubernetes) GetAllNamespaces() (*v1.NamespaceList, error)

Apr 25, 2021

Changes in this version

+ func IsIPV4Address(s string) bool

+ func MakeCIDRFromOnes(ipString string, ones int) string

+ func MakeCIDRFromZeroes(ipString string, zeroes int) string

Apr 14, 2021

Changes in this version

+ func MakeIPV4CIDR(ipString string, bits int) string

Mar 23, 2021

Changes in this version

+ func DeleteAllNetworkPoliciesInNamespaces(kubernetes IKubernetes, namespaces []string) error

+ func GetNetworkPoliciesInNamespaces(kubernetes IKubernetes, namespaces []string) ([]networkingv1.NetworkPolicy, error)

+ func GetPodsInNamespaces(kubernetes IKubernetes, namespaces []string) ([]v1.Pod, error)

+ func GetServicesInNamespaces(kubernetes IKubernetes, namespaces []string) ([]v1.Service, error)

+ func NetworkPoliciesToTable(policies []*NetworkPolicy) string

+ func PrintIPBlock(i IPBlock) string

+ func PrintNSPodPeer(nsSelector *metav1.LabelSelector, podSelector *metav1.LabelSelector) string

+ func PrintPeers(npPeers []NetworkPolicyPeer) string

+ func PrintPorts(npPorts []NetworkPolicyPort) string

type IKubernetes

+ GetNetworkPoliciesInNamespace func(namespace string) ([]networkingv1.NetworkPolicy, error)

+ GetPodsInNamespace func(namespace string) ([]v1.Pod, error)

+ GetServicesInNamespace func(namespace string) ([]v1.Service, error)

type Kubernetes

+ func (k *Kubernetes) GetNetworkPoliciesInNamespace(namespace string) ([]networkingv1.NetworkPolicy, error)

+ func (k *Kubernetes) GetPodsInNamespace(namespace string) ([]v1.Pod, error)

+ func (k *Kubernetes) GetServicesInNamespace(namespace string) ([]v1.Service, error)

type MockKubernetes

+ func (m *MockKubernetes) GetNetworkPoliciesInNamespace(namespace string) ([]networkingv1.NetworkPolicy, error)

+ func (m *MockKubernetes) GetPodsInNamespace(namespace string) ([]v1.Pod, error)

+ func (m *MockKubernetes) GetServicesInNamespace(namespace string) ([]v1.Service, error)

Mar 4, 2021

Changes in this version

type Kubernetes

+ func (k *Kubernetes) GetAllNamespaces() (*v1.NamespaceList, error)

Mar 3, 2021

Changes in this version

+ type IKubernetes interface

+ CreateNamespace func(ns *v1.Namespace) (*v1.Namespace, error)

+ CreateNetworkPolicy func(policy *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

+ CreatePod func(pod *v1.Pod) (*v1.Pod, error)

+ CreateService func(svc *v1.Service) (*v1.Service, error)

+ DeleteAllNetworkPoliciesInNamespace func(ns string) error

+ DeleteAllNetworkPoliciesInNamespaces func(nss []string) error

+ DeleteNamespace func(ns string) error

+ DeleteNetworkPolicy func(ns string, name string) error

+ DeletePod func(namespace string, podName string) error

+ DeleteService func(namespace string, name string) error

+ ExecuteRemoteCommand func(namespace string, pod string, container string, command []string) (string, string, error, error)

+ GetNamespace func(namespace string) (*v1.Namespace, error)

+ GetNetworkPoliciesInNamespaces func(namespaces []string) ([]networkingv1.NetworkPolicy, error)

+ GetPod func(namespace string, podName string) (*v1.Pod, error)

+ GetPodsInNamespaces func(namespaces []string) ([]v1.Pod, error)

+ GetService func(namespace string, name string) (*v1.Service, error)

+ SetNamespaceLabels func(namespace string, labels map[string]string) (*v1.Namespace, error)

+ SetPodLabels func(namespace string, podName string, labels map[string]string) (*v1.Pod, error)

+ UpdateNetworkPolicy func(policy *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

type Kubernetes

+ func (k *Kubernetes) CreateNamespace(ns *v1.Namespace) (*v1.Namespace, error)

+ type MockKubernetes struct

+ Namespaces map[string]*MockNamespace

+ func NewMockKubernetes(passRate float64) *MockKubernetes

+ func (m *MockKubernetes) CreateNamespace(ns *v1.Namespace) (*v1.Namespace, error)

+ func (m *MockKubernetes) CreateNetworkPolicy(policy *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

+ func (m *MockKubernetes) CreatePod(pod *v1.Pod) (*v1.Pod, error)

+ func (m *MockKubernetes) CreateService(svc *v1.Service) (*v1.Service, error)

+ func (m *MockKubernetes) DeleteAllNetworkPoliciesInNamespace(ns string) error

+ func (m *MockKubernetes) DeleteAllNetworkPoliciesInNamespaces(nss []string) error

+ func (m *MockKubernetes) DeleteNamespace(ns string) error

+ func (m *MockKubernetes) DeleteNetworkPolicy(ns string, name string) error

+ func (m *MockKubernetes) DeletePod(namespace string, podName string) error

+ func (m *MockKubernetes) DeleteService(namespace string, name string) error

+ func (m *MockKubernetes) ExecuteRemoteCommand(namespace string, pod string, container string, command []string) (string, string, error, error)

+ func (m *MockKubernetes) GetNamespace(namespace string) (*v1.Namespace, error)

+ func (m *MockKubernetes) GetNetworkPoliciesInNamespaces(namespaces []string) ([]networkingv1.NetworkPolicy, error)

+ func (m *MockKubernetes) GetPod(namespace string, podName string) (*v1.Pod, error)

+ func (m *MockKubernetes) GetPodsInNamespaces(namespaces []string) ([]v1.Pod, error)

+ func (m *MockKubernetes) GetService(namespace string, name string) (*v1.Service, error)

+ func (m *MockKubernetes) SetNamespaceLabels(namespace string, labels map[string]string) (*v1.Namespace, error)

+ func (m *MockKubernetes) SetPodLabels(namespace string, podName string, labels map[string]string) (*v1.Pod, error)

+ func (m *MockKubernetes) UpdateNetworkPolicy(policy *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

+ type MockNamespace struct

+ NamespaceObject *v1.Namespace

+ Netpols map[string]*networkingv1.NetworkPolicy

+ Pods map[string]*v1.Pod

+ Services map[string]*v1.Service

Feb 27, 2021

Changes in this version

+ func RunLabelSelectorTests()

type Kubernetes

+ func (k *Kubernetes) DeletePod(namespace string, podName string) error

+ func (k *Kubernetes) DeleteService(namespace string, name string) error

Feb 8, 2021

Changes in this version

+ func LabelSelectorTableLines(selector metav1.LabelSelector) string

Jan 31, 2021

Changes in this version

type Kubernetes

+ func (k *Kubernetes) DeleteNamespace(ns string) error

Jan 30, 2021

Changes in this version

+ func ParseProtocol(protocol string) (v1.Protocol, error)

type Kubernetes

+ func (k *Kubernetes) DeleteNetworkPolicy(ns string, name string) error

+ func (k *Kubernetes) GetNamespace(namespace string) (*v1.Namespace, error)

+ func (k *Kubernetes) GetService(namespace string, name string) (*v1.Service, error)

+ func (k *Kubernetes) SetNamespaceLabels(namespace string, labels map[string]string) (*v1.Namespace, error)

+ func (k *Kubernetes) SetPodLabels(namespace string, podName string, labels map[string]string) (*v1.Pod, error)

+ func (k *Kubernetes) UpdateNetworkPolicy(policy *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

Jan 24, 2021

Changes in this version

+ func IsLabelSelectorEmpty(l metav1.LabelSelector) bool

+ func RunIPAddressTests()

+ func SerializeLabelSelector(ls metav1.LabelSelector) string

Jan 20, 2021

Changes in this version

+ func PathToKubeConfig() string

type Kubernetes

+ RestConfig *rest.Config

+ func NewKubernetesForContext(context string) (*Kubernetes, error)

+ func NewKubernetesForDefaultContext() (*Kubernetes, error)

+ func (k *Kubernetes) GetNetworkPoliciesInNamespaces(namespaces []string) ([]networkingv1.NetworkPolicy, error)

Jan 18, 2021

Changes in this version

+ func Clientset() (*kubernetes.Clientset, error)

+ func IsIPAddressMatchForIPBlock(ip string, ipBlock *v1.IPBlock) (bool, error)

+ func IsIPInCIDR(ip string, cidr string) (bool, error)

+ func IsLabelsMatchLabelSelector(labels map[string]string, labelSelector metav1.LabelSelector) bool

+ func IsMatchExpressionMatchForLabels(labels map[string]string, exp metav1.LabelSelectorRequirement) bool

+ func IsNameMatch(objectName string, matcher string) bool

+ func QualifiedServiceAddress(ns string, service string) string

+ func RunMatchersTests()

+ type Kubernetes struct

+ ClientSet *kubernetes.Clientset

+ func NewKubernetes() (*Kubernetes, error)

+ func (k *Kubernetes) CreateDaemonSet(namespace string, ds *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

+ func (k *Kubernetes) CreateDaemonSetIfNotExists(namespace string, ds *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

+ func (k *Kubernetes) CreateNetworkPolicy(netpol *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

+ func (k *Kubernetes) CreateOrUpdateNamespace(ns *v1.Namespace) (*v1.Namespace, error)

+ func (k *Kubernetes) CreateOrUpdateNetworkPolicy(ns string, netpol *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error)

+ func (k *Kubernetes) CreateOrUpdateService(svc *v1.Service) (*v1.Service, error)

+ func (k *Kubernetes) CreatePod(pod *v1.Pod) (*v1.Pod, error)

+ func (k *Kubernetes) CreatePodIfNotExists(pod *v1.Pod) (*v1.Pod, error)

+ func (k *Kubernetes) CreateService(svc *v1.Service) (*v1.Service, error)

+ func (k *Kubernetes) CreateServiceIfNotExists(svc *v1.Service) (*v1.Service, error)

+ func (k *Kubernetes) DeleteAllNetworkPoliciesInNamespace(ns string) error

+ func (k *Kubernetes) DeleteAllNetworkPoliciesInNamespaces(nss []string) error

+ func (k *Kubernetes) ExecuteRemoteCommand(namespace string, pod string, container string, command []string) (string, string, error, error)

+ func (k *Kubernetes) GetPod(namespace string, pod string) (*v1.Pod, error)

+ func (k *Kubernetes) GetPodsInNamespaces(namespaces []string) ([]v1.Pod, error)