k8s

Documentation

Index

• Constants
• func ExecCommand(ctx context.Context, cfg *rest.Config, ...) error
• type ExecOptions
  • func (o *ExecOptions) CreateTTY() (term.TTY, remotecommand.TerminalSizeQueue, error)
• type JobRunner
  • func (r JobRunner) Run(ctx context.Context, options admin.RunOptions, cmd []string) error
• type PortForwarder
  • func NewPortForwarder(cfg *rest.Config, podNamespace, podName string, portMappings []string) (*PortForwarder, error)
  • func (f *PortForwarder) ForwardPorts(stop <-chan struct{}, opts *ExecOptions)

Constants

const DefaultWatchInterval = 1 * time.Second

Functions

func ExecCommand

func ExecCommand(ctx context.Context, cfg *rest.Config, podNamespace, podName, containerName string, cmd []string, opts *ExecOptions) error

Types

type ExecOptions

type ExecOptions struct {
	In              io.Reader
	Out             io.Writer
	ErrOut          io.Writer
	TTY             bool
	InterruptParent *interrupt.Handler
	PortMappings    []string
}

func (*ExecOptions) CreateTTY

func (o *ExecOptions) CreateTTY() (term.TTY, remotecommand.TerminalSizeQueue, error)

type JobRunner

type JobRunner struct {
	Namespace         string
	AppName           string
	MainContainerName string
	JobDefinitionName string
	NewConfigFn       k8s.NewConfiger
}

func (JobRunner) Run

func (r JobRunner) Run(ctx context.Context, options admin.RunOptions, cmd []string) error

type PortForwarder

type PortForwarder struct {
	Transport http.RoundTripper
	Upgrader  spdy.Upgrader
	Request   *rest.Request
}

func NewPortForwarder

func NewPortForwarder(cfg *rest.Config, podNamespace, podName string, portMappings []string) (*PortForwarder, error)

func (*PortForwarder) ForwardPorts

func (f *PortForwarder) ForwardPorts(stop <-chan struct{}, opts *ExecOptions)