Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for PeerJoinReq (0.08 sec)

  1. cmd/admin-handlers-site-replication.go

    	if err := parseJSONBody(ctx, r.Body, &joinArg, cred.SecretKey); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	if err := globalSiteReplicationSys.PeerJoinReq(ctx, joinArg); err != nil {
    		adminLogIf(ctx, err)
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    	}
    
    	if err := c.syncToAllPeers(ctx, opts); err != nil {
    		result.InitialSyncErrorMessage = err.Error()
    	}
    
    	return result, nil
    }
    
    // PeerJoinReq - internal API handler to respond to a peer cluster's request to join.
    func (c *SiteReplicationSys) PeerJoinReq(ctx context.Context, arg madmin.SRPeerJoinReq) error {
    	var ourName string
    	for d, p := range arg.Peers {
    		if d == globalDeploymentID() {
    			ourName = p.Name
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 184.8K bytes
    - Viewed (1)
Back to top