util

May 28, 2019

Changes in this version

type Context

+ RemoveBinaries bool

Mar 21, 2019

Changes in this version

+ func HackIssue321InitDynamicClient(ctx *Context) error

type Context

+ DynamicClient dynclient.Client

Mar 8, 2019

Changes in this version

+ func BuildKubernetesClientset(ctx *Context) error

+ func DownloadKubeconfig(cluster *config.Cluster) ([]byte, error)

+ func IsRunning(stdout string) bool

+ func MakeShellCommand(cmd string, variables TemplateVariables) (string, error)

+ type Configuration struct

+ func NewConfiguration() *Configuration

+ func (c *Configuration) AddFile(filename string, content string)

+ func (c *Configuration) Backup(target string) error

+ func (c *Configuration) Debug()

+ func (c *Configuration) Download(conn ssh.Connection, source string, prefix string) error

+ func (c *Configuration) Get(filename string) (string, error)

+ func (c *Configuration) UploadTo(conn ssh.Connection, directory string) error

+ type Context struct

+ APIExtensionClientset *apiextensionsclientset.Clientset

+ BackupFile string

+ Clientset *kubernetes.Clientset

+ Cluster *config.Cluster

+ Configuration *Configuration

+ Connector *ssh.Connector

+ DestroyWorkers bool

+ ForceUpgrade bool

+ JoinCommand string

+ JoinToken string

+ Logger logrus.FieldLogger

+ RESTConfig *rest.Config

+ Runner *Runner

+ UpgradeMachineDeployments bool

+ Verbose bool

+ WorkDir string

+ func (c *Context) Clone() *Context

+ func (c *Context) RunTaskOnAllNodes(task NodeTask, parallel bool) error

+ func (c *Context) RunTaskOnFollowers(task NodeTask, parallel bool) error

+ func (c *Context) RunTaskOnLeader(task NodeTask) error

+ func (c *Context) RunTaskOnNodes(nodes []*config.HostConfig, task NodeTask, parallel bool) error

+ type NodeTask func(ctx *Context, node *config.HostConfig, conn ssh.Connection) error

+ type Runner struct

+ Conn ssh.Connection

+ OS string

+ Prefix string

+ Verbose bool

+ func (r *Runner) Run(cmd string, variables TemplateVariables) (string, string, error)

+ func (r *Runner) WaitForCondition(cmd string, timeout time.Duration, validator validatorFunc) bool

+ func (r *Runner) WaitForPod(namespace string, name string, timeout time.Duration) error

+ type Tee struct

+ func NewTee(wc io.WriteCloser) *Tee

+ func (t *Tee) Close() error

+ func (t *Tee) String() string

+ func (t *Tee) Write(p []byte) (int, error)

+ type TemplateVariables map[string]interface