Method CompareAndSwap

cache/memcached_client.go:558–576

(ctx context.Context, key string, value []byte, ttl time.Duration)

}

func (c *MemcachedClient) CompareAndSwap(ctx context.Context, key string, value []byte, ttl time.Duration) error {
	return c.storeOperation(ctx, key, value, ttl, opCompareAndSwap, func(ctx context.Context, key string, value []byte, ttl time.Duration) error {
		select {
		case <-ctx.Done():
			return ctx.Err()
		default:
			ttlSeconds, ok := toSeconds(ttl)
			if !ok {
				return fmt.Errorf("%w: for compare-and-swap operation on %s %s", ErrInvalidTTL, key, ttl)
			}

			return c.client.CompareAndSwap(&memcache.Item{
				Key:        key,
				Value:      value,
				Expiration: ttlSeconds,
			})
		}
	})
}

func (c *MemcachedClient) FlushAll(ctx context.Context) error {
	var err error