cluster

Nov 8, 2024

Changes in this version

type Flags

+ func (f Flags) Each(fn func(string, string))

+ func (f Flags) Equals(b Flags) bool

+ func (f Flags) Map() map[string]string

type Host

+ func (h *Host) K0sInstallFlags() (Flags, error)

+ func (h *Host) K0sRole() string

Oct 23, 2024

Changes in this version

type Spec

+ func (s *Spec) APIPort() int

+ func (s *Spec) InternalKubeAPIURL() string

+ func (s *Spec) NodeInternalKubeAPIURL(h *Host) string

Sep 11, 2024

Changes in this version

+ var K0sForceFlagSince = version.MustConstraint(">= v1.27.4+k0s.0")

type Host

+ func (h *Host) FlagsChanged() bool

type HostMetadata

+ K0sStatusArgs []string

May 8, 2024

Changes in this version

type Host

+ K0sDownloadURL string

+ func (h *Host) ExpandTokens(input string, k0sVersion *version.Version) string

type K0s

+ func (k *K0s) MarshalYAML() (interface{}, error)

type Spec

+ func (s *Spec) MarshalYAML() (interface{}, error)

Jan 4, 2024

Changes in this version

type Host

+ func (h *Host) CordonNode(node *Host) error

type HostMetadata

+ DryRunFakeLeader bool

+ K0sExistingConfig string

+ K0sInstalled bool

+ K0sJoinToken string

+ K0sJoinTokenID string

+ K0sNewConfig string

type Hosts

+ func (hosts Hosts) Each(filters ...func(h *Host) error) error

type K0s

+ VersionChannel string

type Spec

+ func (s *Spec) SetDefaults()

Aug 16, 2023

Changes in this version

type Host

+ func (h *Host) K0sDataDir() string

+ func (h *Host) WaitK0sDynamicConfigReady() error

type K0s

+ func (k K0s) VersionEqual(b string) bool

Aug 1, 2023

Changes in this version

type K0s

+ func (k K0s) VersionMustEqual(b string) error

Mar 20, 2023

Changes in this version

type Host

+ DataDir string

+ func (h *Host) InstallK0sBinary(path string) error

type HostMetadata

+ K0sBinaryTempFile string

Dec 16, 2022

Changes in this version

type Flags

+ func (f Flags) GetBoolean(s string) (bool, error)

type Host

+ Reset bool

+ func (h *Host) DeleteNode(node *Host) error

+ func (h *Host) LeaveEtcd(node *Host) error

type HostMetadata

+ MachineID string

type Hosts

+ func (hosts Hosts) BatchedParallelEach(batchSize int, filter ...func(h *Host) error) error

May 27, 2022

Changes in this version

type Flags

+ func (f *Flags) AddWithValue(key, value string)

type Host

+ NoTaints bool

+ func (h *Host) FileChanged(lpath, rpath string) bool

type K0s

+ DynamicConfig bool

+ func (k *K0s) NodeConfig() dig.Mapping

Dec 16, 2021

Changes in this version

+ const K0sMinVersion

+ func TokenID(s string) (string, error)

+ type Flags []string

+ func (f *Flags) Add(s string)

+ func (f *Flags) AddOrReplace(s string)

+ func (f *Flags) AddUnlessExist(s string)

+ func (f *Flags) Delete(s string)

+ func (f *Flags) Join() string

+ func (f *Flags) Merge(b Flags)

+ func (f *Flags) MergeAdd(b Flags)

+ func (f *Flags) MergeOverwrite(b Flags)

+ func (f Flags) Get(s string) string

+ func (f Flags) GetValue(s string) string

+ func (f Flags) Include(s string) bool

+ func (f Flags) Index(s string) int

+ type Hooks map[string]map[string][]string

+ func (h Hooks) ForActionAndStage(action, stage string) []string

+ type Host struct

+ Configurer configurer

+ Environment map[string]string

+ Files []*UploadFile

+ Hooks Hooks

+ HostnameOverride string

+ InstallFlags Flags

+ K0sBinaryPath string

+ Metadata HostMetadata

+ OSIDOverride string

+ PrivateAddress string

+ PrivateInterface string

+ Role string

+ UploadBinary bool

+ UploadBinaryPath string

+ func (h *Host) Address() string

+ func (h *Host) CheckHTTPStatus(url string, expected ...int) error

+ func (h *Host) DrainNode(node *Host) error

+ func (h *Host) IsController() bool

+ func (h *Host) K0sBackupCommand(targetDir string) string

+ func (h *Host) K0sConfigPath() string

+ func (h *Host) K0sInstallCommand() string

+ func (h *Host) K0sJoinTokenPath() string

+ func (h *Host) K0sRestoreCommand(backupfile string) string

+ func (h *Host) K0sServiceName() string

+ func (h *Host) KubeNodeReady(node *Host) (bool, error)

+ func (h *Host) NeedCurl() bool

+ func (h *Host) NeedIPTables() bool

+ func (h *Host) NeedInetUtils() bool

+ func (h *Host) Protocol() string

+ func (h *Host) ResolveConfigurer() error

+ func (h *Host) SetDefaults()

+ func (h *Host) UncordonNode(node *Host) error

+ func (h *Host) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (h *Host) UpdateK0sBinary(version string) error

+ func (h *Host) Validate() error

+ func (h *Host) WaitHTTPStatus(url string, expected ...int) error

+ func (h *Host) WaitK0sServiceRunning() error

+ func (h *Host) WaitK0sServiceStopped() error

+ func (h *Host) WaitKubeAPIReady(port int) error

+ func (h *Host) WaitKubeNodeReady(node *Host) error

+ type HostMetadata struct

+ Arch string

+ Hostname string

+ IsK0sLeader bool

+ K0sBinaryVersion string

+ K0sRunningVersion string

+ NeedsUpgrade bool

+ Ready bool

+ type Hosts []*Host

+ func (hosts Hosts) Controllers() Hosts

+ func (hosts Hosts) Filter(filter func(h *Host) bool) Hosts

+ func (hosts Hosts) Find(filter func(h *Host) bool) *Host

+ func (hosts Hosts) First() *Host

+ func (hosts Hosts) Last() *Host

+ func (hosts Hosts) ParallelEach(filter ...func(h *Host) error) error

+ func (hosts Hosts) Validate() error

+ func (hosts Hosts) WithRole(s string) Hosts

+ func (hosts Hosts) Workers() Hosts

+ type K0s struct

+ Config dig.Mapping

+ Metadata K0sMetadata

+ Version string

+ func (k *K0s) SetDefaults()

+ func (k *K0s) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (k *K0s) Validate() error

+ func (k K0s) GenerateToken(h *Host, role string, expiry time.Duration) (token string, err error)

+ func (k K0s) GetClusterID(h *Host) (string, error)

+ type K0sMetadata struct

+ ClusterID string

+ VersionDefaulted bool

+ type LocalFile struct

+ Path string

+ PermMode string

+ type Spec struct

+ Hosts Hosts

+ K0s *K0s

+ func (s *Spec) K0sLeader() *Host

+ func (s *Spec) KubeAPIURL() string

+ func (s *Spec) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (s *Spec) Validate() error

+ type UploadFile struct

+ Base string

+ DestinationDir string

+ DestinationFile string

+ DirPermMode interface{}

+ DirPermString string

+ Group string

+ Name string

+ PermMode interface{}

+ PermString string

+ Source string

+ Sources []*LocalFile

+ User string

+ func (u *UploadFile) IsURL() bool

+ func (u *UploadFile) Owner() string

+ func (u *UploadFile) String() string

+ func (u *UploadFile) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (u UploadFile) Validate() error