getter

package
v2.2.0-20240131 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 9, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ClusterRoleGVK = schema.GroupVersionKind{
	Group:   "batch",
	Kind:    "ClusterRole",
	Version: "v1",
}
View Source 
var ConfigMapGVK = schema.GroupVersionKind{
	Group:   "",
	Kind:    "ConfigMap",
	Version: "v1",
}
View Source 
var CronJobGVK = schema.GroupVersionKind{
	Group:   "batch",
	Kind:    "CronJob",
	Version: "v1",
}
View Source 
var CronJobV1BetaGVK = schema.GroupVersionKind{
	Group:   "batch",
	Kind:    "CronJob",
	Version: "v1beta1",
}
View Source 
var DeploymentGVK = schema.GroupVersionKind{
	Group:   "apps",
	Kind:    "Deployment",
	Version: "v1",
}
View Source 
var IngressBetaGVK = schema.GroupVersionKind{
	Group:   "extensions",
	Kind:    "Ingress",
	Version: "v1beta1",
}
View Source 
var IngressGVK = schema.GroupVersionKind{
	Group:   "networking.k8s.io",
	Kind:    "Ingress",
	Version: "v1",
}
View Source 
var JobGVK = schema.GroupVersionKind{
	Group:   "batch",
	Kind:    "Job",
	Version: "v1",
}
View Source 
var ReplicaSetGVK = schema.GroupVersionKind{
	Group:   "apps",
	Kind:    "ReplicaSet",
	Version: "v1",
}
View Source 
var RoleGVK = schema.GroupVersionKind{
	Group:   "rbac.authorization.k8s.io",
	Kind:    "Role",
	Version: "v1",
}
View Source 
var ServiceGVK = schema.GroupVersionKind{
	Group:   "",
	Kind:    "Service",
	Version: "v1",
}
View Source 
var StatefulSetGVK = schema.GroupVersionKind{
	Group:   "apps",
	Kind:    "StatefulSet",
	Version: "v1",
}

Functions

func GetConfigMap 

func GetConfigMap(ns, name string, cl client.Client) (*corev1.ConfigMap, bool, error)

func GetConfigMapYaml 

