kube

Documentation

Index

• func PodExecuteCommand(req ExecCommandRequest) (int, error)
• func PodUploadFile(req UploadFileRequest) (int, error)
• func WrapAsTar(fileNameOnTar string, fileContent []byte) ([]byte, error)
• type ExecCommandRequest
• type KubeRequest
• type KubernetesApiService
  • func NewKubernetesApiService(clientset *kubernetes.Clientset, restConfig *rest.Config, ...) KubernetesApiService
• type KubernetesApiServiceImpl
  • func (k *KubernetesApiServiceImpl) CreatePrivilegedPod(nodeName string, containerName string, image string, socketPath string, ...) (*corev1.Pod, error)
  • func (k *KubernetesApiServiceImpl) DeletePod(podName string) error
  • func (k *KubernetesApiServiceImpl) ExecuteCommand(podName string, containerName string, command []string, stdOut io.Writer) (int, error)
  • func (k *KubernetesApiServiceImpl) IsSupportedContainerRuntime(nodeName string) (bool, error)
  • func (k *KubernetesApiServiceImpl) UploadFile(localPath string, remotePath string, podName string, containerName string) error
• type NopWriter
  • func (w *NopWriter) Write(p []byte) (n int, err error)
• type UploadFileRequest
• type Writer
  • func (w *Writer) Write(p []byte) (n int, err error)

Functions

func PodExecuteCommand

func PodExecuteCommand(req ExecCommandRequest) (int, error)

func PodUploadFile

func PodUploadFile(req UploadFileRequest) (int, error)

func WrapAsTar

func WrapAsTar(fileNameOnTar string, fileContent []byte) ([]byte, error)

Types

type ExecCommandRequest

type ExecCommandRequest struct {
	KubeRequest
	Command []string
	StdIn   io.Reader
	StdOut  io.Writer
	StdErr  io.Writer
}

type KubeRequest

type KubeRequest struct {
	Clientset  *kubernetes.Clientset
	RestConfig *rest.Config
	Namespace  string
	Pod        string
	Container  string
}

type KubernetesApiService

type KubernetesApiService interface {
	ExecuteCommand(podName string, containerName string, command []string, stdOut io.Writer) (int, error)

	DeletePod(podName string) error

	CreatePrivilegedPod(nodeName string, containerName string, image string, socketPath string, timeout time.Duration) (*corev1.Pod, error)

	UploadFile(localPath string, remotePath string, podName string, containerName string) error
}

func NewKubernetesApiService

func NewKubernetesApiService(clientset *kubernetes.Clientset,
	restConfig *rest.Config, targetNamespace string) KubernetesApiService

type KubernetesApiServiceImpl

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

func (*KubernetesApiServiceImpl) CreatePrivilegedPod

func (k *KubernetesApiServiceImpl) CreatePrivilegedPod(nodeName string, containerName string, image string, socketPath string, timeout time.Duration) (*corev1.Pod, error)

func (*KubernetesApiServiceImpl) DeletePod

func (k *KubernetesApiServiceImpl) DeletePod(podName string) error

func (*KubernetesApiServiceImpl) ExecuteCommand

func (k *KubernetesApiServiceImpl) ExecuteCommand(podName string, containerName string, command []string, stdOut io.Writer) (int, error)

func (*KubernetesApiServiceImpl) IsSupportedContainerRuntime

func (k *KubernetesApiServiceImpl) IsSupportedContainerRuntime(nodeName string) (bool, error)

func (*KubernetesApiServiceImpl) UploadFile

func (k *KubernetesApiServiceImpl) UploadFile(localPath string, remotePath string, podName string, containerName string) error

type NopWriter

type NopWriter struct {
}

func (*NopWriter) Write

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

type UploadFileRequest

type UploadFileRequest struct {
	KubeRequest
	Src string
	Dst string
}

type Writer

type Writer struct {
	Output string
}

func (*Writer) Write

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