commandexecutorkubernetes

package
v0.448.0 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetClusterByName 

func GetClusterByName(clusterName string) (kubernetes kubernetesinterfaces.KubernetesCluster, err error)

func GetCommandExecutorKubernetsByName 

func GetCommandExecutorKubernetsByName(commandExecutor commandexecutorinterfaces.CommandExecutor, clusterName string) (kubernetes kubernetesinterfaces.KubernetesCluster, err error)

func GetCommandExecutorObject added in v0.349.0 

func GetCommandExecutorObject(commandExectutor commandexecutorinterfaces.CommandExecutor, namespace kubernetesinterfaces.Namespace, objectName string, objectType string) (object kubernetesinterfaces.Object, err error)

Types

type CommandExecutorKubernetes 

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

func NewCommandExecutorKubernetes 

func NewCommandExecutorKubernetes() (c *CommandExecutorKubernetes)

func (*CommandExecutorKubernetes) CheckAccessible added in v0.341.0 

func (c *CommandExecutorKubernetes) CheckAccessible(ctx context.Context) error

func (*CommandExecutorKubernetes) ConfigMapByNameExists added in v0.322.0 

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

func (*CommandExecutorKubernetes) CreateConfigMap added in v0.322.0 

func (c *CommandExecutorKubernetes) CreateConfigMap(ctx context.Context, namespaceName string, configMapName string, options *kubernetesparameteroptions.CreateConfigMapOptions) (createdConfigMap kubernetesinterfaces.ConfigMap, err error)

func (*CommandExecutorKubernetes) CreateNamespaceByName 

func (c *CommandExecutorKubernetes) CreateNamespaceByName(ctx context.Context, name string) (createdNamespace kubernetesinterfaces.Namespace, err error)

func (*CommandExecutorKubernetes) CreateObject added in v0.349.0 

func (c *CommandExecutorKubernetes) CreateObject(ctx context.Context, options *kubernetesparameteroptions.CreateObjectOptions) (kubernetesinterfaces.Object, error)

func (*CommandExecutorKubernetes) CreateSecret 

func (c *CommandExecutorKubernetes) CreateSecret(ctx context.Context, namespaceName string, secretName string, options *kubernetesparameteroptions.CreateSecretOptions) (createdSecret kubernetesinterfaces.Secret, err error)

func (*CommandExecutorKubernetes) DeleteConfigMapByName added in v0.322.0 

func (c *CommandExecutorKubernetes) DeleteConfigMapByName(ctx context.Context, namespaceName string, configmapName string) (err error)

func (*CommandExecutorKubernetes) DeleteNamespaceByName 

func (c *CommandExecutorKubernetes) DeleteNamespaceByName(ctx context.Context, name string) (err error)

func (*CommandExecutorKubernetes) DeleteSecretByName 

func (c *CommandExecutorKubernetes) DeleteSecretByName(ctx context.Context, namespaceName string, secretName string) (err error)

func (*CommandExecutorKubernetes) GetCachedContextName 

func (c *CommandExecutorKubernetes) GetCachedContextName() (cachedContextName string, err error)

func (*CommandExecutorKubernetes) GetCachedKubectlContext 

func (c *CommandExecutorKubernetes) GetCachedKubectlContext(ctx context.Context) (context string, err error)

func (*CommandExecutorKubernetes) GetCommandExecutor 

func (c *CommandExecutorKubernetes) GetCommandExecutor() (commandExecutor commandexecutorinterfaces.CommandExecutor, err error)

func (*CommandExecutorKubernetes) GetKubectlContext 

func (c *CommandExecutorKubernetes) GetKubectlContext(ctx context.Context) (context string, err error)

func (*CommandExecutorKubernetes) GetKubectlContexts 

func (c *CommandExecutorKubernetes) GetKubectlContexts() (contexts []kubernetesutils.KubectlContext, err error)

func (*CommandExecutorKubernetes) GetName 

func (c *CommandExecutorKubernetes) GetName() (name string, err error)

Returns the kubernetes cluster name

func (*CommandExecutorKubernetes) GetNamespaceByName 

func (c *CommandExecutorKubernetes) GetNamespaceByName(name string) (namespace kubernetesinterfaces.Namespace, err error)

func (*CommandExecutorKubernetes) GetObjectByNames added in v0.349.0 

func (c *CommandExecutorKubernetes) GetObjectByNames(objectName string, objectType string, namespaceName string) (object kubernetesinterfaces.Object, err error)

func (*CommandExecutorKubernetes) ListNamespaceNames 

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

func (*CommandExecutorKubernetes) ListNamespaces 

func (c *CommandExecutorKubernetes) ListNamespaces(ctx context.Context) (namespaces []kubernetesinterfaces.Namespace, err error)

func (*CommandExecutorKubernetes) ListNodeNames added in v0.367.0 

func (c *CommandExecutorKubernetes) ListNodeNames(ctx context.Context) ([]string, error)

func (*CommandExecutorKubernetes) ListObjectNames added in v0.349.0 

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

func (*CommandExecutorKubernetes) ListObjects added in v0.349.0 

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

func (*CommandExecutorKubernetes) NamespaceByNameExists 

func (c *CommandExecutorKubernetes) NamespaceByNameExists(ctx context.Context, name string) (exists bool, err error)

func (*CommandExecutorKubernetes) ReadSecret added in v0.364.0 

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

func (*CommandExecutorKubernetes) RunCommand 

func (c *CommandExecutorKubernetes) RunCommand(ctx context.Context, runCommandOptions *parameteroptions.RunCommandOptions) (commandOutput *commandoutput.CommandOutput, err error)

func (*CommandExecutorKubernetes) RunCommandAndGetStdoutAsLines 

func (c *CommandExecutorKubernetes) RunCommandAndGetStdoutAsLines(ctx context.Context, runCommandOptions *parameteroptions.RunCommandOptions) (lines []string, err error)

func (*CommandExecutorKubernetes) RunCommandInTemporaryPod added in v0.361.0 

func (c *CommandExecutorKubernetes) RunCommandInTemporaryPod(ctx context.Context, options *kubernetesparameteroptions.RunCommandOptions) (*commandoutput.CommandOutput, error)

func (*CommandExecutorKubernetes) SecretByNameExists 

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

func (*CommandExecutorKubernetes) SetCachedContextName 

func (c *CommandExecutorKubernetes) SetCachedContextName(cachedContextName string) (err error)

func (*CommandExecutorKubernetes) SetCommandExecutor 

func (c *CommandExecutorKubernetes) SetCommandExecutor(commandExecutor commandexecutorinterfaces.CommandExecutor) (err error)

func (*CommandExecutorKubernetes) SetName 

func (c *CommandExecutorKubernetes) SetName(name string) (err error)

func (*CommandExecutorKubernetes) WaitUntilAllPodsInNamespaceAreRunning added in v0.345.0 

func (c *CommandExecutorKubernetes) WaitUntilAllPodsInNamespaceAreRunning(ctx context.Context, namespaceName string, options *kubernetesparameteroptions.WaitForPodsOptions) error

func (*CommandExecutorKubernetes) WhoAmI added in v0.341.0 

func (c *CommandExecutorKubernetes) WhoAmI(ctx context.Context) (*kubernetesimplementationindependend.UserInfo, error)

type CommandExecutorNamespace 

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

func NewCommandExecutorNamespace 

func NewCommandExecutorNamespace() (c *CommandExecutorNamespace)

func (*CommandExecutorNamespace) ConfigMapByNameExists added in v0.322.0 

func (c *CommandExecutorNamespace) ConfigMapByNameExists(ctx context.Context, name string) (bool, error)

func (*CommandExecutorNamespace) Create 

func (c *CommandExecutorNamespace) Create(ctx context.Context) (err error)

func (*CommandExecutorNamespace) CreateConfigMap added in v0.322.0 

func (c *CommandExecutorNamespace) CreateConfigMap(ctx context.Context, name string, options *kubernetesparameteroptions.CreateConfigMapOptions) (createdConfigMap kubernetesinterfaces.ConfigMap, err error)

func (*CommandExecutorNamespace) CreateObject added in v0.349.0 

func (c *CommandExecutorNamespace) CreateObject(ctx context.Context, options *kubernetesparameteroptions.CreateObjectOptions) (kubernetesinterfaces.Object, error)

func (*CommandExecutorNamespace) CreateRole 

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

func (*CommandExecutorNamespace) CreateSecret 

