Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for restClientFromHash (0.09 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K 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()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
Back to top