Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for NewScaleHandler (0.27 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/managedfields/scalehandler.go

    // resource and the scale subresource
    type ScaleHandler struct {
    	parentEntries []metav1.ManagedFieldsEntry
    	groupVersion  schema.GroupVersion
    	mappings      ResourcePathMappings
    }
    
    // NewScaleHandler creates a new ScaleHandler
    func NewScaleHandler(parentEntries []metav1.ManagedFieldsEntry, groupVersion schema.GroupVersion, mappings ResourcePathMappings) *ScaleHandler {
    	return &ScaleHandler{
    		parentEntries: parentEntries,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/managedfields/scalehandler_test.go

    					FieldsType: "FieldsV1",
    					FieldsV1:   &metav1.FieldsV1{Raw: []byte(`{"f:spec":{"f:replicas":{}}}`)},
    				},
    			},
    			expected: nil,
    		},
    	}
    
    	for _, test := range tests {
    		handler := NewScaleHandler(
    			test.input,
    			schema.GroupVersion{Group: "apps", Version: "v1"},
    			defaultMappings(),
    		)
    		subresourceEntries, err := handler.ToSubresource()
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 23.7K bytes
    - Viewed (0)
  3. pkg/registry/core/replicationcontroller/storage/storage.go

    			groupVersion = requestGroupVersion
    		} else {
    			klog.Fatalf("Unrecognized group/version in request info %q", requestGroupVersion.String())
    		}
    	}
    
    	managedFieldsHandler := managedfields.NewScaleHandler(
    		replicationcontroller.ManagedFields,
    		groupVersion,
    		replicasPathInReplicationController,
    	)
    
    	// replicationcontroller -> old scale
    	oldScale := scaleFromRC(replicationcontroller)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 12K bytes
    - Viewed (0)
  4. pkg/registry/apps/replicaset/storage/storage.go

    			groupVersion = requestGroupVersion
    		} else {
    			klog.Fatalf("Unrecognized group/version in request info %q", requestGroupVersion.String())
    		}
    	}
    
    	managedFieldsHandler := managedfields.NewScaleHandler(
    		replicaset.ManagedFields,
    		groupVersion,
    		replicasPathInReplicaSet,
    	)
    
    	// replicaset -> old scale
    	oldScale, err := scaleFromReplicaSet(replicaset)
    	if err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd.go

    	cr := oldObj.DeepCopyObject().(*unstructured.Unstructured)
    	const invalidSpecReplicas = -2147483648 // smallest int32
    
    	managedFieldsHandler := managedfields.NewScaleHandler(
    		cr.GetManagedFields(),
    		i.parentGV,
    		i.replicasPathMapping,
    	)
    
    	oldScale, replicasFound, err := scaleFromCustomResource(cr, i.specReplicasPath, i.statusReplicasPath, i.labelSelectorPath)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 12.4K bytes
    - Viewed (0)
  6. pkg/registry/apps/statefulset/storage/storage.go

    			groupVersion = requestGroupVersion
    		} else {
    			klog.Fatalf("Unrecognized group/version in request info %q", requestGroupVersion.String())
    		}
    	}
    
    	managedFieldsHandler := managedfields.NewScaleHandler(
    		statefulset.ManagedFields,
    		groupVersion,
    		replicasPathInStatefulSet,
    	)
    
    	// statefulset -> old scale
    	oldScale, err := scaleFromStatefulSet(statefulset)
    	if err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  7. pkg/registry/apps/deployment/storage/storage.go

    			groupVersion = requestGroupVersion
    		} else {
    			klog.Fatalf("Unrecognized group/version in request info %q", requestGroupVersion.String())
    		}
    	}
    
    	managedFieldsHandler := managedfields.NewScaleHandler(
    		deployment.ManagedFields,
    		groupVersion,
    		replicasPathInDeployment,
    	)
    
    	// deployment -> old scale
    	oldScale, err := scaleFromDeployment(deployment)
    	if err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 16.8K bytes
    - Viewed (0)
Back to top