p25734189
/
wheat-cache
forked from p93542168/wheat-cache
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix(storage): fix storage method name

This commit is contained in:
bandl 2021-10-24 00:34:16 +08:00
parent e894734418
commit 9a1f1fe0ee
3 changed files with 68 additions and 68 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
storage/cmd/root.go
View File

@ -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)
}

96
storage/server/single/listx.go
View File

@ -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
}

38
storage/server/single/stringx.go
View File

@ -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
}