Get implements kv.Client.
(ctx context.Context, key string)
| 281 | |
| 282 | // Get implements kv.Client. |
| 283 | func (c *Client) Get(ctx context.Context, key string) (interface{}, error) { |
| 284 | resp, err := c.cli.Get(ctx, key) |
| 285 | if err != nil { |
| 286 | return nil, err |
| 287 | } |
| 288 | if len(resp.Kvs) == 0 { |
| 289 | return nil, nil |
| 290 | } else if len(resp.Kvs) != 1 { |
| 291 | return nil, fmt.Errorf("got %d kvs, expected 1 or 0", len(resp.Kvs)) |
| 292 | } |
| 293 | return c.codec.Decode(resp.Kvs[0].Value) |
| 294 | } |
| 295 | |
| 296 | // Delete implements kv.Client. |
| 297 | func (c *Client) Delete(ctx context.Context, key string) error { |