(val int64)
| 349 | } |
| 350 | |
| 351 | func (c *counterInt64) triggerValueCallback(val int64) { |
| 352 | c.callbackMu.RLock() |
| 353 | callbacks := make([]func(int64), len(c.valueCallbacks)) |
| 354 | copy(callbacks, c.valueCallbacks) |
| 355 | c.callbackMu.RUnlock() |
| 356 | |
| 357 | for _, cb := range callbacks { |
| 358 | if cb != nil { |
| 359 | cb(val) |
| 360 | } |
| 361 | } |
| 362 | } |
| 363 | |
| 364 | func (c *counterInt64) TryUpdate(ctx context.Context, newValue int64) int64 { |
| 365 | ctx, span := common.StartSpan(ctx, "CounterInt64.TryUpdate", |
no test coverage detected