nativekubernetes

package
v0.337.0 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EventMatchesOptions added in v0.333.0 

func EventMatchesOptions(event *corev1.Event, options *kubernetesutils.WatchEventOptions) bool

func EventToString added in v0.333.0 

func EventToString(event *corev1.Event) string

func GetClientSet 

func GetClientSet(ctx context.Context) (*kubernetes.Clientset, error)

Get the kubernetes.Clientset to communicate with the kubernetes cluster.

If in cluster authentication is available (e.g. running in a pod in the cluster) the returned clientset uses this method.

Otherwise a clientset based on ~/.kube/config is returned.

func GetClientSetFromKubeconfig 

func GetClientSetFromKubeconfig(ctx context.Context) (*kubernetes.Clientset, error)

Get a client set based on the ~/.kube/config

func GetInClusterClientSet 

func GetInClusterClientSet(ctx context.Context) (*kubernetes.Clientset, error)

func WatchEvents added in v0.333.0 

func WatchEvents(ctx context.Context, options *kubernetesutils.WatchEventOptions, onCreate func(*corev1.Event), onUpdate func(*corev1.Event), onDelete func(*corev1.Event)) error

Types

type NativeConfigMap added in v0.322.0 

type NativeConfigMap struct {
	// contains filtered or unexported fields
}

func (*NativeConfigMap) Exists added in v0.322.0 

func (n *NativeConfigMap) Exists(ctx context.Context) (bool, error)

func (*NativeConfigMap) GetAllData added in v0.330.0 

func (n *NativeConfigMap) GetAllData(ctx context.Context) (map[string]string, error)

func (*NativeConfigMap) GetAllLabels added in v0.330.0 

func (n *NativeConfigMap) GetAllLabels(ctx context.Context) (map[string]string, error)

func (*NativeConfigMap) GetData added in v0.330.0 

func (n *NativeConfigMap) GetData(ctx context.Context, fieldName string) (string, error)

func (*NativeConfigMap) GetName added in v0.322.0 

func (n *NativeConfigMap) GetName() (string, error)

func (*NativeConfigMap) GetNamespace added in v0.322.0 

func (n *NativeConfigMap) GetNamespace() (*NativeNamespace, error)

func (*NativeConfigMap) GetNamespaceName added in v0.330.0 

func (n *NativeConfigMap) GetNamespaceName() (string, error)

func (*NativeConfigMap) GetRawResponse added in v0.330.0 

func (n *NativeConfigMap) GetRawResponse(ctx context.Context) (*v1.ConfigMap, error)

type NativeKubernetesCluster 

type NativeKubernetesCluster struct {
	// contains filtered or unexported fields
}

func GetClusterByName 

func GetClusterByName(ctx context.Context, clusterName string) (*NativeKubernetesCluster, error)

func (*NativeKubernetesCluster) ConfigMapByNameExists added in v0.322.0 

func (n *NativeKubernetesCluster) ConfigMapByNameExists(ctx context.Context, namespaceName string, configmapName string) (exists bool, err error)

func (*NativeKubernetesCluster) CreateConfigMap added in v0.322.0 

func (n *NativeKubernetesCluster) CreateConfigMap(ctx context.Context, namespaceName string, configMapName string, options *kubernetesutils.CreateConfigMapOptions) (createdSecret kubernetesutils.ConfigMap, err error)

func (*NativeKubernetesCluster) CreateNamespaceByName 

func (n *NativeKubernetesCluster) CreateNamespaceByName(ctx context.Context, namespaceName string) (createdNamespace kubernetesutils.Namespace, err error)

func (*NativeKubernetesCluster) CreateSecret 

func (n *NativeKubernetesCluster) CreateSecret(ctx context.Context, namespaceName string, secretName string, options *kubernetesutils.CreateSecretOptions) (createdSecret kubernetesutils.Secret, err error)

func (*NativeKubernetesCluster) DeleteConfigMapByName added in v0.322.0 

func (n *NativeKubernetesCluster) DeleteConfigMapByName(ctx context.Context, namespaceName string, configmapName string) (err error)

func (*NativeKubernetesCluster) DeleteNamespaceByName 

func (n *NativeKubernetesCluster) DeleteNamespaceByName(ctx context.Context, namespaceName string) (err error)

func (*NativeKubernetesCluster) DeleteSecretByName 

func (n *NativeKubernetesCluster) DeleteSecretByName(ctx context.Context, namespaceName string, secretName string) (err error)

func (*NativeKubernetesCluster) GetClientSet 

func (n *NativeKubernetesCluster) GetClientSet() (*kubernetes.Clientset, error)

func (*NativeKubernetesCluster) GetKubectlContext 

func (n *NativeKubernetesCluster) GetKubectlContext(ctx context.Context) (contextName string, err error)

func (*NativeKubernetesCluster) GetName 

func (n *NativeKubernetesCluster) GetName() (name string, err error)

func (*NativeKubernetesCluster) GetNamespaceByName 

func (n *NativeKubernetesCluster) GetNamespaceByName(name string) (namespace kubernetesutils.Namespace, err error)

func (*NativeKubernetesCluster) GetResourceByNames 

func (n *NativeKubernetesCluster) GetResourceByNames(resourceName string, resourceType string, namespaceName string) (resource kubernetesutils.Resource, err error)

func (*NativeKubernetesCluster) ListNamespaceNames 

func (n *NativeKubernetesCluster) ListNamespaceNames(ctx context.Context) (namespaceNames []string, err error)

func (*NativeKubernetesCluster) ListNamespaces 

