(ctx context.Context, key string)
| 100 | } |
| 101 | |
| 102 | func (c *Client) Get(ctx context.Context, key string) (any, error) { |
| 103 | resp, _, err := c.kv.Query(ctx, dynamodbKey{primaryKey: key}, false) |
| 104 | if err != nil { |
| 105 | level.Warn(c.logger).Log("msg", "error Get", "key", key, "err", err) |
| 106 | return nil, err |
| 107 | } |
| 108 | res, err := c.decodeMultikey(resp) |
| 109 | if err != nil { |
| 110 | return nil, err |
| 111 | } |
| 112 | c.updateStaleData(key, res, time.Now().UTC()) |
| 113 | |
| 114 | return res, nil |
| 115 | } |
| 116 | |
| 117 | func (c *Client) Delete(ctx context.Context, key string) error { |
| 118 | resp, _, err := c.kv.Query(ctx, dynamodbKey{primaryKey: key}, false) |
nothing calls this directly
no test coverage detected