connect

Documentation

Index

• Variables
• func Run(ctx context.Context, client ExecClient, namespace, pod string, ...) error
• func RunOnContainer(ctx context.Context, client ExecClient, namespace, pod, container string, ...) error
• func RunWithRetry(ctx context.Context, client ExecClient, namespace, pod string, ...) error
• type ExecClient
• type ExecContainerClient
• type RetryPolicy

Variables

var DefaultRetryPolicy = RetryPolicy{
	MaxAttempts:    3,
	InitialBackoff: 1 * time.Second,
	MaxBackoff:     5 * time.Second,
}

Functions

func Run

func Run(ctx context.Context, client ExecClient, namespace, pod string, command []string, tty bool, stdin io.Reader, stdout io.Writer, stderr io.Writer) error

func RunOnContainer

func RunOnContainer(ctx context.Context, client ExecClient, namespace, pod, container string, command []string, tty bool, stdin io.Reader, stdout io.Writer, stderr io.Writer) error

RunOnContainer executes a command in a specific container within a pod. If container is empty, it falls back to the default ExecInteractive behavior.

func RunWithRetry

func RunWithRetry(ctx context.Context, client ExecClient, namespace, pod string, command []string, tty bool, stdin io.Reader, stdout io.Writer, stderr io.Writer, policy RetryPolicy) error

Types

type ExecClient

type ExecClient interface {
	ExecInteractive(ctx context.Context, namespace, pod string, tty bool, command []string, stdin io.Reader, stdout io.Writer, stderr io.Writer) error
}

type ExecContainerClient

type ExecContainerClient interface {
	ExecClient
	ExecInteractiveInContainer(ctx context.Context, namespace, pod, container string, tty bool, command []string, stdin io.Reader, stdout io.Writer, stderr io.Writer) error
}

ExecContainerClient extends ExecClient with container-targeted exec.

type RetryPolicy

type RetryPolicy struct {
	MaxAttempts    int
	InitialBackoff time.Duration
	MaxBackoff     time.Duration
}