- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for newRevision (0.25 sec)
-
pilot/pkg/config/memory/controller.go
config: config, event: model.EventAdd, }) } return } func (c *Controller) Update(config config.Config) (newRevision string, err error) { oldconfig := c.configStore.Get(config.GroupVersionKind, config.Name, config.Namespace) if newRevision, err = c.configStore.Update(config); err == nil { c.monitor.ScheduleProcessEvent(ConfigEvent{ old: *oldconfig, config: config,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 26 13:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/controller/history/controller_history_test.go
} updated, err := history.UpdateControllerRevision(test.revision, test.newRevision) if !test.err && err != nil { t.Errorf("%s: %s", test.name, err) } if !test.err && updated.Revision != test.newRevision { t.Errorf("%s: got %d want %d", test.name, updated.Revision, test.newRevision) } if test.err && err == nil { t.Errorf("%s: expected error", test.name) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 49.1K bytes - Viewed (0) -
pkg/controller/history/controller_history.go
} } func (rh *realHistory) UpdateControllerRevision(revision *apps.ControllerRevision, newRevision int64) (*apps.ControllerRevision, error) { clone := revision.DeepCopy() err := retry.RetryOnConflict(retry.DefaultBackoff, func() error { if clone.Revision == newRevision { return nil } clone.Revision = newRevision
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 13:33:52 UTC 2021 - 18.2K bytes - Viewed (0) -
pkg/controller/deployment/util/deployment_util.go
} newRevisionInt, err := strconv.ParseInt(newRevision, 10, 64) if err != nil { logger.Info("Updating replica set revision NewRevision not int", "err", err) return false } if oldRevisionInt < newRevisionInt { newRS.Annotations[RevisionAnnotation] = newRevision annotationChanged = true logger.V(4).Info("Updating replica set revision", "replicaSet", klog.KObj(newRS), "newRevision", newRevision) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 07:09:11 UTC 2023 - 39.3K bytes - Viewed (0) -
pilot/pkg/model/fake_store.go
if configs == nil { configs = make(map[string]config.Config) nsConfigs[cfg.Namespace] = configs } configs[cfg.Name] = cfg return "", nil } func (s *FakeStore) Update(cfg config.Config) (newRevision string, err error) { nsConfigs := s.store[cfg.GroupVersionKind] if nsConfigs != nil { configs := nsConfigs[cfg.Namespace] if configs != nil { if _, f := configs[cfg.Name]; f { configs[cfg.Name] = cfg
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 18 06:50:06 UTC 2023 - 3K bytes - Viewed (0) -
pkg/controller/deployment/sync.go
// Calculate the max revision number among all old RSes maxOldRevision := deploymentutil.MaxRevision(logger, oldRSs) // Calculate revision number for this new replica set newRevision := strconv.FormatInt(maxOldRevision+1, 10) // Latest replica set exists. We need to sync its annotations (includes copying all but // annotationsToSkip from the parent deployment, and update revision, desiredReplicas,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 24.5K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
return "", errUnsupportedOp } func (c *Controller) Update(config config.Config) (newRevision string, err error) { return "", errUnsupportedOp } func (c *Controller) UpdateStatus(config config.Config) (newRevision string, err error) { return "", errUnsupportedOp } func (c *Controller) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/model/config.go
// operation to achieve optimistic concurrency. This method returns a new // revision if the operation succeeds. Update(config config.Config) (newRevision string, err error) UpdateStatus(config config.Config) (newRevision string, err error) // Patch applies only the modifications made in the PatchFunc rather than doing a full replace. Useful to avoid
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 08:51:03 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/config/file/store.go
return s.inner.Create(config) } func (s *KubeSource) Update(config config.Config) (newRevision string, err error) { return s.inner.Update(config) } func (s *KubeSource) UpdateStatus(config config.Config) (newRevision string, err error) { return s.inner.UpdateStatus(config) } func (s *KubeSource) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
set.Status.CollisionCount = new(int32) currentSet := set.DeepCopy() currentRevision, err := newRevision(set, 1, set.Status.CollisionCount) if err != nil { t.Fatal(err) } set.Spec.Template.Spec.Containers[0].Env = []v1.EnvVar{{Name: "foo", Value: "bar"}} updateSet := set.DeepCopy() updateRevision, err := newRevision(set, 2, set.Status.CollisionCount) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0)