Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for case1 (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top