Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Peers (0.02 sec)

  1. cmd/iam.go

    		}
    	}
    
    	err := sys.store.DeletePolicy(ctx, policyName, !notifyPeers)
    	if err != nil {
    		return err
    	}
    
    	if !notifyPeers || sys.HasWatcher() {
    		return nil
    	}
    
    	// Notify all other MinIO peers to delete policy
    	for _, nerr := range globalNotificationSys.DeletePolicy(ctx, policyName) {
    		if nerr.Err != nil {
    			logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String())
    			iamLogIf(ctx, nerr.Err)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    		m.VariableLabels[serverName] = globalLocalNodeName
    		res = append(res, &m)
    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    // GetPeerMetrics gets the metrics to be federated across peers.
    func (s *peerRESTServer) GetPeerMetrics(_ *grid.MSS) (*grid.Array[*MetricV2], *grid.RemoteErr) {
    	res := make([]*MetricV2, 0, len(peerMetricsGroups))
    	populateAndPublish(peerMetricsGroups, func(m MetricV2) bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    		case <-timer.C:
    			z.mpCache.Range(func(id string, info MultipartInfo) bool {
    				if time.Since(info.Initiated) >= globalAPIConfig.getStaleUploadsExpiry() {
    					z.mpCache.Delete(id)
    					// No need to notify to peers, each node will delete its own cache.
    				}
    				return true
    			})
    
    			// Reset for the next interval
    			timer.Reset(globalAPIConfig.getStaleUploadsCleanupInterval())
    		}
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top