nativekubernetes

package
v0.373.0 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrOnlyCombinedStreamAvailable = errors.New("specify the stream is not supported. Only combinded stream is availalbe by the kubernetes API, feature flag seems deactivated")

Functions

func DeletePod added in v0.361.0 

func DeletePod(ctx context.Context, clientset *kubernetes.Clientset, podName string, namespace string) error

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 GetContainerAllLogs added in v0.361.0 

func GetContainerAllLogs(ctx context.Context, clientset *kubernetes.Clientset, namespace string, podName string, containerName string) ([]byte, error)

'All' combines stdout and stderr.

func GetContainerLogs added in v0.361.0 

func GetContainerLogs(ctx context.Context, clientset *kubernetes.Clientset, namespace string, podName string, containerName string) (stdout []byte, stderr []byte, err error)

func GetContainerStderrLogs added in v0.361.0 

func GetContainerStderrLogs(ctx context.Context, clientset *kubernetes.Clientset, namespace string, podName string, containerName string) ([]byte, error)

func GetContainerStdoutLogs added in v0.361.0 

func GetContainerStdoutLogs(ctx context.Context, clientset *kubernetes.Clientset, namespace string, podName string, containerName string) ([]byte, error)

func GetInClusterConfig added in v0.341.0 

func GetInClusterConfig(ctx context.Context) (*rest.Config, error)

func IsConfigMapContentEqual added in v0.353.0 

func IsConfigMapContentEqual(configMap1 map[string]string, configMap2 map[string]string) bool

func IsConfigMapLabelsEqual added in v0.353.0 

func IsConfigMapLabelsEqual(labels1 map[string]string, labels2 map[string]string) bool

func ListNodeNames added in v0.367.0 

func ListNodeNames(ctx context.Context, clientset *kubernetes.Clientset) ([]string, error)

func ReadSecret added in v0.364.0 

func ReadSecret(ctx context.Context, clientset *kubernetes.Clientset, namespaceName string, secretName string) (map[string][]byte, error)

func RunCommandInTemporaryPod added in v0.361.0 

func RunCommandInTemporaryPod(ctx context.Context, config *rest.Config, options *kubernetesparameteroptions.RunCommandOptions) (*commandexecutor.CommandOutput, 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) CreateObject added in v0.349.0 

func (n *NativeKubernetesCluster) CreateObject(ctx context.Context, options *kubernetesparameteroptions.CreateObjectOptions) (kubernetesinterfaces.Object, 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) GetNamespaceByYamlString added in v0.348.0 

func (n *NativeKubernetesCluster) GetNamespaceByYamlString(yaml string) (kubernetesinterfaces.Namespace, error)

func (*NativeKubernetesCluster) GetObjectByNames added in v0.349.0 

func (n *NativeKubernetesCluster) GetObjectByNames(objectName string, objectType string, namespaceName string) (object kubernetesinterfaces.Object, 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) ListNodeNames added in v0.367.0 

func (n *NativeKubernetesCluster) ListNodeNames(ctx context.Context) ([]string, error)

func (*NativeKubernetesCluster) ListObjectNames added in v0.349.0 

func (n *NativeKubernetesCluster) ListObjectNames(options *kubernetesparameteroptions.ListKubernetesObjectsOptions) (objectNames []string, err error)

func (*NativeKubernetesCluster) ListObjects added in v0.349.0 

func (n *NativeKubernetesCluster) ListObjects(options *kubernetesparameteroptions.ListKubernetesObjectsOptions) (objects []kubernetesinterfaces.Object, err error)

func (*NativeKubernetesCluster) NamespaceByNameExists 

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

func (*NativeKubernetesCluster) ReadSecret added in v0.364.0 

func (n *NativeKubernetesCluster) ReadSecret(ctx context.Context, namespaceName string, secretName string) (map[string][]byte, error)

func (*NativeKubernetesCluster) RunCommandInTemporaryPod added in v0.361.0 

func (n *NativeKubernetesCluster) RunCommandInTemporaryPod(ctx context.Context, options *kubernetesparameteroptions.RunCommandOptions) (*commandexecutor.CommandOutput, error)

func (*NativeKubernetesCluster) SecretByNameExists 

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

