k8sinterface

Sep 13, 2021

Changes in this version

+ var ConnectedToCluster = true

+ func GetClusterName() string

+ func GetDefaultNamespace() string

+ func IsConnectedToCluster() bool

Sep 9, 2021

Changes in this version

+ var K8SCmdConfig clientcmd.ClientConfig

Aug 31, 2021

Changes in this version

+ const ValueNotFound

+ var GroupsClusterScope = []string

+ var K8SConfig *restclient.Config

+ var ResourceClusterScope = []string

+ var ResourceGroupMapping = map[string]string

+ var RunningIncluster bool

+ func CheckIsACRImage(imageTag string) bool

+ func CheckIsECRImage(imageTag string) bool

+ func CheckIsGCRImage(imageTag string) bool

+ func ConvertUnstructuredSliceToMap(unstructuredSlice []unstructured.Unstructured) []map[string]interface

+ func FilterOutOwneredResources(result []unstructured.Unstructured) []unstructured.Unstructured

+ func GetCloudVendorRegistryCredentials(imageTag string) (map[string]types.AuthConfig, error)

+ func GetGroupVersionResource(resource string) (schema.GroupVersionResource, error)

+ func GetK8sConfig() *restclient.Config

+ func GetLoginDetailsForAzurCR(imageTag string) (string, string, error)

+ func GetLoginDetailsForECR(imageTag string) (string, string, error)

+ func GetLoginDetailsForGCR(imageTag string) (string, string, error)

+ func GetResourceTriplets(group, version, resource string) []string

+ func InspectWorkload(workload interface{}, scopes ...string) (val interface{}, k bool)

+ func IsAgentCompatibleAnnotation(annotations map[string]string) *bool

+ func IsAgentCompatibleLabel(labels map[string]string) *bool

+ func IsAttached(labels map[string]string) *bool

+ func IsLabel(labels map[string]string, key string) *bool

+ func IsNamespaceScope(apiGroup, resource string) bool

+ func IsStringInSlice(slice []string, val string) bool

+ func JoinResourceTriplets(group, version, resource string) string

+ func LoadK8sConfig() error

+ func PodMetadata(kind string) []string

+ func PodSpec(kind string) []string

+ func ResourceGroupToString(group, version, resource string) []string

+ func SelectorToString(ls labels.Set) string

+ func SetAgentCompatibleAnnotation(annotations map[string]string, val bool)

+ func SetAgentCompatibleLabel(labels map[string]string, val bool)

+ func SetLabel(labels map[string]string, key string, val bool)

+ func StringInSlice(strSlice []string, str string) int

+ func StringToResourceGroup(str string) (string, string, string)

+ func V1AllClusterWithCompromisedRegistriesMock() *unstructured.UnstructuredList

+ func V1KubeSystemNamespaceMock() *unstructured.UnstructuredList

+ type IBasicWorkload interface

+ GetAnnotation func(string) (string, bool)

+ GetAnnotations func() map[string]string

+ GetApiVersion func() string

+ GetContainers func() ([]corev1.Container, error)

+ GetGenerateName func() string

+ GetImagePullSecret func() ([]corev1.LocalObjectReference, error)

+ GetInitContainers func() ([]corev1.Container, error)

+ GetInnerAnnotation func(string) (string, bool)

+ GetInnerAnnotations func() map[string]string

+ GetInnerLabels func() map[string]string

+ GetKind func() string

+ GetLabel func(string) (string, bool)

+ GetLabels func() map[string]string

+ GetName func() string

+ GetNamespace func() string

+ GetOwnerReferences func() ([]metav1.OwnerReference, error)

+ GetPodAnnotation func(string) (string, bool)

+ GetPodAnnotations func() map[string]string

+ GetPodLabels func() map[string]string

+ GetPodSpec func() (*corev1.PodSpec, error)

+ GetReplicas func() int

+ GetResourceVersion func() string

