- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 335 for claims0 (0.14 sec)
-
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
t.Errorf("In-flight claims are different (- expected, + actual):\n%s", diff) } } func (tc *testContext) listAll(t *testing.T) (objects []metav1.Object) { t.Helper() claims, err := tc.client.ResourceV1alpha2().ResourceClaims("").List(tc.ctx, metav1.ListOptions{}) require.NoError(t, err, "list claims") for _, claim := range claims.Items { claim := claim objects = append(objects, &claim) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/delete_test.go
// Bind the volume to resurrected claim (this should never // happen) claim := newClaim("claim8-7", "uid8-7", "10Gi", "volume8-7", v1.ClaimBound, nil) reactor.AddClaimBoundToVolume(claim) ctrl.claims.Add(claim) }), }, { // delete success - volume bound by user is deleted, while a new // claim is created with another UID.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/jwt.go
func authenticateNode(accessKey, secretKey, audience string) (string, error) { claims := xjwt.NewStandardClaims() claims.SetExpiry(UTCNow().Add(defaultInterNodeJWTExpiry)) claims.SetAccessKey(accessKey) claims.SetAudience(audience) jwt := jwtgo.NewWithClaims(jwtgo.SigningMethodHS512, claims) return jwt.SignedString([]byte(secretKey)) } // Check if the request is authenticated.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
func (b *volumeBinder) revertAssumedPVCs(claims []*v1.PersistentVolumeClaim) { for _, claim := range claims { b.pvcCache.Restore(getPVCName(claim)) } } // hasEnoughCapacity checks whether the provisioner has enough capacity left for a new volume of the given size // that is available from the node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.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) -
cmd/sts-handlers.go
// metadata map claims[expClaim] = UTCNow().Add(time.Duration(expiry) * time.Second).Unix() claims[subClaim] = parentUser claims[roleArnClaim] = roleArn.String() claims[parentClaim] = parentUser // Add all other claims from the plugin **without** replacing any // existing claims. for k, v := range res.Success.Claims { if _, ok := claims[k]; !ok { claims[k] = v } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
set := apps.StatefulSet{} set.Name = "my-set" claim := v1.PersistentVolumeClaim{} claim.Name = "volume-my-set-2" if pod := getClaimPodName(&set, &claim); pod != "my-set-2" { t.Errorf("Expected my-set-2 found %s", pod) } claim.Name = "long-volume-my-set-20" if pod := getClaimPodName(&set, &claim); pod != "my-set-20" { t.Errorf("Expected my-set-20 found %s", pod) } claim.Name = "volume-2-my-set"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
logger.V(5).Info("pod for claim not found", "claim", klog.KObj(claim), "pod", klog.KRef(claim.Namespace, podName)) default: return fmt.Errorf("lookup pod: %v", err) } } else { logger.V(5).Info("claim not generated for a pod", "claim", klog.KObj(claim)) } } return nil } func owningPod(claim *resourcev1alpha2.ResourceClaim) (string, types.UID) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
security/pkg/util/jwtutil.go
if err != nil { return nil, err } dec := json.NewDecoder(bytes.NewBuffer(claimBytes)) claims := make(map[string]any) if err := dec.Decode(&claims); err != nil { return nil, fmt.Errorf("failed to decode the JWT claims") } return claims, nil } func DecodeJwtPart(seg string) ([]byte, error) { if l := len(seg) % 4; l > 0 { seg += strings.Repeat("=", 4-l) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 16:07:11 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/bucket-policy.go
// JWT specific values // // Add all string claims for k, v := range claims { vStr, ok := v.(string) if ok { // Trim any LDAP specific prefix args[strings.ToLower(strings.TrimPrefix(k, "ldap"))] = []string{vStr} } } // Add groups claim which could be a list. This will ensure that the claim // `jwt:groups` works. if grpsVal, ok := claims["groups"]; ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8K bytes - Viewed (0)