Documentation
¶
Overview ¶
Package cluster provides controllers which manage Talos cluster resources.
Index ¶
- type AffiliateMergeController
- type ConfigController
- type DiscoveryServiceController
- func (ctrl *DiscoveryServiceController) Inputs() []controller.Input
- func (ctrl *DiscoveryServiceController) Name() string
- func (ctrl *DiscoveryServiceController) Outputs() []controller.Output
- func (ctrl *DiscoveryServiceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
- type EndpointController
- type InfoController
- type KubernetesPullController
- type KubernetesPushController
- type LocalAffiliateController
- type MemberController
- type NodeIdentityController
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 ¶
func (ctrl *AffiliateMergeController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
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 ¶
func (ctrl *DiscoveryServiceController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
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 ¶
func (ctrl *KubernetesPullController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
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 ¶
func (ctrl *KubernetesPushController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
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 ¶
func (ctrl *LocalAffiliateController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
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 ¶
func (ctrl *MemberController) Run(ctx context.Context, r controller.Runtime, _ *zap.Logger) error
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 ¶
func (ctrl *NodeIdentityController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
Source Files