kubeexec

Documentation

Index

• Constants
• type KubeConfig
• type KubeExecutor
  • func NewKubeExecutor(config *KubeConfig) (*KubeExecutor, error)
  • func (k *KubeExecutor) ConnectAndExec(host, resource string, commands []string, timeoutMinutes int) ([]string, error)
  • func (k *KubeExecutor) RebalanceOnExpansion() bool
  • func (k *KubeExecutor) RemoteCommandExecute(host string, commands []string, timeoutMinutes int) ([]string, error)
  • func (k *KubeExecutor) SnapShotLimit() int

Constants

const (
	KubeGlusterFSPodLabelKey = "glusterfs-node"
)

Types

type KubeConfig

type KubeConfig struct {
	sshexec.CLICommandConfig
	Host      string `json:"host"`
	CertFile  string `json:"cert"`
	Insecure  bool   `json:"insecure"`
	User      string `json:"user"`
	Password  string `json:"password"`
	Token     string `json:"token"`
	Namespace string `json:"namespace"`
	// Use Secrets to get the Bearerkey
	UseSecrets bool `json:"use_secrets"`

	TokenFile     string `json:"token_file"`
	NamespaceFile string `json:"namespace_file"`

	// Use POD name instead of using label
	// to access POD
	UsePodNames bool `json:"use_pod_names"`
}

type KubeExecutor

type KubeExecutor struct {
	// Embed all sshexecutor functions
	sshexec.SshExecutor
	// contains filtered or unexported fields
}

func NewKubeExecutor

func NewKubeExecutor(config *KubeConfig) (*KubeExecutor, error)

func (*KubeExecutor) ConnectAndExec

func (k *KubeExecutor) ConnectAndExec(host, resource string,
	commands []string,
	timeoutMinutes int) ([]string, error)

func (*KubeExecutor) RebalanceOnExpansion

func (k *KubeExecutor) RebalanceOnExpansion() bool

func (*KubeExecutor) RemoteCommandExecute

func (k *KubeExecutor) RemoteCommandExecute(host string,
	commands []string,
	timeoutMinutes int) ([]string, error)

func (*KubeExecutor) SnapShotLimit

func (k *KubeExecutor) SnapShotLimit() int