API 在 etcd 集群中查找密钥
API to find a key in a etcd cluster
我正在尝试编写一段代码,我需要在其中查找某个密钥是否存在于 etcd 中。我试过这个:
_, err = kapi.Get(context.Background(), key, nil)
if err != nil {
return err
} else { ...
但是即使key不在集群中,错误也总是nil
。
知道我在这里做错了什么吗?或者还有其他 API 电话要打吗?
这里如果使用go client v3 KV客户端:https://godoc.org/go.etcd.io/etcd/clientv3#KV
它returns以下类型:
https://godoc.org/go.etcd.io/etcd/etcdserver/etcdserverpb#RangeResponse
type RangeResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
// kvs is the list of key-value pairs matched by the range request.
// kvs is empty when count is requested.
Kvs []*mvccpb.KeyValue `protobuf:"bytes,2,rep,name=kvs" json:"kvs,omitempty"`
// more indicates if there are more keys to return in the requested range.
More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
// count is set to the number of keys within the range when requested.
Count int64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
}
如您所见,有一个 Count
属性 和一个 Kvs
属性,如果您想检查您的响应是否包含密钥,您可以检查Count > 0
或 len(res.Kvs) > 0
我正在尝试编写一段代码,我需要在其中查找某个密钥是否存在于 etcd 中。我试过这个:
_, err = kapi.Get(context.Background(), key, nil)
if err != nil {
return err
} else { ...
但是即使key不在集群中,错误也总是nil
。
知道我在这里做错了什么吗?或者还有其他 API 电话要打吗?
这里如果使用go client v3 KV客户端:https://godoc.org/go.etcd.io/etcd/clientv3#KV
它returns以下类型: https://godoc.org/go.etcd.io/etcd/etcdserver/etcdserverpb#RangeResponse
type RangeResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
// kvs is the list of key-value pairs matched by the range request.
// kvs is empty when count is requested.
Kvs []*mvccpb.KeyValue `protobuf:"bytes,2,rep,name=kvs" json:"kvs,omitempty"`
// more indicates if there are more keys to return in the requested range.
More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
// count is set to the number of keys within the range when requested.
Count int64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
}
如您所见,有一个 Count
属性 和一个 Kvs
属性,如果您想检查您的响应是否包含密钥,您可以检查Count > 0
或 len(res.Kvs) > 0