- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for case1 (0.04 sec)
-
pilot/pkg/xds/delta.go
// Spontaneous DeltaDiscoveryRequests from the client. // This can be done to dynamically add or remove elements from the tracked resource_names set. // In this case response_nonce is empty. spontaneousReq := request.ResponseNonce == "" // It is invalid in the below two cases: // 1. no subscribed resources change from spontaneous delta request. // 2. subscribed resources changes from ACK.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/api-errors.go
case PrefixAccessDenied: apiErr = ErrAccessDenied case BucketNameInvalid: apiErr = ErrInvalidBucketName case BucketNotFound: apiErr = ErrNoSuchBucket case BucketAlreadyOwnedByYou: apiErr = ErrBucketAlreadyOwnedByYou case BucketNotEmpty: apiErr = ErrBucketNotEmpty case BucketAlreadyExists: apiErr = ErrBucketAlreadyExists case BucketExists: apiErr = ErrBucketAlreadyOwnedByYou
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
podIP = podIPs[0] } switch internalFieldPath { case "spec.nodeName": return pod.Spec.NodeName, nil case "spec.serviceAccountName": return pod.Spec.ServiceAccountName, nil case "status.hostIP": hostIPs, err := kl.getHostIPsAnyWay() if err != nil { return "", err } return hostIPs[0].String(), nil case "status.hostIPs":
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
cmd/bucket-replication.go
} if ch == nil && healCh == nil { return } select { case <-p.ctx.Done(): case healCh <- ri: case ch <- ri: default: globalReplicationPool.queueMRFSave(ri.ToMRFEntry()) p.mu.RLock() prio := p.priority maxWorkers := p.maxWorkers p.mu.RUnlock() switch prio { case "fast":
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
return &model.Proxy{ConfigNamespace: ns} } cases := []struct { name string cfg []Configer proxy *model.Proxy routeName string expected map[string][]string expectedGateway map[string][]string oldestWins bool }{ // Port 80 has special cases as there is defaulting logic around this port { name: "simple port 80",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/simulation/traffic.go
switch pt := r.Match.GetPathSpecifier().(type) { case *route.RouteMatch_Prefix: if !strings.HasPrefix(input.Path, pt.Prefix) { continue } case *route.RouteMatch_PathSeparatedPrefix: if !strings.HasPrefix(input.Path, pt.PathSeparatedPrefix) { continue } case *route.RouteMatch_Path: if input.Path != pt.Path { continue } case *route.RouteMatch_SafeRegex:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 19.4K bytes - Viewed (0) -
cmd/iam.go
defer cancel() switch { case usersPrefix: accessKey := path.Dir(strings.TrimPrefix(event.keyPath, iamConfigUsersPrefix)) err = sys.store.UserNotificationHandler(ctx, accessKey, regUser) case stsPrefix: accessKey := path.Dir(strings.TrimPrefix(event.keyPath, iamConfigSTSPrefix)) err = sys.store.UserNotificationHandler(ctx, accessKey, stsUser) case svcPrefix:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
pilot/pkg/bootstrap/certcontroller.go
} case <-s.fileWatcher.Events(tlsOptions.KeyFile): if keyCertTimerC == nil { keyCertTimerC = time.After(watchDebounceDelay) } case err := <-s.fileWatcher.Errors(tlsOptions.CertFile): log.Errorf("error watching %v: %v", tlsOptions.CertFile, err) case err := <-s.fileWatcher.Errors(tlsOptions.KeyFile): log.Errorf("error watching %v: %v", tlsOptions.KeyFile, err) case <-stop: return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 11.3K bytes - Viewed (0) -
cmd/iam-store.go
} switch opts.status { // The caller did not ask to update status account, do nothing case "": case string(madmin.AccountEnabled): cr.Status = auth.AccountOn case string(madmin.AccountDisabled): cr.Status = auth.AccountOff // Update account status case auth.AccountOn, auth.AccountOff: cr.Status = opts.status default:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
len1, len2 := getURILength(m1), getURILength(m2) switch { // 1: Exact/Prefix/Regex case r1 != r2: return r1 > r2 case len1 != len2: return len1 > len2 // 2: method math case (m1.Method == nil) != (m2.Method == nil): return m1.Method != nil // 3: number of header matches case len(m1.Headers) != len(m2.Headers): return len(m1.Headers) > len(m2.Headers) // 4: number of query matches
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0)