From 21b0779a6e3840a6e6dbe6f71ea44cd9824442df Mon Sep 17 00:00:00 2001 From: hugoShaka Date: Thu, 31 Oct 2024 15:17:08 -0400 Subject: [PATCH] enforce conditaional updates on AutoUpdate* + rename typos --- api/types/autoupdate/rollout.go | 6 +++--- lib/services/autoupdates.go | 6 +++--- lib/services/local/autoupdate.go | 6 +++--- 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/api/types/autoupdate/rollout.go b/api/types/autoupdate/rollout.go index 814d71313d3ed..d935244af31b3 100644 --- a/api/types/autoupdate/rollout.go +++ b/api/types/autoupdate/rollout.go @@ -26,7 +26,7 @@ import ( // NewAutoUpdateAgentRollout creates a new auto update version resource. func NewAutoUpdateAgentRollout(spec *autoupdate.AutoUpdateAgentRolloutSpec) (*autoupdate.AutoUpdateAgentRollout, error) { - version := &autoupdate.AutoUpdateAgentRollout{ + rollout := &autoupdate.AutoUpdateAgentRollout{ Kind: types.KindAutoUpdateAgentRollout, Version: types.V1, Metadata: &headerv1.Metadata{ @@ -34,11 +34,11 @@ func NewAutoUpdateAgentRollout(spec *autoupdate.AutoUpdateAgentRolloutSpec) (*au }, Spec: spec, } - if err := ValidateAutoUpdateAgentRollout(version); err != nil { + if err := ValidateAutoUpdateAgentRollout(rollout); err != nil { return nil, trace.Wrap(err) } - return version, nil + return rollout, nil } // ValidateAutoUpdateAgentRollout checks that required parameters are set diff --git a/lib/services/autoupdates.go b/lib/services/autoupdates.go index 72d51b4ac2338..f57d384df2dde 100644 --- a/lib/services/autoupdates.go +++ b/lib/services/autoupdates.go @@ -65,13 +65,13 @@ type AutoUpdateService interface { DeleteAutoUpdateVersion(ctx context.Context) error // CreateAutoUpdateAgentRollout creates the AutoUpdateAgentRollout singleton resource. - CreateAutoUpdateAgentRollout(ctx context.Context, plan *autoupdate.AutoUpdateAgentRollout) (*autoupdate.AutoUpdateAgentRollout, error) + CreateAutoUpdateAgentRollout(ctx context.Context, rollout *autoupdate.AutoUpdateAgentRollout) (*autoupdate.AutoUpdateAgentRollout, error) // UpdateAutoUpdateAgentRollout updates the AutoUpdateAgentRollout singleton resource. - UpdateAutoUpdateAgentRollout(ctx context.Context, plan *autoupdate.AutoUpdateAgentRollout) (*autoupdate.AutoUpdateAgentRollout, error) + UpdateAutoUpdateAgentRollout(ctx context.Context, rollout *autoupdate.AutoUpdateAgentRollout) (*autoupdate.AutoUpdateAgentRollout, error) // UpsertAutoUpdateAgentRollout sets the AutoUpdateAgentRollout singleton resource. - UpsertAutoUpdateAgentRollout(ctx context.Context, plan *autoupdate.AutoUpdateAgentRollout) (*autoupdate.AutoUpdateAgentRollout, error) + UpsertAutoUpdateAgentRollout(ctx context.Context, rollout *autoupdate.AutoUpdateAgentRollout) (*autoupdate.AutoUpdateAgentRollout, error) // DeleteAutoUpdateAgentRollout deletes the AutoUpdateAgentRollout singleton resource. DeleteAutoUpdateAgentRollout(ctx context.Context) error diff --git a/lib/services/local/autoupdate.go b/lib/services/local/autoupdate.go index 879e5348d1d4e..93a5142ca81a1 100644 --- a/lib/services/local/autoupdate.go +++ b/lib/services/local/autoupdate.go @@ -113,7 +113,7 @@ func (s *AutoUpdateService) UpdateAutoUpdateConfig( ctx context.Context, c *autoupdate.AutoUpdateConfig, ) (*autoupdate.AutoUpdateConfig, error) { - config, err := s.config.UpdateResource(ctx, c) + config, err := s.config.ConditionalUpdateResource(ctx, c) return config, trace.Wrap(err) } @@ -151,7 +151,7 @@ func (s *AutoUpdateService) UpdateAutoUpdateVersion( ctx context.Context, v *autoupdate.AutoUpdateVersion, ) (*autoupdate.AutoUpdateVersion, error) { - version, err := s.version.UpdateResource(ctx, v) + version, err := s.version.ConditionalUpdateResource(ctx, v) return version, trace.Wrap(err) } @@ -189,7 +189,7 @@ func (s *AutoUpdateService) UpdateAutoUpdateAgentRollout( ctx context.Context, v *autoupdate.AutoUpdateAgentRollout, ) (*autoupdate.AutoUpdateAgentRollout, error) { - rollout, err := s.rollout.UpdateResource(ctx, v) + rollout, err := s.rollout.ConditionalUpdateResource(ctx, v) return rollout, trace.Wrap(err) }