Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for restClientFromHash (0.38 sec)

  1. cmd/metacache-server-pool.go

    	//
    	// If we don't have a list id we must ask the server if it has a cache or create a new.
    	if o.ID != "" && !o.Transient {
    		// Create or ping with handout...
    		rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))
    		var c *metacache
    		if rpc == nil {
    			resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o)
    			c = &resp
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  2. cmd/notification.go

    			}
    			reply[idx] = info
    		}(client, i)
    	}
    	wg.Wait()
    
    	return reply
    }
    
    // restClientFromHash will return a deterministic peerRESTClient based on s.
    // Will return nil if client is local.
    func (sys *NotificationSys) restClientFromHash(s string) (client *peerRESTClient) {
    	if len(sys.peerClients) == 0 {
    		return nil
    	}
    	peerClients := sys.allPeerClients
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  3. cmd/metacache-set.go

    }
    
    func (er *erasureObjects) streamMetadataParts(ctx context.Context, o listPathOptions) (entries metaCacheEntriesSorted, err error) {
    	retries := 0
    	rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))
    
    	const (
    		retryDelay    = 50 * time.Millisecond
    		retryDelay250 = 250 * time.Millisecond
    	)
    
    	for {
    		if contextCanceled(ctx) {
    			return entries, ctx.Err()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
Back to top