+ GetSelector func() (*metav1.LabelSelector, error)

+ GetServiceAccountName func() string

+ GetUID func() string

+ GetVolumes func() ([]corev1.Volume, error)

+ GetWorkload func() map[string]interface{}

+ RemoveAnnotation func(string)

+ RemoveLabel func(string)

+ RemovePodStatus func()

+ RemoveResourceVersion func()

+ SetAnnotation func(key, value string)

+ SetKind func(string)

+ SetLabel func(key, value string)

+ SetName func(string)

+ SetNamespace func(string)

+ SetWorkload func(map[string]interface{})

+ type IWorkload interface

+ GetGroup func() string

+ GetJobID func() *apis.JobTracking

+ GetVersion func() string

+ GetWlid func() string

+ IsAttached func() bool

+ IsCompatible func() bool

+ IsIgnore func() bool

+ IsIncompatible func() bool

+ IsInject func() bool

+ Json func() string

+ RemoveArmoAnnotations func()

+ RemoveArmoLabels func()

+ RemoveArmoMetadata func()

+ RemoveCompatible func()

+ RemoveIgnore func()

+ RemoveInject func()

+ RemoveJobID func()

+ RemoveSecretData func()

+ RemoveUpdateTime func()

+ RemoveWlid func()

+ SetCompatible func()

+ SetIgnore func()

+ SetIncompatible func()

+ SetInject func()

+ SetJobID func(apis.JobTracking)

+ SetReplaceheaders func()

+ SetUpdateTime func()

+ SetWlid func(string)

+ ToString func() string

+ ToUnstructured func() (*unstructured.Unstructured, error)

+ type KubernetesApi struct

+ Context context.Context

+ DynamicClient dynamic.Interface

+ KubernetesClient kubernetes.Interface

+ func NewKubernetesApi() *KubernetesApi

+ func (k8sAPI *KubernetesApi) CalculateWorkloadParentRecursive(workload *Workload) (string, string, error)

+ func (k8sAPI *KubernetesApi) CreateWorkload(workload *Workload) (*Workload, error)

+ func (k8sAPI *KubernetesApi) DeleteWorkloadByWlid(wlid string) error

+ func (k8sAPI *KubernetesApi) GetNamespace(ns string) (*Workload, error)

+ func (k8sAPI *KubernetesApi) GetWorkload(namespace, kind, name string) (*Workload, error)

+ func (k8sAPI *KubernetesApi) GetWorkloadByWlid(wlid string) (*Workload, error)

+ func (k8sAPI *KubernetesApi) ListAttachedPods(namespace string) ([]corev1.Pod, error)

+ func (k8sAPI *KubernetesApi) ListPods(namespace string, podLabels map[string]string) ([]corev1.Pod, error)

+ func (k8sAPI *KubernetesApi) ListWorkloads(groupVersionResource *schema.GroupVersionResource, namespace string, ...) ([]Workload, error)

+ func (k8sAPI *KubernetesApi) ResourceInterface(resource *schema.GroupVersionResource, namespace string) dynamic.ResourceInterface

+ func (k8sAPI *KubernetesApi) UpdateWorkload(workload *Workload) (*Workload, error)

+ type Workload struct

+ func NewWorkload(bWorkload []byte) (*Workload, error)

+ func NewWorkloadObj(workload map[string]interface{}) *Workload

+ func (w *Workload) GetAnnotation(annotation string) (string, bool)

+ func (w *Workload) GetAnnotations() map[string]string

+ func (w *Workload) GetApiVersion() string

+ func (w *Workload) GetContainers() ([]corev1.Container, error)

+ func (w *Workload) GetGenerateName() string

+ func (w *Workload) GetGroup() string

+ func (w *Workload) GetImagePullSecret() ([]corev1.LocalObjectReference, error)

+ func (w *Workload) GetInitContainers() ([]corev1.Container, error)

+ func (w *Workload) GetInnerAnnotation(annotation string) (string, bool)

