- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 109 for controllerrevisions (0.45 sec)
-
pkg/controller/history/controller_history.go
} // FindEqualRevisions returns all ControllerRevisions in revisions that are equal to needle using EqualRevision as the // equality test. The returned slice preserves the order of revisions. func FindEqualRevisions(revisions []*apps.ControllerRevision, needle *apps.ControllerRevision) []*apps.ControllerRevision { var eq []*apps.ControllerRevision for i := range revisions { if EqualRevision(revisions[i], needle) {
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/registry/apps/rest/storage_apps.go
} storage[resource] = replicaSetStorage.ReplicaSet storage[resource+"/status"] = replicaSetStorage.Status storage[resource+"/scale"] = replicaSetStorage.Scale } // controllerrevisions if resource := "controllerrevisions"; apiResourceConfigSource.ResourceEnabled(appsapiv1.SchemeGroupVersion.WithResource(resource)) { historyStorage, err := controllerrevisionsstore.NewREST(restOptionsGetter) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 4.5K bytes - Viewed (0) -
pkg/controller/history/controller_history_test.go
informer := informerFactory.Apps().V1().ControllerRevisions() informerFactory.WaitForCacheSync(stop) history := NewHistory(client, informer.Lister()) var collisionCount int32 for _, item := range test.existing { _, err := client.AppsV1().ControllerRevisions(item.parent.GetNamespace()).Create(context.TODO(), item.revision, metav1.CreateOptions{}) if err != nil { t.Fatal(err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 49.1K bytes - Viewed (0) -
api/discovery/apis__apps__v1.json
{ "apiVersion": "v1", "groupVersion": "apps/v1", "kind": "APIResourceList", "resources": [ { "kind": "ControllerRevision", "name": "controllerrevisions", "namespaced": true, "singularName": "controllerrevision", "storageVersionHash": "85nkx63pcBU=", "verbs": [ "create", "delete", "deletecollection", "get", "list", "patch",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 15 18:18:19 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/controller/daemon/update.go
func (dsc *DaemonSetsController) constructHistory(ctx context.Context, ds *apps.DaemonSet) (cur *apps.ControllerRevision, old []*apps.ControllerRevision, err error) { var histories []*apps.ControllerRevision var currentHistories []*apps.ControllerRevision histories, err = dsc.controlledHistories(ctx, ds) if err != nil { return nil, nil, err } for _, history := range histories {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/controller/controller_ref_manager.go
// reconciliation was necessary. The list of ControllerRevisions that you now own is // returned. func (m *ControllerRevisionControllerRefManager) ClaimControllerRevisions(ctx context.Context, histories []*apps.ControllerRevision) ([]*apps.ControllerRevision, error) { var claimed []*apps.ControllerRevision var errlist []error match := func(obj metav1.Object) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 21.5K bytes - Viewed (0) -
pkg/registry/apps/controllerrevision/storage/storage.go
NewListFunc: func() runtime.Object { return &apps.ControllerRevisionList{} }, DefaultQualifiedResource: apps.Resource("controllerrevisions"), SingularQualifiedResource: apps.Resource("controllerrevision"), CreateStrategy: controllerrevision.Strategy, UpdateStrategy: controllerrevision.Strategy, DeleteStrategy: controllerrevision.Strategy,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:13 UTC 2022 - 2K bytes - Viewed (0) -
cmd/kube-controller-manager/app/apps.go
dsc, err := daemon.NewDaemonSetsController( ctx, controllerContext.InformerFactory.Apps().V1().DaemonSets(), controllerContext.InformerFactory.Apps().V1().ControllerRevisions(), controllerContext.InformerFactory.Core().V1().Pods(), controllerContext.InformerFactory.Core().V1().Nodes(), controllerContext.ClientBuilder.ClientOrDie("daemon-set-controller"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
// ListRevisions returns a array of the ControllerRevisions that represent the revisions of set. If the returned // error is nil, the returns slice of ControllerRevisions is valid. ListRevisions(set *apps.StatefulSet) ([]*apps.ControllerRevision, error) // AdoptOrphanRevisions adopts any orphaned ControllerRevisions that match set's Selector. If all adoptions are // successful the returned error is nil.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
return fresh, nil }) } // adoptOrphanRevisions adopts any orphaned ControllerRevisions matched by set's Selector. func (ssc *StatefulSetController) adoptOrphanRevisions(ctx context.Context, set *apps.StatefulSet) error { revisions, err := ssc.control.ListRevisions(set) if err != nil { return err } orphanRevisions := make([]*apps.ControllerRevision, 0) for i := range revisions {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0)