Method trackError

cache/memcached_client.go:642–674

(op string, err error, msg ...interface{})

}

func (c *MemcachedClient) trackError(op string, err error, msg ...interface{}) {
	severity := level.DebugValue()

	var connErr *memcache.ConnectTimeoutError
	var netErr net.Error
	switch {
	case errors.As(err, &connErr):
		c.metrics.failures.WithLabelValues(op, reasonConnectTimeout).Inc()
	case errors.As(err, &netErr):
		if netErr.Timeout() {
			c.metrics.failures.WithLabelValues(op, reasonTimeout).Inc()
		} else {
			c.metrics.failures.WithLabelValues(op, reasonNetworkError).Inc()
		}
	case errors.Is(err, ErrNotStored):
		c.metrics.failures.WithLabelValues(op, reasonNotStored).Inc()
	case errors.Is(err, ErrInvalidTTL):
		c.metrics.failures.WithLabelValues(op, reasonInvalidTTL).Inc()
	case errors.Is(err, memcache.ErrMalformedKey):
		c.metrics.failures.WithLabelValues(op, reasonMalformedKey).Inc()
	case errors.Is(err, memcache.ErrServerError):
		c.metrics.failures.WithLabelValues(op, reasonServerError).Inc()
	case errors.Is(err, context.Canceled):
		c.metrics.failures.WithLabelValues(op, reasonCanceled).Inc()
	default:
		c.metrics.failures.WithLabelValues(op, reasonOther).Inc()
		severity = level.WarnValue() // Log unexpected kinds of errors with higher severity so they're easier to diagnose.
	}

	logger := log.WithPrefix(c.logger, level.Key(), severity)
	logger = log.WithSuffix(logger, "err", err)
	logger.Log(msg...)
}

func (c *MemcachedClient) getMultiBatched(ctx context.Context, keys []string, opts ...memcache.Option) ([]map[string]*memcache.Item, error) {
	// Do not batch if the input keys are less than the max batch size.