Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controller

package

Go to main page

Versions in this module

v0

v0.13.1

Apr 15, 2021

v0.13.0

Apr 7, 2021

Changes in this version

+ type KubeRouter struct

+ func NewKubeRouter(clusterConf *config.ClusterConfig, manifestsSaver manifestsSaver) (*KubeRouter, error)

+ func (c *KubeRouter) Healthy() error

+ func (c *KubeRouter) Init() error

+ func (c *KubeRouter) Run() error

+ func (c *KubeRouter) Stop() error

v0.13.0-rc.1

Apr 7, 2021

v0.13.0-beta.1

Apr 7, 2021

v0.12.1

Mar 30, 2021

v0.12.1-rc.2

Mar 30, 2021

v0.12.1-rc.1

Mar 29, 2021

v0.12.0

Mar 25, 2021

Changes in this version

type APIServer

+ EnableKonnectivity bool

v0.12.0-rc.2

Mar 24, 2021

v0.12.0-rc.1

Mar 23, 2021

v0.11.1

Mar 17, 2021

v0.11.1-rc.2

Mar 10, 2021

v0.11.1-rc.1

Mar 10, 2021

v0.11.0

Mar 2, 2021

Changes in this version

+ type APIEndpointReconciler struct

+ ClusterConfig *config.ClusterConfig

+ L *logrus.Entry

+ func NewEndpointReconciler(c *k0sv1beta1.ClusterConfig, leaderElector LeaderElector, ...) *APIEndpointReconciler

+ func (a *APIEndpointReconciler) Healthy() error

+ func (a *APIEndpointReconciler) Init() error

+ func (a *APIEndpointReconciler) Run() error

+ func (a *APIEndpointReconciler) Stop() error

+ type APIServer struct

+ ClusterConfig *config.ClusterConfig

+ K0sVars constant.CfgVars

+ LogLevel string

+ Storage component.Component

+ func (a *APIServer) Healthy() error

+ func (a *APIServer) Init() error

+ func (a *APIServer) Run() error

+ func (a *APIServer) Stop() error

+ type CASyncer struct

+ JoinClient *v1beta1.JoinClient

+ K0sVars constant.CfgVars

+ func (c *CASyncer) Healthy() error

+ func (c *CASyncer) Init() error

+ func (c *CASyncer) Run() error

+ func (c *CASyncer) Stop() error

+ type CRD struct

+ func NewCRD(s manifestsSaver) *CRD

+ func (c CRD) Healthy() error

+ func (c CRD) Init() error

+ func (c CRD) Run() error

+ func (c CRD) Stop() error

+ type CSRApprover struct

+ ClusterConfig *config.ClusterConfig

+ KubeClientFactory kubeutil.ClientFactory

+ L *logrus.Entry

+ func NewCSRApprover(c *k0sv1beta1.ClusterConfig, leaderElector LeaderElector, ...) *CSRApprover

+ func (a *CSRApprover) Healthy() error

+ func (a *CSRApprover) Init() error

+ func (a *CSRApprover) Run() error

+ func (a *CSRApprover) Stop() error

+ type Calico struct

+ func NewCalico(clusterConf *config.ClusterConfig, crdSaver manifestsSaver, ...) (*Calico, error)

+ func (c *Calico) Healthy() error

+ func (c *Calico) Init() error

+ func (c *Calico) Run() error

+ func (c *Calico) Stop() error

+ type Certificates struct

+ CACert string

+ CertManager certificate.Manager

+ ClusterSpec *config.ClusterSpec

+ K0sVars constant.CfgVars

+ func (c *Certificates) Healthy() error

+ func (c *Certificates) Init() error

+ func (c *Certificates) Run() error

+ func (c *Certificates) Stop() error

+ type CoreDNS struct

+ K0sVars constant.CfgVars

+ func NewCoreDNS(clusterConfig *config.ClusterConfig, k0sVars constant.CfgVars, ...) (*CoreDNS, error)

+ func (c *CoreDNS) Healthy() error

+ func (c *CoreDNS) Init() error

+ func (c *CoreDNS) Run() error

+ func (c *CoreDNS) Stop() error

+ type DefaultPSP struct

+ func NewDefaultPSP(clusterSpec *config.ClusterSpec, k0sVars constant.CfgVars) (*DefaultPSP, error)

+ func (d *DefaultPSP) Healthy() error

+ func (d *DefaultPSP) Init() error

+ func (d *DefaultPSP) Run() error

+ func (d *DefaultPSP) Stop() error

+ type DummyLeaderElector struct

+ Leader bool

+ func (l *DummyLeaderElector) AddAcquiredLeaseCallback(fn func())

+ func (l *DummyLeaderElector) AddLostLeaseCallback(fn func())

+ func (l *DummyLeaderElector) Healthy() error

+ func (l *DummyLeaderElector) Init() error

+ func (l *DummyLeaderElector) IsLeader() bool

+ func (l *DummyLeaderElector) Run() error

+ func (l *DummyLeaderElector) Stop() error

+ type Etcd struct

+ CertManager certificate.Manager

