kubernetes

Documentation

Overview

kubernetes package provides access to log collections on k8s

Index

• type KubectlK8sActions
  • func NewKubectlK8sActions(kubectlPath, coordinatorContainer, executorContainer, namespace string) *KubectlK8sActions
  • func (c *KubectlK8sActions) CopyFromHost(hostString string, isCoordinator bool, source, destination string) (out string, err error)
  • func (c *KubectlK8sActions) CopyFromHostSudo(hostString string, isCoordinator bool, _, source, destination string) (out string, err error)
  • func (c *KubectlK8sActions) CopyToHost(hostString string, isCoordinator bool, source, destination string) (out string, err error)
  • func (c *KubectlK8sActions) CopyToHostSudo(hostString string, isCoordinator bool, _, source, destination string) (out string, err error)
  • func (c *KubectlK8sActions) FindHosts(searchTerm string) (podName []string, err error)
  • func (c *KubectlK8sActions) HelpText() string
  • func (c *KubectlK8sActions) HostExecute(hostString string, isCoordinator bool, args ...string) (out string, err error)
  • func (c *KubectlK8sActions) HostExecuteAndStream(hostString string, output cli.OutputHandler, isCoordinator bool, ...) (err error)

Types

type KubectlK8sActions

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

KubectlK8sActions provides a way to collect and copy files using kubectl

func NewKubectlK8sActions

func NewKubectlK8sActions(kubectlPath, coordinatorContainer, executorContainer, namespace string) *KubectlK8sActions

NewKubectlK8sActions is the only supported way to initialize the KubectlK8sActions struct one must pass the path to kubectl

func (*KubectlK8sActions) CopyFromHost

func (c *KubectlK8sActions) CopyFromHost(hostString string, isCoordinator bool, source, destination string) (out string, err error)

func (*KubectlK8sActions) CopyFromHostSudo

func (c *KubectlK8sActions) CopyFromHostSudo(hostString string, isCoordinator bool, _, source, destination string) (out string, err error)

func (*KubectlK8sActions) CopyToHost

func (c *KubectlK8sActions) CopyToHost(hostString string, isCoordinator bool, source, destination string) (out string, err error)

func (*KubectlK8sActions) CopyToHostSudo

func (c *KubectlK8sActions) CopyToHostSudo(hostString string, isCoordinator bool, _, source, destination string) (out string, err error)

func (*KubectlK8sActions) FindHosts

func (c *KubectlK8sActions) FindHosts(searchTerm string) (podName []string, err error)

func (*KubectlK8sActions) HelpText

func (c *KubectlK8sActions) HelpText() string

func (*KubectlK8sActions) HostExecute

func (c *KubectlK8sActions) HostExecute(hostString string, isCoordinator bool, args ...string) (out string, err error)

func (*KubectlK8sActions) HostExecuteAndStream

func (c *KubectlK8sActions) HostExecuteAndStream(hostString string, output cli.OutputHandler, isCoordinator bool, args ...string) (err error)