bootstrapper

Apr 27, 2019

Changes in this version

+ func GetCachedBinaryList(bootstrapper string) []string

Mar 27, 2019

Changes in this version

type Bootstrapper

+ GetAPIServerStatus func(net.IP) (string, error)

Feb 15, 2019

Changes in this version

type Bootstrapper

+ DeleteCluster func(config.KubernetesConfig) error

+ LogCommands func(LogOptions) map[string]string

+ PullImages func(config.KubernetesConfig) error

+ type LogOptions struct

+ Follow bool

+ Lines int

Dec 10, 2018

Changes in this version

type Bootstrapper

+ GetApiServerStatus func(net.IP) (string, error)

+ GetKubeletStatus func() (string, error)

Apr 10, 2018

Changes in this version

type Bootstrapper

+ GetClusterLogsTo func(follow bool, out io.Writer) error

type CommandRunner

+ CombinedOutputTo func(cmd string, out io.Writer) error

type ExecRunner

+ func (*ExecRunner) CombinedOutputTo(cmd string, out io.Writer) error

type FakeCommandRunner

+ func (f *FakeCommandRunner) CombinedOutputTo(cmd string, out io.Writer) error

type SSHRunner

+ func (s *SSHRunner) CombinedOutputTo(cmd string, out io.Writer) error

Jan 26, 2018

Changes in this version

type KubernetesConfig

+ APIServerIPs []net.IP

+ APIServerNames []string

Nov 29, 2017

Changes in this version

type KubernetesConfig

+ ServiceCIDR string

Sep 18, 2017

Changes in this version

+ const BootstrapperTypeKubeadm

+ func GetCachedImageList(version string, bootstrapper string) []string

Sep 7, 2017

Changes in this version

+ const BootstrapperTypeLocalkube

+ var CachedImagesForBootstrapper = map[string][]string

+ func SetupCerts(cmd CommandRunner, k8s KubernetesConfig) error

+ type Bootstrapper interface

+ GetClusterLogs func(follow bool) (string, error)

+ GetClusterStatus func() (string, error)

+ RestartCluster func(KubernetesConfig) error

+ SetupCerts func(cfg KubernetesConfig) error

+ StartCluster func(KubernetesConfig) error

+ UpdateCluster func(KubernetesConfig) error

+ type CommandRunner interface

+ CombinedOutput func(cmd string) (string, error)

+ Copy func(assets.CopyableFile) error

+ Remove func(assets.CopyableFile) error

+ Run func(cmd string) error

+ type ExecRunner struct

+ func (*ExecRunner) CombinedOutput(cmd string) (string, error)

+ func (*ExecRunner) Copy(f assets.CopyableFile) error

+ func (*ExecRunner) Run(cmd string) error

+ func (e *ExecRunner) Remove(f assets.CopyableFile) error

+ type FakeCommandRunner struct

+ func NewFakeCommandRunner() *FakeCommandRunner

+ func (f *FakeCommandRunner) CombinedOutput(cmd string) (string, error)

+ func (f *FakeCommandRunner) Copy(file assets.CopyableFile) error

+ func (f *FakeCommandRunner) DumpMaps(w io.Writer)

+ func (f *FakeCommandRunner) GetFileToContents(filename string) (string, error)

+ func (f *FakeCommandRunner) Remove(file assets.CopyableFile) error

+ func (f *FakeCommandRunner) Run(cmd string) error

+ func (f *FakeCommandRunner) SetCommandToOutput(cmdToOutput map[string]string)

+ func (f *FakeCommandRunner) SetFileToContents(fileToContents map[string]string)

+ type KubernetesConfig struct

+ APIServerName string

+ ContainerRuntime string

+ DNSDomain string

+ ExtraOptions util.ExtraOptionSlice

+ FeatureGates string

+ KubernetesVersion string

+ NetworkPlugin string

+ NodeIP string

+ NodeName string

+ ShouldLoadCachedImages bool

+ type SSHRunner struct

+ func NewSSHRunner(c *ssh.Client) *SSHRunner

+ func (s *SSHRunner) CombinedOutput(cmd string) (string, error)

+ func (s *SSHRunner) Copy(f assets.CopyableFile) error

+ func (s *SSHRunner) Remove(f assets.CopyableFile) error

+ func (s *SSHRunner) Run(cmd string) error