func (n *NativeKubernetesCluster) ListNamespaces(ctx context.Context) (namespaces []kubernetesutils.Namespace, err error)

func (*NativeKubernetesCluster) ListResourceNames 

func (n *NativeKubernetesCluster) ListResourceNames(options *parameteroptions.ListKubernetesResourcesOptions) (resourceNames []string, err error)

func (*NativeKubernetesCluster) ListResources 

func (n *NativeKubernetesCluster) ListResources(options *parameteroptions.ListKubernetesResourcesOptions) (resources []kubernetesutils.Resource, err error)

func (*NativeKubernetesCluster) NamespaceByNameExists 

func (n *NativeKubernetesCluster) NamespaceByNameExists(ctx context.Context, namespaceName string) (exist bool, err error)

func (*NativeKubernetesCluster) SecretByNameExists 

func (n *NativeKubernetesCluster) SecretByNameExists(ctx context.Context, namespaceName string, secretName string) (exists bool, err error)

func (*NativeKubernetesCluster) WaitUntilNamespaceCreated 

func (n *NativeKubernetesCluster) WaitUntilNamespaceCreated(ctx context.Context, namepaceName string) (err error)

func (*NativeKubernetesCluster) WaitUntilNamespaceDeleted 

func (n *NativeKubernetesCluster) WaitUntilNamespaceDeleted(ctx context.Context, namepaceName string) (err error)

type NativeNamespace 

type NativeNamespace struct {
	// contains filtered or unexported fields
}

func (*NativeNamespace) ConfigMapByNameExists added in v0.322.0 

func (n *NativeNamespace) ConfigMapByNameExists(ctx context.Context, configmapName string) (bool, error)

func (*NativeNamespace) Create 

func (n *NativeNamespace) Create(ctx context.Context) (err error)

func (*NativeNamespace) CreateConfigMap added in v0.322.0 

func (n *NativeNamespace) CreateConfigMap(ctx context.Context, configMapName string, options *kubernetesutils.CreateConfigMapOptions) (createdConfigMap kubernetesutils.ConfigMap, err error)

func (*NativeNamespace) CreateRole 

func (n *NativeNamespace) CreateRole(ctx context.Context, createOptions *kubernetesutils.CreateRoleOptions) (createdRole kubernetesutils.Role, err error)

func (*NativeNamespace) CreateSecret 

func (n *NativeNamespace) CreateSecret(ctx context.Context, secretName string, options *kubernetesutils.CreateSecretOptions) (createdSecret kubernetesutils.Secret, err error)

func (*NativeNamespace) DeleteConfigMapByName added in v0.322.0 

func (n *NativeNamespace) DeleteConfigMapByName(ctx context.Context, configmapName string) (err error)

func (*NativeNamespace) DeleteRoleByName 

func (n *NativeNamespace) DeleteRoleByName(ctx context.Context, name string) (err error)

func (*NativeNamespace) DeleteSecretByName 

func (n *NativeNamespace) DeleteSecretByName(ctx context.Context, secretName string) (err error)

func (*NativeNamespace) GetClientSet 

func (n *NativeNamespace) GetClientSet() (*kubernetes.Clientset, error)

func (*NativeNamespace) GetClusterName 

func (n *NativeNamespace) GetClusterName() (clusterName string, err error)

func (*NativeNamespace) GetConfigMapByName added in v0.322.0 

func (n *NativeNamespace) GetConfigMapByName(name string) (configMap kubernetesutils.ConfigMap, err error)

func (*NativeNamespace) GetKubectlContext 

func (n *NativeNamespace) GetKubectlContext(ctx context.Context) (contextName string, err error)

func (*NativeNamespace) GetKubernetesCluster 

func (n *NativeNamespace) GetKubernetesCluster() (*NativeKubernetesCluster, error)

func (*NativeNamespace) GetName 

func (n *NativeNamespace) GetName() (name string, err error)

func (*NativeNamespace) GetResourceByNames 

func (n *NativeNamespace) GetResourceByNames(resourceName string, resourceType string) (resource kubernetesutils.Resource, err error)

func (*NativeNamespace) GetRoleByName 

func (n *NativeNamespace) GetRoleByName(name string) (role kubernetesutils.Role, err error)

func (*NativeNamespace) GetSecretByName 

func (n *NativeNamespace) GetSecretByName(name string) (secret kubernetesutils.Secret, err error)

func (*NativeNamespace) ListRoleNames 

func (n *NativeNamespace) ListRoleNames(ctx context.Context) (roleNames []string, err error)

func (*NativeNamespace) RoleByNameExists 

func (n *NativeNamespace) RoleByNameExists(ctx context.Context, name string) (exists bool, err error)

func (*NativeNamespace) SecretByNameExists 

func (n *NativeNamespace) SecretByNameExists(ctx context.Context, secretName string) (bool, error)

func (*NativeNamespace) WatchConfigMap added in v0.332.0 

func (n *NativeNamespace) WatchConfigMap(ctx context.Context, configMapName string, onCreate func(kubernetesutils.ConfigMap), onUpdate func(kubernetesutils.ConfigMap), onDelete func(kubernetesutils.ConfigMap)) error

type NativeSecret 

type NativeSecret struct {
	// contains filtered or unexported fields
}

func (*NativeSecret) Exists 

func (n *NativeSecret) Exists(ctx context.Context) (bool, error)

func (*NativeSecret) GetName 

func (n *NativeSecret) GetName() (string, error)

func (*NativeSecret) GetNamespace 

func (n *NativeSecret) GetNamespace() (*NativeNamespace, error)

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.