Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for do (0.11 sec)

  1. internal/config/cache/cache.go

    	}
    
    	if c.Endpoint == "" {
    		// Endpoint not set, make this a no-op
    		return nil, nil
    	}
    
    	buf, err := r.MarshalMsg(nil)
    	if err != nil {
    		return nil, err
    	}
    
    	// We do not want Gets to take so much time, anything
    	// beyond 250ms we should cut it, remote cache is too
    	// busy already.
    	ctx, cancel := context.WithTimeout(context.Background(), 250*time.Millisecond)
    	defer cancel()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  2. internal/cachevalue/cache.go

    	}
    }
    
    // InitOnce initializes the cache with a TTL and an update function. It is
    // guaranteed to be called only once.
    func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func() (T, error)) {
    	t.Once.Do(func() {
    		t.ttl = ttl
    		t.updateFn = update
    		t.opts = opts
    	})
    }
    
    // Get will return a cached value or fetch a new one.
    // Tf the Update function returns an error the value is forwarded as is and not cached.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top