Method TryUpdate

data/shared_state_variable.go:364–388

(ctx context.Context, newValue int64)

}

func (c *counterInt64) TryUpdate(ctx context.Context, newValue int64) int64 {
	ctx, span := common.StartSpan(ctx, "CounterInt64.TryUpdate",
		trace.WithAttributes(
			attribute.String("key", c.key),
		),
	)
	defer span.End()
	if common.IsTracingDetailed {
		span.SetAttributes(
			attribute.Int64("new_value", newValue),
		)
	}
	// IMPORTANT: TryUpdate must never wait on updateMu.
	// updateMu exists to coordinate expensive refresh execution in TryUpdateIfStale (thundering herd control),
	// but local counter advancement must remain fast even if a refresh is in-flight.
	updated := c.processNewValue(UpdateSourceTryUpdate, newValue)

	// Schedule background push when value was actually updated (increase OR decrease).
	// With unified semantics, all value changes are propagated to remote.
	// Note: Value can be 0 for valid cases like earliest block = genesis.
	if updated {
		c.scheduleBackgroundPushCurrent()
	}
	return c.value.Load()
}

func (c *counterInt64) TryUpdateIfStale(ctx context.Context, staleness time.Duration, executeNewValueFn func(ctx context.Context) (int64, error)) (int64, error) {
	ctx, span := common.StartSpan(ctx, "CounterInt64.TryUpdateIfStale",