func (*NativeKubernetesCluster) WaitUntilAllPodsInNamespaceAreRunning added in v0.345.0 

func (n *NativeKubernetesCluster) WaitUntilAllPodsInNamespaceAreRunning(ctx context.Context, namespaceName string, options *kubernetesparameteroptions.WaitForPodsOptions) 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) CreateObject added in v0.349.0 

func (n *NativeNamespace) CreateObject(ctx context.Context, options *kubernetesparameteroptions.CreateObjectOptions) (kubernetesinterfaces.Object, 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) Exists added in v0.360.0 

func (n *NativeNamespace) Exists(ctx context.Context) (bool, 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) GetDiscoveryClient added in v0.343.0 

func (n *NativeNamespace) GetDiscoveryClient() (discovery.DiscoveryInterface, 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) GetObjectByNames added in v0.349.0 

func (n *NativeNamespace) GetObjectByNames(objectName string, objectKind string) (object kubernetesinterfaces.Object, err error)

func (*NativeNamespace) GetObjectByYamlString added in v0.349.0 

func (n *NativeNamespace) GetObjectByYamlString(yaml string) (kubernetesinterfaces.Object, 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) WaitUntilAllPodsInNamespaceAreRunning added in v0.345.0 

func (n *NativeNamespace) WaitUntilAllPodsInNamespaceAreRunning(ctx context.Context, options *kubernetesparameteroptions.WaitForPodsOptions) 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 NativeObject added in v0.349.0 

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

func (*NativeObject) CreateByYamlString added in v0.349.0 

func (n *NativeObject) CreateByYamlString(ctx context.Context, options *kubernetesparameteroptions.CreateObjectOptions) (err error)

func (*NativeObject) Delete added in v0.349.0 

func (n *NativeObject) Delete(ctx context.Context) error

func (*NativeObject) EnsureNamespaceExists added in v0.349.0 

func (n *NativeObject) EnsureNamespaceExists(ctx context.Context) error

func (*NativeObject) Exists added in v0.349.0 

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

func (*NativeObject) GetApiVersion added in v0.349.0 

func (n *NativeObject) GetApiVersion(ctx context.Context) (string, error)

func (*NativeObject) GetAsYamlString added in v0.349.0 

func (n *NativeObject) GetAsYamlString() (yamlString string, err error)

func (*NativeObject) GetDynamicClient added in v0.349.0 

func (n *NativeObject) GetDynamicClient() (*dynamic.DynamicClient, error)

func (*NativeObject) GetGroupVersion added in v0.349.0 

func (n *NativeObject) GetGroupVersion(ctx context.Context) (*schema.GroupVersion, error)

func (*NativeObject) GetGroupVersionKind added in v0.349.0 

func (n *NativeObject) GetGroupVersionKind(ctx context.Context) (*schema.GroupVersionKind, error)

func (*NativeObject) GetGroupVersionObject added in v0.349.0 

func (n *NativeObject) GetGroupVersionObject(ctx context.Context) (*schema.GroupVersionResource, error)

func (*NativeObject) GetKind added in v0.349.0 

func (n *NativeObject) GetKind() (string, error)

func (*NativeObject) GetName added in v0.349.0 

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

func (*NativeObject) GetNamespace added in v0.349.0 

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

func (*NativeObject) GetNamespaceName added in v0.349.0 

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

func (*NativeObject) GetObjectInterface added in v0.349.0 

func (n *NativeObject) GetObjectInterface(ctx context.Context) (dynamic.ResourceInterface, error)

func (*NativeObject) GetObjectPlural added in v0.349.0 

func (n *NativeObject) GetObjectPlural() (string, error)

func (*NativeObject) SetApiVersion added in v0.349.0 

func (n *NativeObject) SetApiVersion(apiVersion string) error

func (*NativeObject) SetKind added in v0.349.0 

func (n *NativeObject) SetKind(kind string) 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) GetClientSet added in v0.364.0 

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

func (*NativeSecret) GetName 

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

func (*NativeSecret) GetNamespace 

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

func (*NativeSecret) GetNamespaceName added in v0.364.0 

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

func (*NativeSecret) Read added in v0.364.0 

func (n *NativeSecret) Read(ctx context.Context) (map[string][]byte, 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.