diff --git a/storage/server/single/listx.go b/storage/server/single/listx.go new file mode 100644 index 0000000..50ead28 --- /dev/null +++ b/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") +} + diff --git a/storage/server/single/stringx.go b/storage/server/single/stringx.go index 59cb73a..83be2b0 100644 --- a/storage/server/single/stringx.go +++ b/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