k8sinterface

Apr 6, 2022

Changes in this version

+ func GetContextName() string

Jan 9, 2022

Changes in this version

+ func SetClusterContextName(contextName string)

Dec 21, 2021

Changes in this version

+ func GetResourceGroupMapping() map[string]string

+ func GetResourceNamesapcedScope() []string

+ func GetSingleResourceFromGroupMapping(resource string) (string, bool)

+ func SplitResourceTriplets(resourceTriplets string) (string, string, string)

Dec 20, 2021

Changes in this version

+ func IsTypeWorkload(object map[string]interface{}) bool

+ func SplitApiVersion(apiVersion string) (string, string)

Dec 19, 2021

Changes in this version

+ func IsResourceInNamespaceScope(resource string) bool

Dec 19, 2021

Changes in this version

+ var ResourceNamesapcedScope = []string

+ func IsKindKubernetes(kind string) bool

Dec 5, 2021

Changes in this version

+ func GetResourceListMock() ([]*metav1.APIResourceList, error)

Nov 30, 2021

Changes in this version

+ var ResourceClusterScopeMock = []string

+ var ResourceGroupMappingMock = map[string]string

+ func GroupVersionResourceToString(resource *schema.GroupVersionResource) string

+ func InitializeMapResources(discoveryClient discovery.DiscoveryInterface) error

+ func InitializeMapResourcesMock()

+ func JoinGroupVersion(group, version string) string

type KubernetesApi

+ DiscoveryClient discovery.DiscoveryInterface

Nov 29, 2021

Changes in this version

+ const ValueNotFound

+ var ConnectedToCluster = true

+ var GroupsClusterScope = []string

+ var K8SConfig *restclient.Config

+ var ResourceClusterScope = []string

+ var ResourceGroupMapping = map[string]string

+ var RunningIncluster bool

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

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

+ func GetClusterName() string

+ func GetCurrentContext() *api.Context

+ func GetDefaultNamespace() string

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

+ func GetK8sConfig() *restclient.Config

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

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

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

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

+ func IsConnectedToCluster() 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 ResourceGroupToSlice(group, version, resource 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 IWorkload workloadinterface.IWorkload

+ type KubernetesApi struct

+ Context context.Context

+ DynamicClient dynamic.Interface

+ KubernetesClient kubernetes.Interface

+ func NewKubernetesApi() *KubernetesApi

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

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

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

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

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

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

+ func (k8sAPI *KubernetesApi) ListAllWorkload() ([]IWorkload, 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, ...) ([]IWorkload, error)

+ func (k8sAPI *KubernetesApi) ListWorkloads2(namespace, kind string) ([]IWorkload, error)

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

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