func GetConfigMapYaml(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetConfigMapYamlFormat 

func GetConfigMapYamlFormat(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetCronJob 

func GetCronJob(ns, name string, cl client.Client, versionLessThan121 bool) (*batchv1.CronJob, *batchv1beta1.CronJob, bool, error)

func GetCronJobByNameWithCache 

func GetCronJobByNameWithCache(cronJobName, namespace string, lister informers.SharedInformerFactory, versionLessThan121 bool) (*batchv1.CronJob, *batchv1beta1.CronJob, error)

func GetCronJobYaml 

func GetCronJobYaml(ns, name string, cl client.Client, versionLessThan121 bool) ([]byte, bool, error)

GetCronJobYaml if k8s version higher than 1.21, only batch/v1 is supported, or we will fetch batch/v1beta1

func GetCronJobYamlFormat 

func GetCronJobYamlFormat(ns, name string, cl client.Client, versionLessThan121 bool) ([]byte, bool, error)

func GetDaemonSet 

func GetDaemonSet(ns, name string, cl client.Client) (*appsv1.DaemonSet, bool, error)

func GetDaemonSetYaml 

func GetDaemonSetYaml(ns, name string, cl client.Client) ([]byte, bool, error)

func GetDeployment 

func GetDeployment(ns, name string, cl client.Client) (*appsv1.Deployment, bool, error)

func GetDeploymentByNameWithCache 

func GetDeploymentByNameWithCache(name, namespace string, lister informers.SharedInformerFactory) (*appsv1.Deployment, error)

func GetDeploymentYaml 

func GetDeploymentYaml(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetDeploymentYamlFormat 

func GetDeploymentYamlFormat(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetExtensionsV1Beta1Ingress 

func GetExtensionsV1Beta1Ingress(namespace, name string, lister informers.SharedInformerFactory) (*extensionsv1beta1.Ingress, bool, error)

func GetIngressYaml 

func GetIngressYaml(ns string, name string, cl client.Client, lessThan122 bool) ([]byte, bool, error)

func GetIngressYamlFormat 

func GetIngressYamlFormat(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetJob 

func GetJob(ns, name string, cl client.Client) (*batchv1.Job, bool, error)

func GetJobYaml 

func GetJobYaml(ns, name string, cl client.Client) ([]byte, bool, error)

func GetNamespace 

func GetNamespace(ns string, cl client.Client) (*corev1.Namespace, bool, error)

func GetNetworkingV1Ingress 

func GetNetworkingV1Ingress(namespace, name string, lister informers.SharedInformerFactory) (*v1.Ingress, error)

func GetPVCYaml 

func GetPVCYaml(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetPVCYamlFormat 

func GetPVCYamlFormat(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetPod 

func GetPod(ns, name string, cl client.Client) (*corev1.Pod, bool, error)

func GetPvc 

func GetPvc(ns, name string, cl client.Client) (*corev1.PersistentVolumeClaim, bool, error)

func GetResourceInCache 

func GetResourceInCache(ns, name string, obj client.Object, cl client.Reader) (bool, error)

GetResourceInCache gets a specific Kubernetes object in local cache, object can be any types which are registered by "scheme.AddToScheme()". Return true if object is found, false if not, or an error if something bad happened.

func GetResourceJSONInCache 

func GetResourceJSONInCache(ns, name string, gvk schema.GroupVersionKind, cl client.Reader) ([]byte, bool, error)

GetResourceJSONInCache gets a specific Kubernetes object in local cache, and return a representation in json format. Return true if object is found, false if not, or an error if something bad happened.

func GetResourceJSONInCacheFormat 

func GetResourceJSONInCacheFormat(ns, name string, gvk schema.GroupVersionKind, cl client.Reader) ([]byte, bool, error)

func GetResourceYamlInCache 

func GetResourceYamlInCache(ns, name string, gvk schema.GroupVersionKind, cl client.Reader) ([]byte, bool, error)

GetResourceYamlInCache gets a specific Kubernetes object in local cache, and return a representation in yaml format. Return true if object is found, false if not, or an error if something bad happened.

func GetResourceYamlInCacheFormat 

func GetResourceYamlInCacheFormat(ns, name string, gvk schema.GroupVersionKind, cl client.Reader) ([]byte, bool, error)

func GetSecret 

func GetSecret(ns, name string, cl client.Client) (*corev1.Secret, bool, error)

func GetSecretYaml 

func GetSecretYaml(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetSecretYamlFormat 

func GetSecretYamlFormat(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetService 

func GetService(ns, name string, cl client.Client) (*corev1.Service, bool, error)

func GetServiceByNameFromCache 

func GetServiceByNameFromCache(name, namespace string, lister informers.SharedInformerFactory) (*corev1.Service, error)

func GetServiceYaml 

func GetServiceYaml(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetServiceYamlFormat 

func GetServiceYamlFormat(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetStatefulSet 

func GetStatefulSet(ns, name string, cl client.Client) (*appsv1.StatefulSet, bool, error)

func GetStatefulSetByNameWWithCache 

func GetStatefulSetByNameWWithCache(name, namespace string, lister informers.SharedInformerFactory) (*appsv1.StatefulSet, error)

func GetStatefulSetYaml 

func GetStatefulSetYaml(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetStatefulSetYamlFormat 

func GetStatefulSetYamlFormat(ns string, name string, cl client.Client) ([]byte, bool, error)

func GetUnstructuredIngress 

func GetUnstructuredIngress(namespace, name string, cl client.Client, clientset *kubernetes.Clientset) (*unstructured.Unstructured, bool, error)

func ListConfigMaps 

func ListConfigMaps(ns string, selector labels.Selector, cl client.Client) ([]*corev1.ConfigMap, error)

func ListConfigMapsYaml 

func ListConfigMapsYaml(ns string, selector labels.Selector, cl client.Client) ([][]byte, error)

func ListCronJobs 

func ListCronJobs(ns string, selector labels.Selector, cl client.Client, versionLessThan121 bool) ([]*batchv1.CronJob, []*batchv1beta1.CronJob, error)

func ListCronJobsV1 

func ListCronJobsV1(ns string, selector labels.Selector, cl client.Client) ([]*batchv1.CronJob, error)

func ListCronJobsV1Beta 

func ListCronJobsV1Beta(ns string, selector labels.Selector, cl client.Client) ([]*batchv1beta1.CronJob, error)

func ListCronJobsWithCache 

func ListCronJobsWithCache(selector labels.Selector, lister informers.SharedInformerFactory, versionLessThan121 bool) ([]*batchv1.CronJob, []*batchv1beta1.CronJob, error)

func ListCronJobsYaml 

func ListCronJobsYaml(ns string, selector labels.Selector, cl client.Client, versionLessThan121 bool) ([][]byte, error)

func ListDaemonsets 

func ListDaemonsets(ns string, selector labels.Selector, cl client.Client) ([]*appsv1.DaemonSet, error)

func ListDeployments 

func ListDeployments(ns string, selector labels.Selector, cl client.Client) ([]*appsv1.Deployment, error)

func ListDeploymentsWithCache 

func ListDeploymentsWithCache(selector labels.Selector, lister informers.SharedInformerFactory) ([]*appsv1.Deployment, error)

func ListDeploymentsYaml 

func ListDeploymentsYaml(ns string, selector labels.Selector, cl client.Client) ([][]byte, error)

func ListEvents 

func ListEvents(ns string, selector fields.Selector, cl client.Reader) ([]*corev1.Event, error)

func ListExtensionsV1Beta1Ingresses 

func ListExtensionsV1Beta1Ingresses(selector labels.Selector, lister informers.SharedInformerFactory) ([]*extensionsv1beta1.Ingress, error)

ListExtensionsV1Beta1Ingresses gets the ingress (extensions/v1beta1) from the informer

func ListIngresses 

func ListIngresses(namespace string, cl client.Client, lessThan122 bool) (*unstructured.UnstructuredList, error)

func ListIngressesYaml 

func ListIngressesYaml(ns string, selector labels.Selector, cl client.Client) ([][]byte, error)

func ListJobs 

func ListJobs(ns string, selector labels.Selector, cl client.Client) ([]*batchv1.Job, error)

func ListNamespaces 

func ListNamespaces(cl client.Reader) ([]*corev1.Namespace, error)

func ListNetworkingV1Ingress 

func ListNetworkingV1Ingress(selector labels.Selector, lister informers.SharedInformerFactory) ([]*v1.Ingress, error)

func ListNodes 

func ListNodes(cl client.Client) ([]*corev1.Node, error)

func ListPods 

func ListPods(ns string, selector labels.Selector, cl client.Client) ([]*corev1.Pod, error)

func ListPodsWithCache 

func ListPodsWithCache(selector labels.Selector, informer informers.SharedInformerFactory) ([]*corev1.Pod, error)

func ListPvcs 

func ListPvcs(ns string, selector fields.Selector, cl client.Reader) ([]*corev1.PersistentVolumeClaim, error)

func ListReplicaSets 

func ListReplicaSets(ns string, selector labels.Selector, cl client.Client) ([]*appsv1.ReplicaSet, error)

func ListResourceInCache 

func ListResourceInCache(ns string, selector labels.Selector, fieldSelector fields.Selector, obj client.ObjectList, cl client.Reader) error

ListResourceInCache gets a set of specific Kubernetes object in local cache, object can be any types which are registered by "scheme.AddToScheme()". Important: fieldSelector must be nil or contain just one kv pair, otherwise, controller-runtime will return error.

func ListResourceJSONInCache 

func ListResourceJSONInCache(ns string, selector labels.Selector, fieldSelector fields.Selector, gvk schema.GroupVersionKind, cl client.Reader) ([][]byte, error)

ListResourceJSONInCache gets a set of specific Kubernetes object in local cache, and return a representation in json format.

func ListResourceYamlInCache 

func ListResourceYamlInCache(ns string, selector labels.Selector, fieldSelector fields.Selector, gvk schema.GroupVersionKind, cl client.Reader) ([][]byte, error)

ListResourceYamlInCache gets a set of specific Kubernetes object in local cache, and return a representation in yaml format.

func ListSecrets 

func ListSecrets(ns string, selector labels.Selector, cl client.Client) ([]*corev1.Secret, error)

func ListServices 

func ListServices(ns string, selector labels.Selector, cl client.Client) ([]*corev1.Service, error)

func ListServicesWithCache 

func ListServicesWithCache(selector labels.Selector, lister informers.SharedInformerFactory) ([]*corev1.Service, error)

func ListServicesYaml 

func ListServicesYaml(ns string, selector labels.Selector, cl client.Client) ([][]byte, error)

func ListStatefulSets 

func ListStatefulSets(ns string, selector labels.Selector, cl client.Client) ([]*appsv1.StatefulSet, error)

func ListStatefulSetsWithCache 

func ListStatefulSetsWithCache(selector labels.Selector, lister informers.SharedInformerFactory) ([]*appsv1.StatefulSet, error)

func ListStatefulSetsYaml 

func ListStatefulSetsYaml(ns string, selector labels.Selector, cl client.Client) ([][]byte, error)

func ListUnstructuredResourceInCache 

func ListUnstructuredResourceInCache(ns string, selector labels.Selector, fieldSelector fields.Selector, gvk schema.GroupVersionKind, cl client.Reader) ([]*unstructured.Unstructured, error)

ListUnstructuredResourceInCache gets a set of specific Kubernetes object in local cache, and return a representation in yaml format.

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.