mirror of
https://github.com/siderolabs/talos.git
synced 2026-01-04 08:11:44 +01:00
e08b4f8f9e
Fixed: https://github.com/talos-systems/talos/issues/3686 Replaced sequencer tasks for KSPP and Kubernetes required sysctl props by the ones set by controllers. KernelParam flow includes of 3 controllers and 2 resources: - `KernelParamConfigController` - handles user sysctls coming from v1alpha1 config. - `KernelParamDefaultsController` - handles our built-in KSPP and K8s required sysctls. - `KernelParamSpecController` - consumes `KernelParamSpec`s created by the previous two controllers, applies them and updates the corresponding `KernelParamStatus`. Signed-off-by: Artem Chernyshev <artem.0xD2@gmail.com>
60 lines
1.5 KiB
Go
60 lines
1.5 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 runtime
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/cosi-project/runtime/pkg/resource"
|
|
"github.com/cosi-project/runtime/pkg/state"
|
|
|
|
"github.com/talos-systems/talos/pkg/kernel"
|
|
)
|
|
|
|
// KernelParamsSetCondition implements condition which waits for the kernels to be in sync.
|
|
type KernelParamsSetCondition struct {
|
|
state state.State
|
|
props []*kernel.Param
|
|
}
|
|
|
|
// NewKernelParamsSetCondition builds a coondition which waits for the kernel to be in sync.
|
|
func NewKernelParamsSetCondition(state state.State, props ...*kernel.Param) *KernelParamsSetCondition {
|
|
return &KernelParamsSetCondition{
|
|
state: state,
|
|
props: props,
|
|
}
|
|
}
|
|
|
|
func (condition *KernelParamsSetCondition) String() string {
|
|
return "kernelParams"
|
|
}
|
|
|
|
// Wait implements condition interface.
|
|
func (condition *KernelParamsSetCondition) Wait(ctx context.Context) error {
|
|
for _, prop := range condition.props {
|
|
prop := prop
|
|
if _, err := condition.state.WatchFor(
|
|
ctx,
|
|
resource.NewMetadata(NamespaceName, KernelParamStatusType, prop.Key, resource.VersionUndefined),
|
|
state.WithCondition(func(r resource.Resource) (bool, error) {
|
|
if resource.IsTombstone(r) {
|
|
return false, nil
|
|
}
|
|
|
|
status := r.(*KernelParamStatus).TypedSpec()
|
|
if status.Current != prop.Value {
|
|
return false, nil
|
|
}
|
|
|
|
return true, nil
|
|
}),
|
|
); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|