From e63eb33904b0df0ac8a7a975cbc5eaeb0963553e Mon Sep 17 00:00:00 2001
From: guzeng <gz@flyrise.cn>
Date: Tue, 31 Aug 2021 14:57:04 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=9B=86=E5=90=88=E7=9A=84?=
 =?UTF-8?q?=E6=93=8D=E4=BD=9C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 redis.pb.go | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 redis.proto | 12 ++++++++++++
 2 files changed, 64 insertions(+)

diff --git a/redis.pb.go b/redis.pb.go
index 9e4279e..c8758c9 100644
--- a/redis.pb.go
+++ b/redis.pb.go
@@ -22,6 +22,8 @@ It has these top-level messages:
 	DelResponse
 	HSetResponse
 	SetExpireResponse
+	SAddRequest
+	SMembersRequest
 */
 package redisrpc
 
@@ -315,6 +317,48 @@ func (m *SetExpireResponse) GetRet() int64 {
 	return 0
 }
 
+// 集合添加值
+type SAddRequest struct {
+	Key              *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
+	Field            *string `protobuf:"bytes,2,opt,name=field" json:"field,omitempty"`
+	XXX_unrecognized []byte  `json:"-"`
+}
+
+func (m *SAddRequest) Reset()         { *m = SAddRequest{} }
+func (m *SAddRequest) String() string { return proto.CompactTextString(m) }
+func (*SAddRequest) ProtoMessage()    {}
+
+func (m *SAddRequest) GetKey() string {
+	if m != nil && m.Key != nil {
+		return *m.Key
+	}
+	return ""
+}
+
+func (m *SAddRequest) GetField() string {
+	if m != nil && m.Field != nil {
+		return *m.Field
+	}
+	return ""
+}
+
+// 集合添加值
+type SMembersRequest struct {
+	Key              *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
+	XXX_unrecognized []byte  `json:"-"`
+}
+
+func (m *SMembersRequest) Reset()         { *m = SMembersRequest{} }
+func (m *SMembersRequest) String() string { return proto.CompactTextString(m) }
+func (*SMembersRequest) ProtoMessage()    {}
+
+func (m *SMembersRequest) GetKey() string {
+	if m != nil && m.Key != nil {
+		return *m.Key
+	}
+	return ""
+}
+
 func init() {
 }
 
@@ -329,6 +373,8 @@ type RedisService interface {
 	HGetAll(in *GetRequest, out *HGetListResponse) error
 	HExists(in *HGetRequest, out *DelResponse) error
 	Exists(in *GetRequest, out *DelResponse) error
+	SAdd(in *SAddRequest, out *HSetResponse) error
+	SIsmember(in *SAddRequest, out *HSetResponse) error
 }
 
 // AcceptRedisServiceClient accepts connections on the listener and serves requests
@@ -430,6 +476,12 @@ func (c *RedisServiceClient) HExists(in *HGetRequest, out *DelResponse) error {
 func (c *RedisServiceClient) Exists(in *GetRequest, out *DelResponse) error {
 	return c.Call("RedisService.Exists", in, out)
 }
+func (c *RedisServiceClient) SAdd(in *SAddRequest, out *HSetResponse) error {
+	return c.Call("RedisService.SAdd", in, out)
+}
+func (c *RedisServiceClient) SIsmember(in *SAddRequest, out *HSetResponse) error {
+	return c.Call("RedisService.SIsmember", 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 b81d559..c5f4635 100644
--- a/redis.proto
+++ b/redis.proto
@@ -67,6 +67,16 @@ message SetExpireResponse {
     int64 ret = 1;
 }
 
+//集合添加值
+message SAddRequest{
+	string key = 1;
+    string field = 2;
+}
+//集合添加值
+message SMembersRequest{
+	string key = 1;
+}
+
 // rpc方法
 service RedisService {
     rpc Get (GetRequest) returns (GetStringResponse);    // 使用key查询
@@ -79,4 +89,6 @@ service RedisService {
     rpc HGetAll(GetRequest) returns (HGetListResponse); //get hash all
     rpc HExists(HGetRequest) returns (DelResponse); //hash键是否存在
     rpc Exists(GetRequest) returns (DelResponse); //键是否存在
+    rpc SAdd(SAddRequest) returns (HSetResponse); //添加进入集合
+    rpc SIsmember(SAddRequest) returns (HSetResponse); //集合中是否存在值
 }
\ No newline at end of file