Skip to content

Commit c1e4507

Browse files
committed
refactor: use etcd configuration from the EtcdSpec resource
This is currently no-op, just noticed that while looking into another bug. This should make the intention more clean. Signed-off-by: Andrey Smirnov <andrey.smirnov@siderolabs.com>
1 parent 4e9b688 commit c1e4507

File tree

1 file changed

+10
-10
lines changed
  • internal/app/machined/pkg/system/services

1 file changed

+10
-10
lines changed

internal/app/machined/pkg/system/services/etcd.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -108,22 +108,22 @@ func (e *Etcd) PreFunc(ctx context.Context, r runtime.Runtime) error {
108108
// Pull the image and unpack it.
109109
containerdctx := namespaces.WithNamespace(ctx, constants.SystemContainerdNamespace)
110110

111-
img, err := image.Pull(containerdctx, r.Config().Machine().Registries(), client, r.Config().Cluster().Etcd().Image(), image.WithSkipIfAlreadyPulled())
111+
spec, err := safe.ReaderGet[*etcdresource.Spec](ctx, r.State().V1Alpha2().Resources(), etcdresource.NewSpec(etcdresource.NamespaceName, etcdresource.SpecID).Metadata())
112+
if err != nil {
113+
// spec should be ready
114+
return fmt.Errorf("failed to get etcd spec: %w", err)
115+
}
116+
117+
img, err := image.Pull(containerdctx, r.Config().Machine().Registries(), client, spec.TypedSpec().Image, image.WithSkipIfAlreadyPulled())
112118
if err != nil {
113-
return fmt.Errorf("failed to pull image %q: %w", r.Config().Cluster().Etcd().Image(), err)
119+
return fmt.Errorf("failed to pull image %q: %w", spec.TypedSpec().Image, err)
114120
}
115121

116122
e.imgRef = img.Target().Digest.String()
117123

118124
// Clear any previously set learner member ID
119125
e.learnerMemberID = 0
120126

121-
spec, err := safe.ReaderGet[*etcdresource.Spec](ctx, r.State().V1Alpha2().Resources(), etcdresource.NewSpec(etcdresource.NamespaceName, etcdresource.SpecID).Metadata())
122-
if err != nil {
123-
// spec should be ready
124-
return fmt.Errorf("failed to get etcd spec: %w", err)
125-
}
126-
127127
switch t := r.Config().Machine().Type(); t {
128128
case machine.TypeInit:
129129
if err = e.argsForInit(ctx, r, spec.TypedSpec()); err != nil {
@@ -400,7 +400,7 @@ func (e *Etcd) argsForInit(ctx context.Context, r runtime.Runtime, spec *etcdres
400400
"experimental-compact-hash-check-enabled": "true",
401401
}
402402

403-
extraArgs := argsbuilder.Args(r.Config().Cluster().Etcd().ExtraArgs())
403+
extraArgs := argsbuilder.Args(spec.ExtraArgs)
404404

405405
denyList := argsbuilder.WithDenyList(denyListArgs)
406406

@@ -477,7 +477,7 @@ func (e *Etcd) argsForControlPlane(ctx context.Context, r runtime.Runtime, spec
477477
"experimental-compact-hash-check-enabled": "true",
478478
}
479479

480-
extraArgs := argsbuilder.Args(r.Config().Cluster().Etcd().ExtraArgs())
480+
extraArgs := argsbuilder.Args(spec.ExtraArgs)
481481

482482
denyList := argsbuilder.WithDenyList(denyListArgs)
483483

0 commit comments

Comments
 (0)