- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for do (0.76 sec)
-
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) -
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)