CAS is part of kv.Client interface
(ctx context.Context, key string, f func(in interface{}) (out interface{}, retry bool, err error))
| 91 | |
| 92 | // CAS is part of kv.Client interface |
| 93 | func (c *Client) CAS(ctx context.Context, key string, f func(in interface{}) (out interface{}, retry bool, err error)) error { |
| 94 | err := c.awaitKVRunningOrStopping(ctx) |
| 95 | if err != nil { |
| 96 | return err |
| 97 | } |
| 98 | |
| 99 | return c.kv.CAS(ctx, key, c.codec, f) |
| 100 | } |
| 101 | |
| 102 | // WatchKey is part of kv.Client interface. |
| 103 | func (c *Client) WatchKey(ctx context.Context, key string, f func(interface{}) bool) { |