+ func (w *Workload) GetInnerAnnotations() map[string]string

+ func (w *Workload) GetInnerLabels() map[string]string

+ func (w *Workload) GetJobID() *apis.JobTracking

+ func (w *Workload) GetKind() string

+ func (w *Workload) GetLabel(label string) (string, bool)

+ func (w *Workload) GetLabels() map[string]string

+ func (w *Workload) GetName() string

+ func (w *Workload) GetNamespace() string

+ func (w *Workload) GetOwnerReferences() ([]metav1.OwnerReference, error)

+ func (w *Workload) GetPodAnnotation(annotation string) (string, bool)

+ func (w *Workload) GetPodAnnotations() map[string]string

+ func (w *Workload) GetPodLabel(label string) (string, bool)

+ func (w *Workload) GetPodLabels() map[string]string

+ func (w *Workload) GetPodSpec() (*corev1.PodSpec, error)

+ func (w *Workload) GetReplicas() int

+ func (w *Workload) GetResourceVersion() string

+ func (w *Workload) GetSelector() (*metav1.LabelSelector, error)

+ func (w *Workload) GetServiceAccountName() string

+ func (w *Workload) GetUID() string

+ func (w *Workload) GetVersion() string

+ func (w *Workload) GetVolumes() ([]corev1.Volume, error)

+ func (w *Workload) GetWlid() string

+ func (w *Workload) GetWorkload() map[string]interface{}

+ func (w *Workload) IsAttached() bool

+ func (w *Workload) IsCompatible() bool

+ func (w *Workload) IsIgnore() bool

+ func (w *Workload) IsIncompatible() bool

+ func (w *Workload) IsInject() bool

+ func (w *Workload) IsReplaceheaders() bool

+ func (w *Workload) Json() string

+ func (w *Workload) RemoveAnnotation(key string)

+ func (w *Workload) RemoveArmoAnnotations()

+ func (w *Workload) RemoveArmoLabels()

+ func (w *Workload) RemoveArmoMetadata()

+ func (w *Workload) RemoveCompatible()

+ func (w *Workload) RemoveIgnore()

+ func (w *Workload) RemoveInject()

+ func (w *Workload) RemoveJobID()

+ func (w *Workload) RemoveLabel(key string)

+ func (w *Workload) RemoveMetadata(scope []string, metadata, key string)

+ func (w *Workload) RemovePodAnnotation(key string)

+ func (w *Workload) RemovePodLabel(key string)

+ func (w *Workload) RemovePodStatus()

+ func (w *Workload) RemoveResourceVersion()

+ func (w *Workload) RemoveSecretData()

+ func (w *Workload) RemoveUpdateTime()

+ func (w *Workload) RemoveWlid()

+ func (w *Workload) SetAnnotation(key, value string)

+ func (w *Workload) SetCompatible()

+ func (w *Workload) SetIgnore()

+ func (w *Workload) SetIncompatible()

+ func (w *Workload) SetInject()

+ func (w *Workload) SetJobID(jobTracking apis.JobTracking)

+ func (w *Workload) SetKind(kind string)

+ func (w *Workload) SetLabel(key, value string)

+ func (w *Workload) SetMetadata(scope []string, key string, val interface{})

+ func (w *Workload) SetName(name string)

+ func (w *Workload) SetNamespace(namespace string)

+ func (w *Workload) SetPodAnnotation(key, value string)

+ func (w *Workload) SetPodLabel(key, value string)

+ func (w *Workload) SetReplaceheaders()

+ func (w *Workload) SetUpdateTime()

+ func (w *Workload) SetWlid(wlid string)

+ func (w *Workload) SetWorkload(workload map[string]interface{})

+ func (w *Workload) ToString() string

+ func (w *Workload) ToUnstructured() (*unstructured.Unstructured, error)

+ func (workload *Workload) DeepCopy(w map[string]interface{})