nativekubernetes

package
v0.342.0 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2025 License: Apache-2.0 Imports: 27 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, clusterName string) (*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 GetConfig added in v0.341.0 

func GetConfig(ctx context.Context, clusterName string) (*rest.Config, error)

Get the rest.Config to communicate with the kubernetes cluster.

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

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

func GetConfigFromKubeconfig added in v0.341.0 

func GetConfigFromKubeconfig(ctx context.Context, clusterName string) (*rest.Config, error)

func GetInClusterConfig added in v0.341.0 

func GetInClusterConfig(ctx context.Context) (*rest.Config, 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 GetDefaultCluster added in v0.341.0 

func GetDefaultCluster(ctx context.Context) (*NativeKubernetesCluster, error)

func (*NativeKubernetesCluster) CheckAccessible added in v0.341.0 

func (n *NativeKubernetesCluster) CheckAccessible(ctx context.Context) 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 *kubernetesparameteroptions.CreateConfigMapOptions) (createdSecret kubernetesinterfaces.ConfigMap, err error)

func (*NativeKubernetesCluster) CreateNamespaceByName 

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

func (*NativeKubernetesCluster) CreateSecret 

func (n *NativeKubernetesCluster) CreateSecret(ctx context.Context, namespaceName string, secretName string, options *kubernetesparameteroptions.CreateSecretOptions) (createdSecret kubernetesinterfaces.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) GetConfig added in v0.341.0 

func (n *NativeKubernetesCluster) GetConfig() (*rest.Config, error)

func (*NativeKubernetesCluster) GetDiscoveryClient added in v0.341.0 

func (n *NativeKubernetesCluster) GetDiscoveryClient() (discovery.DiscoveryInterface, error)

func (*NativeKubernetesCluster) GetDynamicClient added in v0.341.0 

func (n *NativeKubernetesCluster) GetDynamicClient() (*dynamic.DynamicClient, 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 kubernetesinterfaces.Namespace, err error)

func (*NativeKubernetesCluster) GetResourceByNames 

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

func (*NativeKubernetesCluster) GetUserNameByContextName added in v0.341.0 

func (n *NativeKubernetesCluster) GetUserNameByContextName(ctx context.Context, kubeContext string) (string, error)

func (*NativeKubernetesCluster) ListKindNames added in v0.341.0 

func (n *NativeKubernetesCluster) ListKindNames(ctx context.Context) ([]string, 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 []kubernetesinterfaces.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 []kubernetesinterfaces.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)

func (*NativeKubernetesCluster) WhoAmI added in v0.341.0 

func (n *NativeKubernetesCluster) WhoAmI(ctx context.Context) (*kubernetesimplementationindependend.UserInfo, 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 *kubernetesparameteroptions.CreateConfigMapOptions) (createdConfigMap kubernetesinterfaces.ConfigMap, err error)

func (*NativeNamespace) CreateRole 

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

func (*NativeNamespace) CreateSecret 

func (n *NativeNamespace) CreateSecret(ctx context.Context, secretName string, options *kubernetesparameteroptions.CreateSecretOptions) (createdSecret kubernetesinterfaces.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 kubernetesinterfaces.ConfigMap, err error)

func (*NativeNamespace) GetDynamicClient added in v0.341.0 

func (n *NativeNamespace) GetDynamicClient() (*dynamic.DynamicClient, 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 kubernetesinterfaces.Resource, err error)

func (*NativeNamespace) GetRoleByName 

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

func (*NativeNamespace) GetSecretByName 

func (n *NativeNamespace) GetSecretByName(name string) (secret kubernetesinterfaces.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(kubernetesinterfaces.ConfigMap), onUpdate func(kubernetesinterfaces.ConfigMap), onDelete func(kubernetesinterfaces.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.