Method SetAsync

cache/memcached_client.go:322–340

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

}

func (c *MemcachedClient) SetAsync(key string, value []byte, ttl time.Duration) {
	if !c.itemSizeIsAcceptable(key, value, opSet) {
		return
	}

	err := c.queue.submit(func() {
		// Because this operation is executed in a separate goroutine: We run the operation without
		// a context (it is expected to keep running no matter what happens) and we don't return the
		// error (it will be tracked via metrics instead of being returned to the caller).
		_ = c.storeOperation(context.Background(), key, value, ttl, opSet, func(_ context.Context, key string, value []byte, ttl time.Duration) error {
			return c.setSingleItem(key, value, ttl)
		})
	})

	if err != nil {
		c.metrics.skipped.WithLabelValues(opSet, reasonAsyncBufferFull).Inc()
		level.Debug(c.logger).Log("msg", "failed to store item to cache because the async buffer is full", "key", key, "err", err, "buffer_size", c.config.MaxAsyncBufferSize)
	}
}

func (c *MemcachedClient) itemSizeIsAcceptable(key string, value []byte, op string) bool {
	if c.config.MaxItemSize > 0 && len(value) > c.config.MaxItemSize {