Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 403 for Make (0.15 sec)

  1. cmd/notification.go

    }
    
    // GetLastDayTierStats fetches per-tier stats of the last 24hrs from all peers
    func (sys *NotificationSys) GetLastDayTierStats(ctx context.Context) DailyAllTierStats {
    	errs := make([]error, len(sys.allPeerClients))
    	lastDayStats := make([]DailyAllTierStats, len(sys.allPeerClients))
    	var wg sync.WaitGroup
    	for index := range sys.peerClients {
    		if sys.peerClients[index] == nil {
    			continue
    		}
    		wg.Add(1)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    	e.ObjVersions.add(summary.versions)
    
    	if e.ReplicationStats == nil {
    		e.ReplicationStats = &replicationAllStats{
    			Targets: make(map[string]replicationStats),
    		}
    	} else if e.ReplicationStats.Targets == nil {
    		e.ReplicationStats.Targets = make(map[string]replicationStats)
    	}
    	e.ReplicationStats.ReplicaSize += uint64(summary.replicaSize)
    	e.ReplicationStats.ReplicaCount += uint64(summary.replicaCount)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  3. cmd/peer-s3-client.go

    			return nil
    		}, idx)
    	}
    
    	errs := g.Wait()
    
    	// The list of buckets in a map to avoid duplication
    	resultMap := make(map[string]BucketInfo)
    
    	for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ {
    		perPoolErrs := make([]error, 0, len(sys.peerClients))
    		for i, client := range sys.peerClients {
    			if slices.Contains(client.GetPools(), poolIdx) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  4. .github/workflows/iam-integrations.yaml

              go run docs/iam/access-manager-plugin.go &
              make test-iam
          - name: Test MinIO Old Version data to IAM import current version
            if: matrix.ldap == 'ldaphost:389'
            env:
              _MINIO_LDAP_TEST_SERVER: ${{ matrix.ldap }}
            run: |
              make test-iam-ldap-upgrade-import
          - name: Test LDAP for automatic site replication
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:49:53 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  5. cmd/erasure.go

    	}
    
    	return
    }
    
    func getOnlineOfflineDisksStats(disksInfo []madmin.Disk) (onlineDisks, offlineDisks madmin.BackendDisks) {
    	onlineDisks = make(madmin.BackendDisks)
    	offlineDisks = make(madmin.BackendDisks)
    
    	for _, disk := range disksInfo {
    		ep := disk.Endpoint
    		if _, ok := offlineDisks[ep]; !ok {
    			offlineDisks[ep] = 0
    		}
    		if _, ok := onlineDisks[ep]; !ok {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  6. .github/workflows/replication.yaml

              sudo sysctl net.ipv6.conf.all.disable_ipv6=0
              sudo sysctl net.ipv6.conf.default.disable_ipv6=0
              make test-decom
    
          - name: Test ILM
            run: |
              sudo sysctl net.ipv6.conf.all.disable_ipv6=0
              sudo sysctl net.ipv6.conf.default.disable_ipv6=0
              make test-ilm
    
          - name: Test Config File
            run: |
              sudo sysctl net.ipv6.conf.all.disable_ipv6=0
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 19 12:48:19 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  7. src/cmd/api/main_test.go

    				ok = false // broke compatibility
    			}
    		case len(required) == 0 || (len(features) > 0 && required[0] > features[0]):
    			newFeature := take(&features)
    			fmt.Fprintf(w, "+%s\n", newFeature)
    			ok = false // feature not in api/next/*
    		default:
    			take(&required)
    			take(&features)
    		}
    	}
    
    	return ok
    }
    
    // aliasReplacer applies type aliases to earlier API files,
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Apr 09 20:48:51 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  8. cmd/admin-heal-ops.go

    			Summary:      healNotStartedStatus,
    			HealSettings: hs,
    		},
    		traverseAndHealDoneCh: make(chan error),
    		cancelCtx:             cancel,
    		ctx:                   ctx,
    		scannedItemsMap:       make(map[madmin.HealItemType]int64),
    		healedItemsMap:        make(map[madmin.HealItemType]int64),
    		healFailedItemsMap:    make(map[string]int64),
    	}
    }
    
    // getScannedItemsCount - returns a count of all scanned items
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  9. cmd/storage-rest-client.go

    		// transport is already down.
    		return "", errDiskNotFound
    	}
    
    	// This call should never be over the network, this is always
    	// a cached value - caller should make sure to use this
    	// function on a fresh disk or make sure to look at the error
    	// from a different networked call to validate the GetDiskID()
    	return *client.diskID.Load(), nil
    }
    
    func (client *storageRESTClient) SetDiskID(id string) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  10. cmd/xl-storage-meta-inline.go

    func (x *xlMetaInlineData) remove(keys ...string) bool {
    	in := x.afterVersion()
    	sz, buf, _ := msgp.ReadMapHeaderBytes(in)
    	newKeys := make([][]byte, 0, sz)
    	newVals := make([][]byte, 0, sz)
    	var removeKey func(s []byte) bool
    
    	// Copy if big number of compares...
    	if len(keys) > 5 && sz > 5 {
    		mKeys := make(map[string]struct{}, len(keys))
    		for _, key := range keys {
    			mKeys[key] = struct{}{}
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
Back to top