- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 269 for claim (0.1 sec)
-
pkg/controller/statefulset/stateful_pod_control_test.go
for k := range claims0 { claim, err := claimLister.PersistentVolumeClaims(claims0[k].Namespace).Get(claims0[k].Name) if err != nil { t.Errorf("Unexpected error getting Claim %s/%s: %v", claim.Namespace, claim.Name, err) } if hasOwnerRef(claim, set) != expectRef { t.Errorf("%s: Claim %s/%s bad set owner ref", tc.name, claim.Namespace, claim.Name) } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
func (ctrl *PersistentVolumeController) deleteClaim(ctx context.Context, claim *v1.PersistentVolumeClaim) { logger := klog.FromContext(ctx) if err := ctrl.claims.Delete(claim); err != nil { logger.Error(err, "Claim deletion encountered", "PVC", klog.KObj(claim)) } claimKey := claimToClaimKey(claim) logger.V(4).Info("Claim deleted", "PVC", klog.KObj(claim))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
templates := set.Spec.VolumeClaimTemplates claims := make(map[string]v1.PersistentVolumeClaim, len(templates)) for i := range templates { claim := templates[i].DeepCopy() claim.Name = getPersistentVolumeClaimName(set, claim, ordinal) claim.Namespace = set.Namespace if claim.Labels != nil { for key, value := range set.Spec.Selector.MatchLabels { claim.Labels[key] = value } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/apiserver/v1alpha1/types.go
// Either claim or expression must be set. // Mutually exclusive with expression. // +optional Claim string `json:"claim,omitempty"` // expression represents the expression which will be evaluated by CEL. // // CEL expressions have access to the contents of the token claims, organized into CEL variable: // - 'claims' is a map of claim names to claim values.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 17:59:05 UTC 2024 - 26.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
if hasNamedOwnerRef(claim, podName) || hasNamedOwnerRef(claim, set.Name) { t.Errorf("bad claim ownerRefs: %s: %v", claim.Name, claim.GetOwnerReferences()) } case scaledownPolicy == retain && deletionPolicy == delete: if hasNamedOwnerRef(claim, podName) || !hasNamedOwnerRef(claim, set.Name) { t.Errorf("bad claim ownerRefs: %s: %v", claim.Name, claim.GetOwnerReferences()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
updateClaimOwnerRefForSetAndPod(logger, claim, set, pod) if err := spc.objectMgr.UpdateClaim(claim); err != nil { return fmt.Errorf("could not update claim %s for delete policy ownerRefs: %w", claimName, err) } } } } return nil } // PodClaimIsStale returns true for a stale PVC that should block pod creation. If the scaling
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
} defer os.RemoveAll(tmpDir) podManager := kubepod.NewBasicPodManager() node, pod, pv, claim := createObjects(v1.PersistentVolumeFilesystem, v1.PersistentVolumeFilesystem) claim.Status = v1.PersistentVolumeClaimStatus{ Phase: v1.ClaimPending, } kubeClient := fake.NewSimpleClientset(node, pod, pv, claim) manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient, node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubeapiserver/options/authentication_test.go
}, }, { name: "groups claim exists", args: []string{ "--oidc-issuer-url=https://testIssuerURL", "--oidc-client-id=testClientID", "--oidc-username-claim=sub", "--oidc-username-prefix=-", "--oidc-groups-claim=groups", "--oidc-groups-prefix=oidc:", "--oidc-signing-algs=RS256", "--oidc-required-claim=foo=bar", }, expectConfig: kubeauthenticator.Config{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 36.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
} return claims } func annotateClaim(claim *v1.PersistentVolumeClaim, ann map[string]string) *v1.PersistentVolumeClaim { if claim.Annotations == nil { claim.Annotations = map[string]string{} } for key, val := range ann { claim.Annotations[key] = val } return claim } // volumeWithAnnotation saves given annotation into given volume.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
staging/src/k8s.io/api/resource/v1alpha2/types_swagger_doc_generated.go
"shareable": "Shareable indicates whether the allocated claim is meant to be shareable by multiple consumers at the same time.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 14 17:07:36 UTC 2024 - 22.4K bytes - Viewed (0)