fix(stringx): ctx

storage/server/single/listx.go

@@ -0,0 +1,52 @@
+package single
+
+import "gitee.com/timedb/wheatCache/pkg/proto"
+
+func (s *serverSingle) Lindex(ctx context.Context, request *proto.LindexRequest) (*proto.LindexResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Llen(ctx context.Context, request *proto.LlenRequest) (*proto.LlenResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Lpop(ctx context.Context, request *proto.LpopRequest) (*proto.LpopResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Lpush(ctx context.Context, request *proto.LpushRequest) (*proto.LpushResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Lpushx(ctx context.Context, request *proto.LpushxRequest) (*proto.LpushxResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Lrange(ctx context.Context, request *proto.LrangeRequest) (*proto.LrangeResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Lrem(ctx context.Context, request *proto.LremRequest) (*proto.LremResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Lset(ctx context.Context, request *proto.LsetRequest) (*proto.LsetResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Rpop(ctx context.Context, request *proto.RpopRequest) (*proto.RpopResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Ltrim(ctx context.Context, request *proto.LtrimRequest) (*proto.LtrimResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Rpush(ctx context.Context, request *proto.RpushRequest) (*proto.RpushResponse, error) {
+	panic("implement me")
+}
+
+func (s *serverSingle) Rpushx(ctx context.Context, request *proto.RpushxRequest) (*proto.RpushxResponse, error) {
+	panic("implement me")
+}
+

storage/server/single/stringx.go

@@ -9,7 +9,7 @@ import (
 )
 
 func (s *serverSingle) Set(
-	cxt context.Context,
+	ctx context.Context,
 	req *proto.SetRequest,
 ) (*proto.SetResponse, error) {
 
@@ -20,7 +20,7 @@ func (s *serverSingle) Set(
 	lruEvent := event.NewEvent(lru.OptionEventName)
 	lruEvent.InitWaitEvent()
 	lruEvent.SetValue(lru.WorkFuncEventKey, work)
-	s.lruProduce.Call(cxt, lruEvent)
+	s.lruProduce.Call(ctx, lruEvent)
 	resp, err := lruEvent.StartWaitEvent(s.timeOut)
 	if err != nil {
 		return nil, err