Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 71 for Sets (0.19 sec)

  1. cmd/erasure-sets.go

    func (s *erasureSets) StorageInfo(ctx context.Context) StorageInfo {
    	var storageInfo madmin.StorageInfo
    
    	storageInfos := make([]madmin.StorageInfo, len(s.sets))
    
    	g := errgroup.WithNErrs(len(s.sets))
    	for index := range s.sets {
    		index := index
    		g.Go(func() error {
    			storageInfos[index] = s.sets[index].StorageInfo(ctx)
    			return nil
    		}, index)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  2. cmd/format-erasure.go

    	tmpFormat.Erasure.This = ""
    	if len(reference.Erasure.Sets) != len(format.Erasure.Sets) {
    		return fmt.Errorf("Expected number of sets %d, got %d", len(reference.Erasure.Sets), len(format.Erasure.Sets))
    	}
    
    	// Make sure that the sets match.
    	for i := range reference.Erasure.Sets {
    		if len(reference.Erasure.Sets[i]) != len(format.Erasure.Sets[i]) {
    			return fmt.Errorf("Each set should be of same size, expected %d got %d",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  3. cmd/format-erasure_test.go

    	}
    	if len(formatV3.Erasure.Sets) != 1 {
    		t.Fatalf("expected single set after migrating from v1 to v3, but found %d", len(formatV3.Erasure.Sets))
    	}
    	if !reflect.DeepEqual(formatV3.Erasure.Sets[0], m.Erasure.JBOD) {
    		t.Fatalf("expected drive uuid: %v, got: %v", m.Erasure.JBOD, formatV3.Erasure.Sets[0])
    	}
    
    	m = &formatErasureV1{}
    	m.Format = "unknown"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  4. cmd/endpoint-ellipses.go

    	return endpoints
    }
    
    // Get returns the sets representation of the endpoints
    // this function also intelligently decides on what will
    // be the right set size etc.
    func (s endpointSet) Get() (sets [][]string) {
    	k := uint64(0)
    	endpoints := s.getEndpoints()
    	for i := range s.setIndexes {
    		for j := range s.setIndexes[i] {
    			sets = append(sets, endpoints[k:s.setIndexes[i][j]+k])
    			k = s.setIndexes[i][j] + k
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  5. cni/README.md

            - If so, calls `istio-iptables` with params to setup pod netns
            - If ambient, sets up the ambient logic.
    
    - `istio-iptables`
        - sets up iptables to redirect a list of ports to the port envoy will listen
        - shared code with istio-init container
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  6. cmd/global-heal.go

    				ss.HealPriority = "high"
    				status.HealDisks = append(status.HealDisks, disk.Endpoint)
    			}
    		}
    		sortDisks(ss.Disks)
    		status.Sets = append(status.Sets, ss)
    	}
    	sort.Slice(status.Sets, func(i, j int) bool {
    		return status.Sets[i].ID < status.Sets[j].ID
    	})
    
    	backendInfo := o.BackendInfo()
    	status.SCParity = make(map[string]int)
    	status.SCParity[storageclass.STANDARD] = backendInfo.StandardSCParity
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  7. okhttp/src/main/kotlin/okhttp3/CacheControl.kt

       * It is set by a client who only wants to make a request if it can be fully satisfied by the
       * cache. Cached responses that would require validation (ie. conditional gets) are not permitted
       * if this header is set.
       */
      @get:JvmName("onlyIfCached") val onlyIfCached: Boolean,
      @get:JvmName("noTransform") val noTransform: Boolean,
      @get:JvmName("immutable") val immutable: Boolean,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 13:41:01 GMT 2024
    - 10K bytes
    - Viewed (0)
  8. istioctl/pkg/waypoint/waypoint.go

    	"istio.io/istio/pkg/config/schema/gvk"
    	"istio.io/istio/pkg/kube"
    	"istio.io/istio/pkg/slices"
    	"istio.io/istio/pkg/util/sets"
    )
    
    var (
    	revision      = ""
    	waitReady     bool
    	allNamespaces bool
    
    	deleteAll bool
    
    	trafficType       = ""
    	validTrafficTypes = sets.New(constants.ServiceTraffic, constants.WorkloadTraffic, constants.AllTraffic, constants.NoTraffic)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/podcgroupns.go

    		can extract a pod uid from it.
    		if we can, open the netns, and save a map of uid->netns-fd
    	*/
    
    	podUIDNetns := make(PodToNetns)
    	netnsObserved := sets.New[uint64]()
    
    	entries, err := fs.ReadDir(p.proc, ".")
    	if err != nil {
    		return nil, err
    	}
    
    	desiredUIDs := sets.New(maps.Keys(pods)...)
    	for _, entry := range entries {
    		// we can't break here because we need to close all the netns we opened
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  10. cmd/metrics-v3-types.go

    			}
    			metrics = append(metrics,
    				prometheus.MustNewConstMetric(promDesc, desc.Type.toProm(), v.Value,
    					labelValues...))
    		}
    	}
    	return metrics
    }
    
    // Set - sets a metric value along with any provided labels. It is used only
    // with Gauge and Counter metrics.
    //
    // If the MetricName given here is not present in the `MetricsGroup`'s
    // descriptors, this function panics.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:05:22 GMT 2024
    - 14.7K bytes
    - Viewed (0)
Back to top