kubernetes

Documentation

Index

• type BackupPod
• type ExecData
  • func PodExec(pod BackupPod, log logr.Logger) (*ExecData, error)
• type PodLister
  • func NewPodLister(ctx context.Context, ...) *PodLister
  • func (p *PodLister) ListPods() ([]BackupPod, error)

Types

type BackupPod

type BackupPod struct {
	Command       string
	PodName       string
	ContainerName string
	Namespace     string
	FileExtension string
}

BackupPod contains all information nessecary to execute the backupcommands.

type ExecData

type ExecData struct {
	Reader *io.PipeReader
	Done   chan bool
}

func PodExec

func PodExec(pod BackupPod, log logr.Logger) (*ExecData, error)

PodExec sends the command to the specified pod and returns a bytes buffer with the stdout

type PodLister

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

PodLister holds the state for listing the pods.

func NewPodLister

func NewPodLister(ctx context.Context, backupCommandAnnotation, fileExtensionAnnotation, namespace string, log logr.Logger) *PodLister

NewPodLister returns a PodLister configured to find the defined annotations.

func (*PodLister) ListPods

func (p *PodLister) ListPods() ([]BackupPod, error)

ListPods resturns a list of pods which have backup commands in their annotations.