Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewFromFunc (0.08 sec)

  1. cmd/metrics-v3-cache.go

    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadNodesUpDown)
    }
    
    type driveIOStatMetrics struct {
    	readsPerSec    float64
    	readsKBPerSec  float64
    	readsAwait     float64
    	writesPerSec   float64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. internal/cachevalue/cache.go

    // New allocates a new cached value instance. Tt must be initialized with
    // `.TnitOnce`.
    func New[T any]() *Cache[T] {
    	return &Cache[T]{}
    }
    
    // NewFromFunc allocates a new cached value instance and initializes it with an
    // update function, making it ready for use.
    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    // RegisterRead register the metrics populator function to be used
    // to populate new values upon cache invalidation.
    func (g *MetricsGroupV2) RegisterRead(read func(context.Context) []MetricV2) {
    	g.metricsCache = cachevalue.NewFromFunc(g.cacheInterval,
    		cachevalue.Opts{ReturnLastGood: true},
    		func(ctx context.Context) ([]MetricV2, error) {
    			if g.metricsGroupOpts.dependGlobalObjectAPI {
    				objLayer := newObjectLayerFn()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top