cluster

package
v0.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 20, 2024 License: MPL-2.0 Imports: 43 Imported by: 0

Documentation

Overview

Package cluster provides controllers which manage Talos cluster resources.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AffiliateMergeController

type AffiliateMergeController struct{}

AffiliateMergeController merges raw Affiliates from the RawNamespaceName into final representation in the NamespaceName.

func (*AffiliateMergeController) Inputs

func (ctrl *AffiliateMergeController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*AffiliateMergeController) Name

func (ctrl *AffiliateMergeController) Name() string

Name implements controller.Controller interface.

func (*AffiliateMergeController) Outputs

func (ctrl *AffiliateMergeController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*AffiliateMergeController) Run

Run implements controller.Controller interface.

type ConfigController

type ConfigController = transform.Controller[*config.MachineConfig, *cluster.Config]

ConfigController watches v1alpha1.Config, updates discovery config.

func NewConfigController

func NewConfigController() *ConfigController

NewConfigController instanciates the config controller.

type DiscoveryServiceController

type DiscoveryServiceController struct {
	// contains filtered or unexported fields
}

DiscoveryServiceController pushes Affiliate resource to the Kubernetes registry.

func (*DiscoveryServiceController) Inputs

func (ctrl *DiscoveryServiceController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*DiscoveryServiceController) Name

func (ctrl *DiscoveryServiceController) Name() string

Name implements controller.Controller interface.

func (*DiscoveryServiceController) Outputs

func (ctrl *DiscoveryServiceController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*DiscoveryServiceController) Run

Run implements controller.Controller interface.

type EndpointController

type EndpointController struct{}

EndpointController looks up control plane endpoints.

func (*EndpointController) Inputs

func (ctrl *EndpointController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*EndpointController) Name

func (ctrl *EndpointController) Name() string

Name implements controller.Controller interface.

func (*EndpointController) Outputs

func (ctrl *EndpointController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*EndpointController) Run

func (ctrl *EndpointController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error

Run implements controller.Controller interface.

type InfoController

type InfoController = transform.Controller[*config.MachineConfig, *cluster.Info]

InfoController looks up control plane infos.

func NewInfoController

func NewInfoController() *InfoController

NewInfoController instanciates the cluster info controller.

type KubernetesPullController

type KubernetesPullController struct{}

KubernetesPullController pulls list of Affiliate resource from the Kubernetes registry.

func (*KubernetesPullController) Inputs

func (ctrl *KubernetesPullController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*KubernetesPullController) Name

func (ctrl *KubernetesPullController) Name() string

Name implements controller.Controller interface.

func (*KubernetesPullController) Outputs

func (ctrl *KubernetesPullController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*KubernetesPullController) Run

Run implements controller.Controller interface.

type KubernetesPushController

type KubernetesPushController struct {
	// contains filtered or unexported fields
}

KubernetesPushController pushes Affiliate resource to the Kubernetes registry.

func (*KubernetesPushController) Inputs

func (ctrl *KubernetesPushController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*KubernetesPushController) Name

func (ctrl *KubernetesPushController) Name() string

Name implements controller.Controller interface.

func (*KubernetesPushController) Outputs

func (ctrl *KubernetesPushController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*KubernetesPushController) Run

Run implements controller.Controller interface.

type LocalAffiliateController

type LocalAffiliateController struct{}

LocalAffiliateController builds Affiliate resource for the local node.

func (*LocalAffiliateController) Inputs

func (ctrl *LocalAffiliateController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*LocalAffiliateController) Name

func (ctrl *LocalAffiliateController) Name() string

Name implements controller.Controller interface.

func (*LocalAffiliateController) Outputs

func (ctrl *LocalAffiliateController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*LocalAffiliateController) Run

Run implements controller.Controller interface.

type MemberController

type MemberController struct{}

MemberController converts Affiliates which have Nodename set into Members.

func (*MemberController) Inputs

func (ctrl *MemberController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*MemberController) Name

func (ctrl *MemberController) Name() string

Name implements controller.Controller interface.

func (*MemberController) Outputs

func (ctrl *MemberController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*MemberController) Run

Run implements controller.Controller interface.

type NodeIdentityController

type NodeIdentityController struct {
	V1Alpha1Mode runtime.Mode
	StatePath    string
	// contains filtered or unexported fields
}

NodeIdentityController manages runtime.Identity caching identity in the STATE.

func (*NodeIdentityController) Inputs

func (ctrl *NodeIdentityController) Inputs() []controller.Input

Inputs implements controller.Controller interface.

func (*NodeIdentityController) Name

func (ctrl *NodeIdentityController) Name() string

Name implements controller.Controller interface.

func (*NodeIdentityController) Outputs

func (ctrl *NodeIdentityController) Outputs() []controller.Output

Outputs implements controller.Controller interface.

func (*NodeIdentityController) Run

Run implements controller.Controller interface.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL