From f2b409d019ecf527da152fe61e2ee762d307c4b0 Mon Sep 17 00:00:00 2001
From: guzeng <gz@flyrise.cn>
Date: Mon, 7 Jun 2021 18:13:52 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=8E=B7=E5=8F=96=E6=89=80?=
 =?UTF-8?q?=E6=9C=89hash=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 expire_test.go |  2 +-
 redis.pb.go    | 22 ++++++++++++++++++++++
 redis.proto    |  5 +++++
 3 files changed, 28 insertions(+), 1 deletion(-)

diff --git a/expire_test.go b/expire_test.go
index a17fb7a..19a630f 100644
--- a/expire_test.go
+++ b/expire_test.go
@@ -10,7 +10,7 @@ func Test_SetExpire(t *testing.T) {
 	c, err := Set("test", "33", 50)
 	t.Log(c)
 	t.Log(err)
-	c2, err := SetExpire("test", 0)
+	c2, err := SetExpire("test", 100)
 	t.Log(c2)
 	t.Log(err)
 
diff --git a/redis.pb.go b/redis.pb.go
index 5ddbcaa..5f1967a 100644
--- a/redis.pb.go
+++ b/redis.pb.go
@@ -17,6 +17,7 @@ It has these top-level messages:
 	HDelRequest
 	SetExpireRequest
 	GetStringResponse
+	HGetListResponse
 	SetResponse
 	DelResponse
 	HSetResponse
@@ -229,6 +230,23 @@ func (m *GetStringResponse) GetValue() string {
 	return ""
 }
 
+// 使用key查询响应结构
+type HGetListResponse struct {
+	List             []byte `protobuf:"bytes,1,opt,name=list" json:"list,omitempty"`
+	XXX_unrecognized []byte `json:"-"`
+}
+
+func (m *HGetListResponse) Reset()         { *m = HGetListResponse{} }
+func (m *HGetListResponse) String() string { return proto.CompactTextString(m) }
+func (*HGetListResponse) ProtoMessage()    {}
+
+func (m *HGetListResponse) GetList() []byte {
+	if m != nil {
+		return m.List
+	}
+	return nil
+}
+
 // 设置key响应结构
 type SetResponse struct {
 	Ret              *string `protobuf:"bytes,1,opt,name=ret" json:"ret,omitempty"`
@@ -308,6 +326,7 @@ type RedisService interface {
 	HSet(in *HSetRequest, out *HSetResponse) error
 	HDel(in *HDelRequest, out *DelResponse) error
 	SetExpire(in *SetExpireRequest, out *SetExpireResponse) error
+	HGetAll(in *GetRequest, out *HGetListResponse) error
 }
 
 // AcceptRedisServiceClient accepts connections on the listener and serves requests
@@ -400,6 +419,9 @@ func (c *RedisServiceClient) HDel(in *HDelRequest, out *DelResponse) error {
 func (c *RedisServiceClient) SetExpire(in *SetExpireRequest, out *SetExpireResponse) error {
 	return c.Call("RedisService.SetExpire", in, out)
 }
+func (c *RedisServiceClient) HGetAll(in *GetRequest, out *HGetListResponse) error {
+	return c.Call("RedisService.HGetAll", in, out)
+}
 
 // DialRedisService connects to an RedisService at the specified network address.
 func DialRedisService(network, addr string) (*RedisServiceClient, *rpc.Client, error) {
diff --git a/redis.proto b/redis.proto
index b4007c5..23a0bd8 100644
--- a/redis.proto
+++ b/redis.proto
@@ -44,6 +44,10 @@ message GetStringResponse {
     string value = 1;
 }
 
+// 使用key查询响应结构
+message HGetListResponse {
+    bytes list = 1;
+}
 // 设置key响应结构
 message SetResponse {
     string ret = 1;
@@ -72,4 +76,5 @@ service RedisService {
     rpc HSet (HSetRequest) returns (HSetResponse);
     rpc HDel (HDelRequest) returns (DelResponse);
     rpc SetExpire (SetExpireRequest) returns (SetExpireResponse); //设置有效期
+    rpc HGetAll(GetRequest) returns (HGetListResponse); //get hash all
 }
\ No newline at end of file