Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ng (0.01 sec)

  1. cmd/notification.go

    	ng := WithNPeers(len(sys.peerClients)).WithRetries(1)
    	for idx, client := range sys.peerClients {
    		ng.Go(ctx, func() error {
    			if client == nil {
    				return errPeerNotReachable
    			}
    			return client.DeletePolicy(ctx, policyName)
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    // LoadPolicy - reloads a specific modified policy across all peers
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    	mErrs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum)
    	if err != nil && revert {
    		ng := errgroup.WithNErrs(len(disks))
    		for index := range disks {
    			if mErrs[index] != nil {
    				continue
    			}
    			index := index
    			ng.Go(func() error {
    				if disks[index] == nil {
    					return errDiskNotFound
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 21.3K bytes
    - Viewed (0)
Back to top