drainer

Documentation

Overview

Package drainer is mostly transplanted from kubectl See: https://github.com/kubernetes/kubernetes/blob/master/pkg/kubectl/cmd/drain/drain.go

Index

• type Drainer
  • func New(client kubernetes.Interface, options *Options) Drainer
• type ErrWriter
  • func (ErrWriter) Write(p []byte) (n int, err error)
• type Options
  • func (o *Options) String() string
• type OutWriter
  • func (OutWriter) Write(p []byte) (n int, err error)

Types

type Drainer

type Drainer interface {
	Drain(nodeName string) error
}

Drainer represents the draining action

func New

func New(client kubernetes.Interface, options *Options) Drainer

New creates a new Drainer with the given Kubernetes client and options

type ErrWriter

type ErrWriter struct{}

ErrWriter allows for log usage inside kubectl drainer implementation

func (ErrWriter) Write

func (ErrWriter) Write(p []byte) (n int, err error)

type Options

type Options struct {
	Node                string
	Force               bool
	GracePeriodSeconds  int
	IgnoreAllDaemonSets bool
	Timeout             time.Duration
	DeleteLocalData     bool
	Selector            string
	PodSelector         string
	DrainDelay          time.Duration `mapstructure:"drain-delay"`
}

Options for the Drainer

func (*Options) String

func (o *Options) String() string

type OutWriter

type OutWriter struct{}

OutWriter allows for log usage inside kubectl drainer implementation

func (OutWriter) Write

func (OutWriter) Write(p []byte) (n int, err error)