(key string)
| 903 | } |
| 904 | |
| 905 | func (e *EtcdStore) getValue(key string) ([]byte, error) { |
| 906 | ctx, cancel := context.WithTimeout(e.rawClient.Ctx(), DefaultRequestTimeout) |
| 907 | defer cancel() |
| 908 | |
| 909 | resp, err := clientv3.NewKV(e.rawClient).Get(ctx, key) |
| 910 | if nil != err { |
| 911 | return nil, err |
| 912 | } |
| 913 | |
| 914 | if len(resp.Kvs) == 0 { |
| 915 | return nil, nil |
| 916 | } |
| 917 | |
| 918 | return resp.Kvs[0].Value, nil |
| 919 | } |
| 920 | |
| 921 | func (e *EtcdStore) allocID() (uint64, error) { |
| 922 | e.idLock.Lock() |