diff --git a/internal/rpc/group/group.go b/internal/rpc/group/group.go index 8e279d82b..f318e03bb 100644 --- a/internal/rpc/group/group.go +++ b/internal/rpc/group/group.go @@ -34,6 +34,10 @@ type groupServer struct { etcdAddr []string } +func (s *groupServer) GetGroupAbstractInfo(c context.Context, req *pbGroup.GetGroupAbstractInfoReq) (*pbGroup.GetGroupAbstractInfoResp, error) { + panic("implement me") +} + func NewGroupServer(port int) *groupServer { log.NewPrivateLog(constant.LogFileName) return &groupServer{ diff --git a/pkg/common/db/RedisModel.go b/pkg/common/db/RedisModel.go index b4dfd6139..589999d4c 100644 --- a/pkg/common/db/RedisModel.go +++ b/pkg/common/db/RedisModel.go @@ -202,6 +202,7 @@ func (d *DataBases) GetMessageListBySeq(userID string, seqList []uint32, operati } return seqMsg, failedSeqList, errResult } + func (d *DataBases) SetMessageToCache(msgList []*pbChat.MsgDataToMQ, uid string, operationID string) error { ctx := context.Background() pipe := d.RDB.Pipeline()