func (c *CommandExecutorNamespace) CreateSecret(ctx context.Context, name string, options *kubernetesparameteroptions.CreateSecretOptions) (createdSecret kubernetesinterfaces.Secret, err error)

func (*CommandExecutorNamespace) DeleteConfigMapByName added in v0.322.0 

func (c *CommandExecutorNamespace) DeleteConfigMapByName(ctx context.Context, name string) (err error)

func (*CommandExecutorNamespace) DeleteRoleByName 

func (c *CommandExecutorNamespace) DeleteRoleByName(ctx context.Context, name string) (err error)

func (*CommandExecutorNamespace) DeleteSecretByName 

func (c *CommandExecutorNamespace) DeleteSecretByName(ctx context.Context, name string) (err error)

func (*CommandExecutorNamespace) Exists added in v0.360.0 

func (c *CommandExecutorNamespace) Exists(ctx context.Context) (bool, error)

func (*CommandExecutorNamespace) GetCachedKubectlContext 

func (c *CommandExecutorNamespace) GetCachedKubectlContext(ctx context.Context) (context string, err error)

func (*CommandExecutorNamespace) GetClusterName 

func (c *CommandExecutorNamespace) GetClusterName() (clusterName string, err error)

func (*CommandExecutorNamespace) GetCommandExecutor 

func (c *CommandExecutorNamespace) GetCommandExecutor() (commandExecutor commandexecutorinterfaces.CommandExecutor, err error)

func (*CommandExecutorNamespace) GetConfigMapByName added in v0.322.0 

func (c *CommandExecutorNamespace) GetConfigMapByName(name string) (secret kubernetesinterfaces.ConfigMap, err error)

func (*CommandExecutorNamespace) GetKubectlContext 

func (c *CommandExecutorNamespace) GetKubectlContext(ctx context.Context) (contextName string, err error)

func (*CommandExecutorNamespace) GetKubernetesCluster 

func (c *CommandExecutorNamespace) GetKubernetesCluster() (kubernetesCluster kubernetesinterfaces.KubernetesCluster, err error)

func (*CommandExecutorNamespace) GetName 

func (c *CommandExecutorNamespace) GetName() (name string, err error)

func (*CommandExecutorNamespace) GetObjectByNames added in v0.349.0 

func (c *CommandExecutorNamespace) GetObjectByNames(objectName string, objectType string) (object kubernetesinterfaces.Object, err error)

func (*CommandExecutorNamespace) GetRoleByName 

func (c *CommandExecutorNamespace) GetRoleByName(name string) (role kubernetesinterfaces.Role, err error)

func (*CommandExecutorNamespace) GetSecretByName 

func (c *CommandExecutorNamespace) GetSecretByName(name string) (secret kubernetesinterfaces.Secret, err error)

func (*CommandExecutorNamespace) ListRoleNames 

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

func (*CommandExecutorNamespace) RoleByNameExists 

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

func (*CommandExecutorNamespace) RunCommand 

func (c *CommandExecutorNamespace) RunCommand(ctx context.Context, runCommandOptions *parameteroptions.RunCommandOptions) (commandOutput *commandoutput.CommandOutput, err error)

func (*CommandExecutorNamespace) RunCommandAndGetStdoutAsLines 

func (c *CommandExecutorNamespace) RunCommandAndGetStdoutAsLines(ctx context.Context, runCommandOptions *parameteroptions.RunCommandOptions) (lines []string, err error)

func (*CommandExecutorNamespace) SecretByNameExists 

func (c *CommandExecutorNamespace) SecretByNameExists(ctx context.Context, name string) (bool, error)

func (*CommandExecutorNamespace) SetKubernetesCluster 

func (c *CommandExecutorNamespace) SetKubernetesCluster(kubernetesCluster kubernetesinterfaces.KubernetesCluster) (err error)

func (*CommandExecutorNamespace) SetName 

func (c *CommandExecutorNamespace) SetName(name string) (err error)

func (*CommandExecutorNamespace) WaitUntilAllPodsInNamespaceAreRunning added in v0.345.0 

func (c *CommandExecutorNamespace) WaitUntilAllPodsInNamespaceAreRunning(ctx context.Context, options *kubernetesparameteroptions.WaitForPodsOptions) error

func (*CommandExecutorNamespace) WatchConfigMap added in v0.332.0 

