Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for siteStatus (0.07 sec)

  1. cmd/site-replication-utils.go

    		if st, ok2 := sm.resyncStatus[rst.resyncID]; ok2 {
    			return st.clone(), nil
    		}
    	}
    	return rs, errSRNoResync
    }
    
    // Status returns latest resync status for this deployment
    func (sm *siteResyncMetrics) siteStatus(ctx context.Context, objAPI ObjectLayer, dID string) (rs SiteResyncStatus, err error) {
    	if !globalSiteReplicationSys.isEnabled() {
    		return rs, errSRNotEnabled
    	}
    	// check in-memory status
    	rs, err = sm.status(dID)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    	if peer.DeploymentID == globalDeploymentID() {
    		return res, errSRResyncToSelf
    	}
    	if _, ok := c.state.Peers[peer.DeploymentID]; !ok {
    		return res, errSRPeerNotFound
    	}
    	rs, err := globalSiteResyncMetrics.siteStatus(ctx, objAPI, peer.DeploymentID)
    	if err != nil {
    		return res, err
    	}
    	if rs.Status == ResyncStarted {
    		return res, errSRResyncStarted
    	}
    	var buckets []BucketInfo
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  3. cmd/notification.go

    		if nErr.Err != nil {
    			peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), nErr.Err, nErr.Host.String())
    		}
    	}
    	siteStats = append(siteStats, globalReplicationStats.Load().getSRMetricsForNode())
    	return siteStats
    }
    
    // ReloadPoolMeta reloads on disk updates on pool metadata
    func (sys *NotificationSys) ReloadPoolMeta(ctx context.Context) {
    	ng := WithNPeers(len(sys.peerClients))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
Back to top