+ Config *config.EtcdConfig

+ Join bool

+ JoinClient *v1beta1.JoinClient

+ K0sVars constant.CfgVars

+ LogLevel string

+ func (e *Etcd) Healthy() error

+ func (e *Etcd) Init() error

+ func (e *Etcd) Run() error

+ func (e *Etcd) Stop() error

+ type FsManifestsSaver struct

+ func NewManifestsSaver(dir string, dataDir string) (*FsManifestsSaver, error)

+ func (f FsManifestsSaver) Save(dst string, content []byte) error

+ type HelmAddons struct

+ Client clientset.ChartV1Beta1Interface

+ ClusterConfig *k0sv1beta1.ClusterConfig

+ L *logrus.Entry

+ func NewHelmAddons(c *k0sv1beta1.ClusterConfig, s manifestsSaver, k0sVars constant.CfgVars, ...) *HelmAddons

+ func (h *HelmAddons) CrdControlLoop()

+ func (h *HelmAddons) Healthy() error

+ func (h *HelmAddons) Init() error

+ func (h *HelmAddons) Run() error

+ func (h *HelmAddons) Stop() error

+ type K0SControlAPI struct

+ ClusterConfig *config.ClusterConfig

+ ConfigPath string

+ K0sVars constant.CfgVars

+ func (m *K0SControlAPI) Healthy() error

+ func (m *K0SControlAPI) Init() error

+ func (m *K0SControlAPI) Run() error

+ func (m *K0SControlAPI) Stop() error

+ type K0sLease struct

+ ClusterConfig *config.ClusterConfig

+ KubeClientFactory kubeutil.ClientFactory

+ func (l *K0sLease) Healthy() error

+ func (l *K0sLease) Init() error

+ func (l *K0sLease) Run() error

+ func (l *K0sLease) Stop() error

+ type Kine struct

+ Config *config.KineConfig

+ K0sVars constant.CfgVars

+ func (k *Kine) Healthy() error

+ func (k *Kine) Init() error

+ func (k *Kine) Run() error

+ func (k *Kine) Stop() error

+ type Konnectivity struct

+ ClusterConfig *config.ClusterConfig

+ K0sVars constant.CfgVars

+ KubeClientFactory k8sutil.ClientFactory

+ LogLevel string

+ func (k *Konnectivity) Healthy() error

+ func (k *Konnectivity) Init() error

+ func (k *Konnectivity) Run() error

+ func (k *Konnectivity) Stop() error

+ type KubeProxy struct

+ K0sVars constant.CfgVars

+ func NewKubeProxy(clusterSpec *config.ClusterConfig, k0sVars constant.CfgVars) (*KubeProxy, error)

+ func (k *KubeProxy) Healthy() error

+ func (k *KubeProxy) Init() error

+ func (k *KubeProxy) Run() error

+ func (k *KubeProxy) Stop() error

+ type KubeletConfig struct

+ func NewKubeletConfig(clusterSpec *config.ClusterSpec, k0sVars constant.CfgVars) (*KubeletConfig, error)

+ func (k *KubeletConfig) Healthy() error

+ func (k *KubeletConfig) Init() error

+ func (k *KubeletConfig) Run() error

+ func (k *KubeletConfig) Stop() error

+ type LeaderElector interface

+ AddAcquiredLeaseCallback func(fn func())

+ AddLostLeaseCallback func(fn func())

+ IsLeader func() bool

+ func NewLeaderElector(c *k0sv1beta1.ClusterConfig, kubeClientFactory kubeutil.ClientFactory) LeaderElector

+ type Manager struct

+ ClusterConfig *config.ClusterConfig

+ K0sVars constant.CfgVars

+ LogLevel string

+ func (a *Manager) Healthy() error

+ func (a *Manager) Init() error

+ func (a *Manager) Run() error

+ func (a *Manager) Stop() error

+ type MetricServer struct

+ K0sVars constant.CfgVars

+ func NewMetricServer(clusterConfig *config.ClusterConfig, k0sVars constant.CfgVars, ...) (*MetricServer, error)

+ func (m *MetricServer) Healthy() error

+ func (m *MetricServer) Init() error

+ func (m *MetricServer) Run() error

+ func (m *MetricServer) Stop() error

+ type Scheduler struct

+ ClusterConfig *config.ClusterConfig

+ K0sVars constant.CfgVars

+ LogLevel string

+ func (a *Scheduler) Healthy() error

+ func (a *Scheduler) Init() error

+ func (a *Scheduler) Run() error

+ func (a *Scheduler) Stop() error

+ type SystemRBAC struct

+ func NewSystemRBAC(manifestDir string) (*SystemRBAC, error)

+ func (s *SystemRBAC) Healthy() error

+ func (s *SystemRBAC) Init() error

+ func (s *SystemRBAC) Run() error

+ func (s *SystemRBAC) Stop() error

v0.11.0-rc1

Mar 2, 2021

v0.11.0-beta.3

Feb 25, 2021

v0.11.0-beta.2

Feb 22, 2021

v0.11.0-beta.1

Feb 19, 2021