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 ¶
func (ctrl *AffiliateMergeController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
type ConfigController ¶
type ConfigController struct{}
ConfigController watches v1alpha1.Config, updates discovery config.
func (*ConfigController) Inputs ¶
func (ctrl *ConfigController) Inputs() []controller.Input
Inputs implements controller.Controller interface.
func (*ConfigController) Name ¶
func (ctrl *ConfigController) Name() string
Name implements controller.Controller interface.
func (*ConfigController) Outputs ¶
func (ctrl *ConfigController) Outputs() []controller.Output
Outputs implements controller.Controller interface.
func (*ConfigController) Run ¶
func (ctrl *ConfigController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error
Run implements controller.Controller interface.
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, logger *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.