From 9a1f1fe0eee5809cd962c05e3358c8772eafa8ab Mon Sep 17 00:00:00 2001 From: bandl <1658002533@qq.com> Date: Sun, 24 Oct 2021 00:34:16 +0800 Subject: [PATCH] fix(storage): fix storage method name --- storage/cmd/root.go | 2 +- storage/server/single/listx.go | 96 ++++++++++++++++---------------- storage/server/single/stringx.go | 38 ++++++------- 3 files changed, 68 insertions(+), 68 deletions(-) diff --git a/storage/cmd/root.go b/storage/cmd/root.go index 22424a4..2f677c4 100644 --- a/storage/cmd/root.go +++ b/storage/cmd/root.go @@ -44,7 +44,7 @@ var rootCmd = &cobra.Command{ server.ElegantExitServer(s) - logx.Info("start gateway in addr: %s", tcpAddr.String()) + logx.Info("start storage in addr: %s", tcpAddr.String()) if err := s.Serve(listen); err != nil { logx.Errorln(err) } diff --git a/storage/server/single/listx.go b/storage/server/single/listx.go index 5f08284..ffc505b 100644 --- a/storage/server/single/listx.go +++ b/storage/server/single/listx.go @@ -8,10 +8,10 @@ import ( "gitee.com/timedb/wheatCache/pkg/proto" ) -func (s *serverSingle) Lindex( +func (s *serverSingle) LIndex( ctx context.Context, - req *proto.LindexRequest, -) (*proto.LindexResponse, error) { + req *proto.LIndexRequest, +) (*proto.LIndexResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.LINdex(req.Key, req.Index) }) @@ -25,15 +25,15 @@ func (s *serverSingle) Lindex( return nil, err } - return &proto.LindexResponse{ + return &proto.LIndexResponse{ Result: resp.(string), }, nil } -func (s *serverSingle) Llen( +func (s *serverSingle) LLen( ctx context.Context, - req *proto.LlenRequest, -) (*proto.LlenResponse, error) { + req *proto.LLenRequest, +) (*proto.LLenResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.LLen(req.Key) }) @@ -47,15 +47,15 @@ func (s *serverSingle) Llen( return nil, err } - return &proto.LlenResponse{ + return &proto.LLenResponse{ Length: resp.(int32), }, nil } -func (s *serverSingle) Lpop( +func (s *serverSingle) LPop( ctx context.Context, - request *proto.LpopRequest, -) (*proto.LpopResponse, error) { + request *proto.LPopRequest, +) (*proto.LPopResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.LPop(request.Key, request.Count) }) @@ -69,15 +69,15 @@ func (s *serverSingle) Lpop( return nil, err } - return &proto.LpopResponse{ + return &proto.LPopResponse{ Results: resp.([]string), }, nil } -func (s *serverSingle) Lpush( +func (s *serverSingle) LPush( ctx context.Context, - req *proto.LpushRequest, -) (*proto.LpushResponse, error) { + req *proto.LPushRequest, +) (*proto.LPushResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return nil, s.dao.LPush(req.Key, req.Values...) }) @@ -91,13 +91,13 @@ func (s *serverSingle) Lpush( return nil, err } - return &proto.LpushResponse{}, nil + return &proto.LPushResponse{}, nil } -func (s *serverSingle) Lpushx( +func (s *serverSingle) LPushX( ctx context.Context, - req *proto.LpushxRequest, -) (*proto.LpushxResponse, error) { + req *proto.LPushXRequest, +) (*proto.LPushXResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return nil, s.dao.LPush(req.Key, req.Values...) }) @@ -111,13 +111,13 @@ func (s *serverSingle) Lpushx( return nil, err } - return &proto.LpushxResponse{}, nil + return &proto.LPushXResponse{}, nil } -func (s *serverSingle) Lrange( +func (s *serverSingle) LRange( ctx context.Context, - req *proto.LrangeRequest, -) (*proto.LrangeResponse, error) { + req *proto.LRangeRequest, +) (*proto.LRangeResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.LRange(req.Key, req.Start, req.End) }) @@ -131,15 +131,15 @@ func (s *serverSingle) Lrange( return nil, err } - return &proto.LrangeResponse{ + return &proto.LRangeResponse{ Values: resp.([]string), }, nil } -func (s *serverSingle) Lrem( +func (s *serverSingle) LRem( ctx context.Context, - req *proto.LremRequest, -) (*proto.LremResponse, error) { + req *proto.LRemRequest, +) (*proto.LRemResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.LRemove(req.Key, req.Count, req.Value) }) @@ -153,15 +153,15 @@ func (s *serverSingle) Lrem( return nil, err } - return &proto.LremResponse{ + return &proto.LRemResponse{ Count: resp.(int32), }, nil } -func (s *serverSingle) Lset( +func (s *serverSingle) LSet( ctx context.Context, - req *proto.LsetRequest, -) (*proto.LsetResponse, error) { + req *proto.LSetRequest, +) (*proto.LSetResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return nil, s.dao.LSet(req.Key, req.Index, req.Value) }) @@ -175,13 +175,13 @@ func (s *serverSingle) Lset( return nil, err } - return &proto.LsetResponse{}, nil + return &proto.LSetResponse{}, nil } -func (s *serverSingle) Rpop( +func (s *serverSingle) RPop( ctx context.Context, - req *proto.RpopRequest, -) (*proto.RpopResponse, error) { + req *proto.RPopRequest, +) (*proto.RPopResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.RPop(req.Key, req.Count) }) @@ -195,15 +195,15 @@ func (s *serverSingle) Rpop( return nil, err } - return &proto.RpopResponse{ + return &proto.RPopResponse{ Result: resp.([]string), }, nil } -func (s *serverSingle) Ltrim( +func (s *serverSingle) LTrim( ctx context.Context, - req *proto.LtrimRequest, -) (*proto.LtrimResponse, error) { + req *proto.LTrimRequest, +) (*proto.LTrimResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return nil, s.dao.LTrim(req.Key, req.Start, req.End) }) @@ -217,13 +217,13 @@ func (s *serverSingle) Ltrim( return nil, err } - return &proto.LtrimResponse{}, nil + return &proto.LTrimResponse{}, nil } -func (s *serverSingle) Rpush( +func (s *serverSingle) RPush( ctx context.Context, - req *proto.RpushRequest, -) (*proto.RpushResponse, error) { + req *proto.RPushRequest, +) (*proto.RPushResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return nil, s.dao.RPush(req.Key, req.Values...) }) @@ -237,13 +237,13 @@ func (s *serverSingle) Rpush( return nil, err } - return &proto.RpushResponse{}, nil + return &proto.RPushResponse{}, nil } -func (s *serverSingle) Rpushx( +func (s *serverSingle) RPushX( ctx context.Context, - req *proto.RpushxRequest, -) (*proto.RpushxResponse, error) { + req *proto.RPushXRequest, +) (*proto.RPushXResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return nil, s.dao.RPushX(req.Key, req.Values...) }) @@ -257,5 +257,5 @@ func (s *serverSingle) Rpushx( return nil, err } - return &proto.RpushxResponse{}, nil + return &proto.RPushXResponse{}, nil } diff --git a/storage/server/single/stringx.go b/storage/server/single/stringx.go index 83be2b0..1a0586b 100644 --- a/storage/server/single/stringx.go +++ b/storage/server/single/stringx.go @@ -94,10 +94,10 @@ func (s *serverSingle) Reduce( }, nil } -func (s *serverSingle) Setbit( +func (s *serverSingle) SetBit( cxt context.Context, - req *proto.SetbitRequest, -) (*proto.SetbitResponse, error) { + req *proto.SetBitRequest, +) (*proto.SetBitResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return nil, s.dao.Setbit(req.Key, req.Val, req.Offer) }) @@ -110,13 +110,13 @@ func (s *serverSingle) Setbit( if err != nil { return nil, err } - return &proto.SetbitResponse{}, nil + return &proto.SetBitResponse{}, nil } -func (s *serverSingle) Getbit( +func (s *serverSingle) GetBit( cxt context.Context, - req *proto.GetbitRequest, -) (*proto.GetbitResponse, error) { + req *proto.GetBitRequest, +) (*proto.GetBitResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.GetBit(req.Key, req.Offer) }) @@ -129,15 +129,15 @@ func (s *serverSingle) Getbit( if err != nil { return nil, err } - return &proto.GetbitResponse{ + return &proto.GetBitResponse{ Val: flag.(bool), }, nil } -func (s *serverSingle) Getrange( +func (s *serverSingle) GetRange( ctx context.Context, - req *proto.GetrangeRequest, -) (*proto.GetrangeResponse, error) { + req *proto.GetRangeRequest, +) (*proto.GetRangeResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.Getrange(req.Key, req.Start, req.End) }) @@ -150,15 +150,15 @@ func (s *serverSingle) Getrange( if err != nil { return nil, err } - return &proto.GetrangeResponse{ + return &proto.GetRangeResponse{ Result: flag.(string), }, nil } func (s *serverSingle) Getset( ctx context.Context, - req *proto.GetsetRequest, -) (*proto.GetsetResponse, error) { + req *proto.GetSetRequest, +) (*proto.GetSetResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.Getset(req.Key, req.Val) }) @@ -171,15 +171,15 @@ func (s *serverSingle) Getset( if err != nil { return nil, err } - return &proto.GetsetResponse{ + return &proto.GetSetResponse{ Result: result.(string), }, nil } -func (s *serverSingle) Strlen( +func (s *serverSingle) StrLen( ctx context.Context, - req *proto.StrlenRequest, -) (*proto.StrlenResponse, error) { + req *proto.StrLenRequest, +) (*proto.StrLenResponse, error) { work := event.EventWorkFunc(func() (interface{}, error) { return s.dao.Strlen(req.Key) }) @@ -192,7 +192,7 @@ func (s *serverSingle) Strlen( if err != nil { return nil, err } - return &proto.StrlenResponse{ + return &proto.StrLenResponse{ Length: flag.(int32), }, nil }