mirror of
https://github.com/siderolabs/talos.git
synced 2025-10-27 14:31:11 +01:00
3aae94e530
This changes the way Kubernetes nodename is computed: it is set by the controller based on the hostname and machine configuration, and pulled from the resource when needed. Kubelet client now also uses nodename to fix the certifcate mismatch issue on AWS. Signed-off-by: Andrey Smirnov <smirnov.andrey@gmail.com>
110 lines
3.0 KiB
Go
110 lines
3.0 KiB
Go
// This Source Code Form is subject to the terms of the Mozilla Public
|
|
// License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
|
|
package k8s
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/AlekSi/pointer"
|
|
"github.com/cosi-project/runtime/pkg/controller"
|
|
"github.com/cosi-project/runtime/pkg/resource"
|
|
"github.com/cosi-project/runtime/pkg/state"
|
|
"go.uber.org/zap"
|
|
|
|
"github.com/talos-systems/talos/pkg/resources/config"
|
|
"github.com/talos-systems/talos/pkg/resources/k8s"
|
|
"github.com/talos-systems/talos/pkg/resources/network"
|
|
)
|
|
|
|
// NodenameController renders manifests based on templates and config/secrets.
|
|
type NodenameController struct{}
|
|
|
|
// Name implements controller.Controller interface.
|
|
func (ctrl *NodenameController) Name() string {
|
|
return "k8s.NodenameController"
|
|
}
|
|
|
|
// Inputs implements controller.Controller interface.
|
|
func (ctrl *NodenameController) Inputs() []controller.Input {
|
|
return []controller.Input{
|
|
{
|
|
Namespace: config.NamespaceName,
|
|
Type: config.MachineConfigType,
|
|
ID: pointer.ToString(config.V1Alpha1ID),
|
|
Kind: controller.InputWeak,
|
|
},
|
|
{
|
|
Namespace: network.NamespaceName,
|
|
Type: network.HostnameStatusType,
|
|
ID: pointer.ToString(network.HostnameID),
|
|
Kind: controller.InputWeak,
|
|
},
|
|
}
|
|
}
|
|
|
|
// Outputs implements controller.Controller interface.
|
|
func (ctrl *NodenameController) Outputs() []controller.Output {
|
|
return []controller.Output{
|
|
{
|
|
Type: k8s.NodenameType,
|
|
Kind: controller.OutputExclusive,
|
|
},
|
|
}
|
|
}
|
|
|
|
// Run implements controller.Controller interface.
|
|
func (ctrl *NodenameController) Run(ctx context.Context, r controller.Runtime, logger *zap.Logger) error {
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
return nil
|
|
case <-r.EventCh():
|
|
}
|
|
|
|
cfg, err := r.Get(ctx, resource.NewMetadata(config.NamespaceName, config.MachineConfigType, config.V1Alpha1ID, resource.VersionUndefined))
|
|
if err != nil {
|
|
if state.IsNotFoundError(err) {
|
|
continue
|
|
}
|
|
|
|
return fmt.Errorf("error getting config: %w", err)
|
|
}
|
|
|
|
cfgProvider := cfg.(*config.MachineConfig).Config()
|
|
|
|
hostnameResource, err := r.Get(ctx, resource.NewMetadata(network.NamespaceName, network.HostnameStatusType, network.HostnameID, resource.VersionUndefined))
|
|
if err != nil {
|
|
if state.IsNotFoundError(err) {
|
|
continue
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
hostnameStatus := hostnameResource.(*network.HostnameStatus).TypedSpec()
|
|
|
|
if err = r.Modify(
|
|
ctx,
|
|
k8s.NewNodename(k8s.ControlPlaneNamespaceName, k8s.NodenameID),
|
|
func(r resource.Resource) error {
|
|
nodename := r.(*k8s.Nodename) //nolint:errcheck,forcetypeassert
|
|
|
|
if cfgProvider.Machine().Kubelet().RegisterWithFQDN() {
|
|
nodename.TypedSpec().Nodename = hostnameStatus.FQDN()
|
|
} else {
|
|
nodename.TypedSpec().Nodename = hostnameStatus.Hostname
|
|
}
|
|
|
|
nodename.TypedSpec().HostnameVersion = hostnameResource.Metadata().Version().String()
|
|
|
|
return nil
|
|
},
|
|
); err != nil {
|
|
return fmt.Errorf("error modifying nodename resource: %w", err)
|
|
}
|
|
}
|
|
}
|