Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for runRecordHook (0.33 sec)

  1. pkg/monitoring/counter.go

    		log.Fatalf("failed to create counter: %v", err)
    	}
    	r := &counter{c: c}
    	r.baseMetric = baseMetric{
    		name: o.name,
    		rest: r,
    	}
    	return r
    }
    
    func (f *counter) Record(value float64) {
    	f.runRecordHook(value)
    	if f.precomputedAddOption != nil {
    		f.c.Add(context.Background(), value, f.precomputedAddOption...)
    	} else {
    		f.c.Add(context.Background(), value)
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  2. pkg/monitoring/distribution.go

    	}
    	r := &distribution{d: d}
    	r.baseMetric = baseMetric{
    		name: o.name,
    		rest: r,
    	}
    	return r
    }
    
    func (f *distribution) Record(value float64) {
    	f.runRecordHook(value)
    	if f.precomputedRecordOption != nil {
    		f.d.Record(context.Background(), value, f.precomputedRecordOption...)
    	} else {
    		f.d.Record(context.Background(), value)
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  3. pkg/monitoring/base.go

    }
    
    func (f baseMetric) Name() string {
    	return f.name
    }
    
    func (f baseMetric) Increment() {
    	f.rest.Record(1)
    }
    
    func (f baseMetric) Decrement() {
    	f.rest.Record(-1)
    }
    
    func (f baseMetric) runRecordHook(value float64) {
    	recordHookMutex.RLock()
    	if rh, ok := recordHooks[f.name]; ok {
    		lv := slices.Map(f.attrs, func(e attribute.KeyValue) LabelValue {
    			return LabelValue{e}
    		})
    		rh.OnRecord(f.name, lv, value)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  4. pkg/monitoring/gauge.go

    	if err != nil {
    		log.Fatalf("failed to create gauge: %v", err)
    	}
    	r.g = g
    	r.baseMetric = baseMetric{
    		name: o.name,
    		rest: r,
    	}
    	return r
    }
    
    func (f *gauge) Record(value float64) {
    	f.runRecordHook(value)
    	// TODO: https://github.com/open-telemetry/opentelemetry-specification/issues/2318 use synchronous gauge so we don't need to deal with this
    	f.attributeSetsMutex.Lock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Sep 13 16:04:48 UTC 2023
    - 2.9K bytes
    - Viewed (0)
Back to top