pns

Documentation

Index

• type PNSExecutor
  • func NewPNSExecutor(clientset *kubernetes.Clientset, podName, namespace string) (*PNSExecutor, error)
  • func (p *PNSExecutor) CopyFile(containerName string, sourcePath string, destPath string, compressionLevel int) (err error)
  • func (p *PNSExecutor) GetFileContents(containerName string, sourcePath string) (string, error)
  • func (p *PNSExecutor) Kill(ctx context.Context, containerNames []string, ...) error
  • func (p *PNSExecutor) ListContainerNames(ctx context.Context) ([]string, error)
  • func (p *PNSExecutor) Wait(ctx context.Context, containerNames []string) error

Types

type PNSExecutor

type PNSExecutor struct {
	*k8sapi.K8sAPIExecutor
	// contains filtered or unexported fields
}

func NewPNSExecutor

func NewPNSExecutor(clientset *kubernetes.Clientset, podName, namespace string) (*PNSExecutor, error)

func (*PNSExecutor) CopyFile

func (p *PNSExecutor) CopyFile(containerName string, sourcePath string, destPath string, compressionLevel int) (err error)

CopyFile copies a source file in a container to a local path

func (*PNSExecutor) GetFileContents

func (p *PNSExecutor) GetFileContents(containerName string, sourcePath string) (string, error)

func (*PNSExecutor) Kill

func (p *PNSExecutor) Kill(ctx context.Context, containerNames []string, terminationGracePeriodDuration time.Duration) error

Kill a list of containers first with a SIGTERM then with a SIGKILL after a grace period

func (*PNSExecutor) ListContainerNames

func (p *PNSExecutor) ListContainerNames(ctx context.Context) ([]string, error)

func (*PNSExecutor) Wait

func (p *PNSExecutor) Wait(ctx context.Context, containerNames []string) error