Method incrDecr

cache/memcached_client.go:507–533

(ctx context.Context, key string, operation string, f func() (uint64, error))

}

func (c *MemcachedClient) incrDecr(ctx context.Context, key string, operation string, f func() (uint64, error)) (uint64, error) {
	var (
		newValue uint64
		err      error
	)
	start := time.Now()
	c.metrics.operations.WithLabelValues(operation).Inc()

	select {
	case <-ctx.Done():
		err = ctx.Err()
	default:
		newValue, err = f()
	}
	if err != nil {
		c.trackError(
			operation, err,
			"msg", "failed to incr/decr cache item",
			"operation", operation,
			"key", key,
		)
	} else {
		c.metrics.duration.WithLabelValues(operation).Observe(time.Since(start).Seconds())
	}

	return newValue, err
}

func (c *MemcachedClient) Touch(ctx context.Context, key string, ttl time.Duration) error {
	start := time.Now()