kubernetes

package

v3.1.0 Latest Latest Go to latest Published: Jun 11, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Details

kubernetes package provides access to log collections on k8s

This section is empty.

This section is empty.

func GetClientset() (*kubernetes.Clientset, *rest.Config, error)

func GetClusters() ([]string, error)

type K8SWriter struct {
	Output cli.OutputHandler
	Buff   *bytes.Buffer
}

func (w *K8SWriter) Write(p []byte) (n int, err error)

type KubeArgs struct {
	Namespace     string
	LabelSelector string
}

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

KubeCtlAPIActions provides a way to collect and copy files using kubectl

func NewK8sAPI(kubeArgs KubeArgs, hook shutdown.CancelHook) (*KubeCtlAPIActions, error)

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

func (c *KubeCtlAPIActions) CleanupRemote() error

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

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

func (c *KubeCtlAPIActions) GetClient() *kubernetes.Clientset

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

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

func (c *KubeCtlAPIActions) HelpText() string

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

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

func (c *KubeCtlAPIActions) Name() string

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

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

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

func (t *TarPipe) Read(p []byte) (n int, err error)