(ctx context.Context, key string)
| 470 | } |
| 471 | |
| 472 | func (c *MemcachedClient) Delete(ctx context.Context, key string) error { |
| 473 | start := time.Now() |
| 474 | c.metrics.operations.WithLabelValues(opDelete).Inc() |
| 475 | |
| 476 | var err error |
| 477 | select { |
| 478 | case <-ctx.Done(): |
| 479 | err = ctx.Err() |
| 480 | default: |
| 481 | err = c.client.Delete(key) |
| 482 | } |
| 483 | if err != nil { |
| 484 | c.trackError( |
| 485 | opDelete, err, |
| 486 | "msg", "failed to delete cache item", |
| 487 | "key", key, |
| 488 | ) |
| 489 | } else { |
| 490 | c.metrics.duration.WithLabelValues(opDelete).Observe(time.Since(start).Seconds()) |
| 491 | } |
| 492 | return err |
| 493 | } |
| 494 | |
| 495 | func (c *MemcachedClient) Increment(ctx context.Context, key string, delta uint64) (uint64, error) { |
| 496 | return c.incrDecr(ctx, key, opIncrement, func() (uint64, error) { |
nothing calls this directly
no test coverage detected