func (c *CommandExecutorNamespace) WatchConfigMap(ctx context.Context, name string, onCreate func(kubernetesinterfaces.ConfigMap), onUpdate func(kubernetesinterfaces.ConfigMap), onDelete func(kubernetesinterfaces.ConfigMap)) error

type CommandExecutorObject added in v0.349.0 

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

func NewCommandExecutorObject added in v0.349.0 

func NewCommandExecutorObject() (c *CommandExecutorObject)

func (*CommandExecutorObject) CreateByYamlString added in v0.349.0 

func (c *CommandExecutorObject) CreateByYamlString(ctx context.Context, options *kubernetesparameteroptions.CreateObjectOptions) (err error)

func (*CommandExecutorObject) Delete added in v0.349.0 

func (c *CommandExecutorObject) Delete(ctx context.Context) (err error)

func (*CommandExecutorObject) EnsureNamespaceExists added in v0.349.0 

func (c *CommandExecutorObject) EnsureNamespaceExists(ctx context.Context) (err error)

func (*CommandExecutorObject) Exists added in v0.349.0 

func (c *CommandExecutorObject) Exists(ctx context.Context) (exists bool, err error)

func (*CommandExecutorObject) GetAsYamlString added in v0.349.0 

func (c *CommandExecutorObject) GetAsYamlString() (yamlString string, err error)

func (*CommandExecutorObject) GetClusterName added in v0.349.0 

func (c *CommandExecutorObject) GetClusterName() (clusterName string, err error)

func (*CommandExecutorObject) GetCommandExecutor added in v0.349.0 

func (c *CommandExecutorObject) GetCommandExecutor() (commandExecutor commandexecutorinterfaces.CommandExecutor, err error)

func (*CommandExecutorObject) GetKubectlContext added in v0.349.0 

func (c *CommandExecutorObject) GetKubectlContext(ctx context.Context) (contextName string, err error)

func (*CommandExecutorObject) GetName added in v0.349.0 

func (c *CommandExecutorObject) GetName() (name string, err error)

func (*CommandExecutorObject) GetNamespace added in v0.349.0 

func (c *CommandExecutorObject) GetNamespace() (namespace kubernetesinterfaces.Namespace, err error)

func (*CommandExecutorObject) GetNamespaceName added in v0.349.0 

func (c *CommandExecutorObject) GetNamespaceName() (namsepaceName string, err error)

func (*CommandExecutorObject) GetObjectAndTypeAndNamespaceAndClusterName added in v0.349.0 

func (c *CommandExecutorObject) GetObjectAndTypeAndNamespaceAndClusterName() (objectName string, objectTypeName string, namespaceName string, clusterName string, err error)

func (*CommandExecutorObject) GetTypeName added in v0.349.0 

func (c *CommandExecutorObject) GetTypeName() (typeName string, err error)

func (*CommandExecutorObject) SetApiVersion added in v0.349.0 

func (c *CommandExecutorObject) SetApiVersion(apiVersion string) error

func (*CommandExecutorObject) SetCommandExecutor added in v0.349.0 

func (c *CommandExecutorObject) SetCommandExecutor(commandExecutor commandexecutorinterfaces.CommandExecutor) (err error)

func (*CommandExecutorObject) SetName added in v0.349.0 

func (c *CommandExecutorObject) SetName(name string) (err error)

func (*CommandExecutorObject) SetNamespace added in v0.349.0 

func (c *CommandExecutorObject) SetNamespace(namespace kubernetesinterfaces.Namespace) (err error)

func (*CommandExecutorObject) SetTypeName added in v0.349.0 

func (c *CommandExecutorObject) SetTypeName(typeName string) (err error)

type CommandExecutorRole 

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

func NewCommandExecutorRole 

func NewCommandExecutorRole() (c *CommandExecutorRole)

func (*CommandExecutorRole) GetName 

func (c *CommandExecutorRole) GetName() (name string, err error)

func (*CommandExecutorRole) GetNamespace 

func (c *CommandExecutorRole) GetNamespace() (namespace kubernetesinterfaces.Namespace, err error)

func (*CommandExecutorRole) SetName 

func (c *CommandExecutorRole) SetName(name string) (err error)

func (*CommandExecutorRole) SetNamespace 

func (c *CommandExecutorRole) SetNamespace(namespace kubernetesinterfaces.Namespace) (err 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.