kubectl

Documentation

Overview

kubectl package provides access to log collections on k8s

Index

• type CliK8sActions
  • func NewKubectlK8sActions(hook shutdown.CancelHook, namespace string) (*CliK8sActions, error)
  • func (c *CliK8sActions) CleanupRemote() error
  • func (c *CliK8sActions) CopyFromHost(hostString string, source, destination string) (out string, err error)
  • func (c *CliK8sActions) CopyToHost(hostString string, source, destination string) (out string, err error)
  • func (c *CliK8sActions) GetCoordinators() (podName []string, err error)
  • func (c *CliK8sActions) GetExecutors() (podName []string, err error)
  • func (c *CliK8sActions) HelpText() string
  • func (c *CliK8sActions) HostExecute(mask bool, hostString string, args ...string) (out string, err error)
  • func (c *CliK8sActions) HostExecuteAndStream(mask bool, hostString string, output cli.OutputHandler, pat string, ...) (err error)
  • func (c *CliK8sActions) Name() string
  • func (c *CliK8sActions) SearchPods(compare func(container string) bool) (podName []string, err error)
  • func (c *CliK8sActions) SetHostPid(host, pidFile string)
• type KubeArgs

Types

type CliK8sActions

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

CliK8sActions provides a way to collect and copy files using kubectl

func NewKubectlK8sActions

func NewKubectlK8sActions(hook shutdown.CancelHook, namespace string) (*CliK8sActions, error)

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

func (*CliK8sActions) CleanupRemote

func (c *CliK8sActions) CleanupRemote() error

func (*CliK8sActions) CopyFromHost

func (c *CliK8sActions) CopyFromHost(hostString string, source, destination string) (out string, err error)

func (*CliK8sActions) CopyToHost

func (c *CliK8sActions) CopyToHost(hostString string, source, destination string) (out string, err error)

func (*CliK8sActions) GetCoordinators

func (c *CliK8sActions) GetCoordinators() (podName []string, err error)

func (*CliK8sActions) GetExecutors

func (c *CliK8sActions) GetExecutors() (podName []string, err error)

func (*CliK8sActions) HelpText

func (c *CliK8sActions) HelpText() string

func (*CliK8sActions) HostExecute

func (c *CliK8sActions) HostExecute(mask bool, hostString string, args ...string) (out string, err error)

func (*CliK8sActions) HostExecuteAndStream

func (c *CliK8sActions) HostExecuteAndStream(mask bool, hostString string, output cli.OutputHandler, pat string, args ...string) (err error)

func (*CliK8sActions) Name

func (c *CliK8sActions) Name() string

func (*CliK8sActions) SearchPods

func (c *CliK8sActions) SearchPods(compare func(container string) bool) (podName []string, err error)

func (*CliK8sActions) SetHostPid

func (c *CliK8sActions) SetHostPid(host, pidFile string)

type KubeArgs

type KubeArgs struct {
	Namespace string
}