Fix nil pointer exception

Signed-off-by: Antonio Navarro Perez <antnavper@gmail.com>
This commit is contained in:
Antonio Navarro Perez 2021-03-01 18:39:04 +01:00
parent ea7643f8bf
commit 6f5770bf65

View file

@ -506,12 +506,11 @@ func (e *Etcd) Schema(ctx context.Context) (disco.Schema, error) {
}
func (e *Etcd) Metadata(ctx context.Context, peerID string) ([]byte, error) {
kv := e.e.Server.KV()
resp, err := kv.Range([]byte(path.Join(metadataPrefix, peerID)), nil, mvcc.RangeOptions{})
resp, err := e.cli.KV.Get(ctx, path.Join(metadataPrefix, peerID))
if err != nil {
return nil, err
}
kvs := resp.KVs
kvs := resp.Kvs
if len(kvs) > 1 {
return nil, disco.ErrTooManyResults