Documentation ¶
Index ¶
- func BootstrapEtcd(ctx context.Context, r runtime.Runtime, req *machineapi.BootstrapRequest) error
- func IsDirEmpty(name string) (bool, error)
- type APID
- func (o *APID) Condition(r runtime.Runtime) conditions.Condition
- func (o *APID) DependsOn(r runtime.Runtime) []string
- func (o *APID) HealthFunc(runtime.Runtime) health.Check
- func (o *APID) HealthSettings(runtime.Runtime) *health.Settings
- func (o *APID) ID(r runtime.Runtime) string
- func (o *APID) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (o *APID) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (o *APID) Runner(r runtime.Runtime) (runner.Runner, error)
- type CRI
- func (c *CRI) Client() (*containerd.Client, error)
- func (c *CRI) Condition(r runtime.Runtime) conditions.Condition
- func (c *CRI) DependsOn(r runtime.Runtime) []string
- func (c *CRI) HealthFunc(runtime.Runtime) health.Check
- func (c *CRI) HealthSettings(runtime.Runtime) *health.Settings
- func (c *CRI) ID(r runtime.Runtime) string
- func (c *CRI) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (c *CRI) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (c *CRI) Runner(r runtime.Runtime) (runner.Runner, error)
- type Containerd
- func (c *Containerd) Client() (*containerd.Client, error)
- func (c *Containerd) Condition(r runtime.Runtime) conditions.Condition
- func (c *Containerd) DependsOn(r runtime.Runtime) []string
- func (c *Containerd) HealthFunc(runtime.Runtime) health.Check
- func (c *Containerd) HealthSettings(runtime.Runtime) *health.Settings
- func (c *Containerd) ID(r runtime.Runtime) string
- func (c *Containerd) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (c *Containerd) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (c *Containerd) Runner(r runtime.Runtime) (runner.Runner, error)
- type Dashboard
- func (d *Dashboard) Condition(_ runtime.Runtime) conditions.Condition
- func (d *Dashboard) DependsOn(_ runtime.Runtime) []string
- func (d *Dashboard) ID(_ runtime.Runtime) string
- func (d *Dashboard) PostFunc(_ runtime.Runtime, _ events.ServiceState) error
- func (d *Dashboard) PreFunc(_ context.Context, _ runtime.Runtime) error
- func (d *Dashboard) Runner(r runtime.Runtime) (runner.Runner, error)
- type Etcd
- func (e *Etcd) Condition(r runtime.Runtime) conditions.Condition
- func (e *Etcd) DependsOn(r runtime.Runtime) []string
- func (e *Etcd) HealthFunc(runtime.Runtime) health.Check
- func (e *Etcd) HealthSettings(runtime.Runtime) *health.Settings
- func (e *Etcd) ID(r runtime.Runtime) string
- func (e *Etcd) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (e *Etcd) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (e *Etcd) Runner(r runtime.Runtime) (runner.Runner, error)
- type Extension
- func (svc *Extension) APIRestartAllowed(runtime.Runtime) bool
- func (svc *Extension) APIStartAllowed(runtime.Runtime) bool
- func (svc *Extension) APIStopAllowed(runtime.Runtime) bool
- func (svc *Extension) Condition(r runtime.Runtime) conditions.Condition
- func (svc *Extension) DependsOn(r runtime.Runtime) []string
- func (svc *Extension) ID(r runtime.Runtime) string
- func (svc *Extension) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (svc *Extension) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (svc *Extension) Runner(r runtime.Runtime) (runner.Runner, error)
- type Kubelet
- func (k *Kubelet) APIRestartAllowed(runtime.Runtime) bool
- func (k *Kubelet) APIStartAllowed(runtime.Runtime) bool
- func (k *Kubelet) Condition(r runtime.Runtime) conditions.Condition
- func (k *Kubelet) DependsOn(r runtime.Runtime) []string
- func (k *Kubelet) HealthFunc(runtime.Runtime) health.Check
- func (k *Kubelet) HealthSettings(runtime.Runtime) *health.Settings
- func (k *Kubelet) ID(r runtime.Runtime) string
- func (k *Kubelet) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (k *Kubelet) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (k *Kubelet) Runner(r runtime.Runtime) (runner.Runner, error)
- type Machined
- func (m *Machined) Condition(r runtime.Runtime) conditions.Condition
- func (m *Machined) DependsOn(r runtime.Runtime) []string
- func (m *Machined) HealthFunc(runtime.Runtime) health.Check
- func (m *Machined) HealthSettings(runtime.Runtime) *health.Settings
- func (m *Machined) ID(r runtime.Runtime) string
- func (m *Machined) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (m *Machined) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (m *Machined) Runner(r runtime.Runtime) (runner.Runner, error)
- type Trustd
- func (t *Trustd) Condition(r runtime.Runtime) conditions.Condition
- func (t *Trustd) DependsOn(r runtime.Runtime) []string
- func (t *Trustd) HealthFunc(runtime.Runtime) health.Check
- func (t *Trustd) HealthSettings(runtime.Runtime) *health.Settings
- func (t *Trustd) ID(r runtime.Runtime) string
- func (t *Trustd) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (t *Trustd) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (t *Trustd) Runner(r runtime.Runtime) (runner.Runner, error)
- type Udevd
- func (c *Udevd) Condition(r runtime.Runtime) conditions.Condition
- func (c *Udevd) DependsOn(r runtime.Runtime) []string
- func (c *Udevd) HealthFunc(runtime.Runtime) health.Check
- func (c *Udevd) HealthSettings(runtime.Runtime) *health.Settings
- func (c *Udevd) ID(r runtime.Runtime) string
- func (c *Udevd) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
- func (c *Udevd) PreFunc(ctx context.Context, r runtime.Runtime) error
- func (c *Udevd) Runner(r runtime.Runtime) (runner.Runner, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BootstrapEtcd ¶
func BootstrapEtcd(ctx context.Context, r runtime.Runtime, req *machineapi.BootstrapRequest) error
BootstrapEtcd bootstraps the etcd cluster.
Current instance of etcd (not joined yet) is stopped, and new instance is started in bootstrap mode.
func IsDirEmpty ¶
IsDirEmpty checks if a directory is empty or not.
Types ¶
type APID ¶
type APID struct {
// contains filtered or unexported fields
}
APID implements the Service interface. It serves as the concrete type with the required methods.
func (*APID) Condition ¶
func (o *APID) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*APID) HealthFunc ¶
HealthFunc implements the HealthcheckedService interface.
func (*APID) HealthSettings ¶
HealthSettings implements the HealthcheckedService interface.
type CRI ¶
type CRI struct {
// contains filtered or unexported fields
}
CRI implements the Service interface. It serves as the concrete type with the required methods.
func (*CRI) Client ¶
func (c *CRI) Client() (*containerd.Client, error)
Client lazy-initializes the containerd client if needed and returns it.
func (*CRI) Condition ¶
func (c *CRI) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*CRI) HealthFunc ¶
HealthFunc implements the HealthcheckedService interface.
func (*CRI) HealthSettings ¶
HealthSettings implements the HealthcheckedService interface.
type Containerd ¶
type Containerd struct {
// contains filtered or unexported fields
}
Containerd implements the Service interface. It serves as the concrete type with the required methods.
func (*Containerd) Client ¶
func (c *Containerd) Client() (*containerd.Client, error)
Client lazy-initializes the containerd client if needed and returns it.
func (*Containerd) Condition ¶
func (c *Containerd) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*Containerd) DependsOn ¶
func (c *Containerd) DependsOn(r runtime.Runtime) []string
DependsOn implements the Service interface.
func (*Containerd) HealthFunc ¶
func (c *Containerd) HealthFunc(runtime.Runtime) health.Check
HealthFunc implements the HealthcheckedService interface.
func (*Containerd) HealthSettings ¶
func (c *Containerd) HealthSettings(runtime.Runtime) *health.Settings
HealthSettings implements the HealthcheckedService interface.
func (*Containerd) ID ¶
func (c *Containerd) ID(r runtime.Runtime) string
ID implements the Service interface.
func (*Containerd) PostFunc ¶
func (c *Containerd) PostFunc(r runtime.Runtime, state events.ServiceState) (err error)
PostFunc implements the Service interface.
type Dashboard ¶ added in v1.4.0
type Dashboard struct{}
Dashboard implements the Service interface. It serves as the concrete type with the required methods.
func (*Dashboard) Condition ¶ added in v1.4.0
func (d *Dashboard) Condition(_ runtime.Runtime) conditions.Condition
Condition implements the Service interface.
type Etcd ¶
type Etcd struct { Bootstrap bool RecoverFromSnapshot bool RecoverSkipHashCheck bool // contains filtered or unexported fields }
Etcd implements the Service interface. It serves as the concrete type with the required methods.
func (*Etcd) Condition ¶
func (e *Etcd) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*Etcd) HealthFunc ¶
HealthFunc implements the HealthcheckedService interface.
func (*Etcd) HealthSettings ¶
HealthSettings implements the HealthcheckedService interface.
type Extension ¶
type Extension struct { Spec *extservices.Spec // contains filtered or unexported fields }
Extension service is a generic wrapper around extension services spec.
func (*Extension) APIRestartAllowed ¶
APIRestartAllowed implements APIRestartableService.
func (*Extension) APIStartAllowed ¶
APIStartAllowed implements APIStartableService.
func (*Extension) APIStopAllowed ¶
APIStopAllowed implements APIStoppableService.
func (*Extension) Condition ¶
func (svc *Extension) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
type Kubelet ¶
type Kubelet struct {
// contains filtered or unexported fields
}
Kubelet implements the Service interface. It serves as the concrete type with the required methods.
func (*Kubelet) APIRestartAllowed ¶
APIRestartAllowed implements APIRestartableService.
func (*Kubelet) APIStartAllowed ¶
APIStartAllowed implements APIStartableService.
func (*Kubelet) Condition ¶
func (k *Kubelet) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*Kubelet) HealthFunc ¶
HealthFunc implements the HealthcheckedService interface.
func (*Kubelet) HealthSettings ¶
HealthSettings implements the HealthcheckedService interface.
type Machined ¶
type Machined struct {
Controller runtime.Controller
}
Machined implements the Service interface. It serves as the concrete type with the required methods.
func (*Machined) Condition ¶
func (m *Machined) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*Machined) HealthFunc ¶
HealthFunc implements the HealthcheckedService interface.
func (*Machined) HealthSettings ¶
HealthSettings implements the HealthcheckedService interface.
type Trustd ¶
type Trustd struct {
// contains filtered or unexported fields
}
Trustd implements the Service interface. It serves as the concrete type with the required methods.
func (*Trustd) Condition ¶
func (t *Trustd) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*Trustd) HealthFunc ¶
HealthFunc implements the HealthcheckedService interface.
func (*Trustd) HealthSettings ¶
HealthSettings implements the HealthcheckedService interface.
type Udevd ¶
type Udevd struct {
// contains filtered or unexported fields
}
Udevd implements the Service interface. It serves as the concrete type with the required methods.
func (*Udevd) Condition ¶
func (c *Udevd) Condition(r runtime.Runtime) conditions.Condition
Condition implements the Service interface.
func (*Udevd) HealthFunc ¶
HealthFunc implements the HealthcheckedService interface.
func (*Udevd) HealthSettings ¶
HealthSettings implements the HealthcheckedService interface.