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

chore(proto): update proto

This commit is contained in:
bandl 2021-10-21 15:57:31 +08:00
parent 3a4fc48f46
commit 2295fbcf40
6 changed files with 2186 additions and 52 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1471
pkg/proto/listx.pb.go Normal file
View File

File diff suppressed because it is too large Load Diff

614
pkg/proto/storage.pb.go
View File

@ -30,35 +30,66 @@ var File_storage_proto protoreflect.FileDescriptor
var file_storage_proto_rawDesc = []byte{ var file_storage_proto_rawDesc = []byte{
0x0a, 0x0d, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0a, 0x0d, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
0x0d, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x78, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32, 0xa2, 0x0d, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x78, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0b,
0x03, 0x0a, 0x0a, 0x43, 0x6f, 0x6d, 0x6d, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x20, 0x0a, 0x6c, 0x69, 0x73, 0x74, 0x78, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32, 0xff, 0x06, 0x0a, 0x0a,
0x03, 0x53, 0x65, 0x74, 0x12, 0x0b, 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x43, 0x6f, 0x6d, 0x6d, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x20, 0x0a, 0x03, 0x53, 0x65,
0x74, 0x1a, 0x0c, 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x74, 0x12, 0x0b, 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0c,
0x20, 0x0a, 0x03, 0x47, 0x65, 0x74, 0x12, 0x0b, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x2e, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x20, 0x0a, 0x03,
0x65, 0x73, 0x74, 0x1a, 0x0c, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x47, 0x65, 0x74, 0x12, 0x0b, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x65, 0x12, 0x20, 0x0a, 0x03, 0x41, 0x64, 0x64, 0x12, 0x0b, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x1a, 0x0c, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x20,
0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0c, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x0a, 0x03, 0x41, 0x64, 0x64, 0x12, 0x0b, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65,
0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x12, 0x0e, 0x2e, 0x73, 0x74, 0x1a, 0x0c, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x12, 0x29, 0x0a, 0x06, 0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x12, 0x0e, 0x2e, 0x52, 0x65, 0x64,
0x52, 0x65, 0x64, 0x75, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x75, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x52, 0x65, 0x64,
0x0a, 0x06, 0x53, 0x65, 0x74, 0x62, 0x69, 0x74, 0x12, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, 0x75, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x53,
0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, 0x65, 0x74, 0x62, 0x69, 0x74, 0x12, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65,
0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65,
0x62, 0x69, 0x74, 0x12, 0x0e, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74,
0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x73, 0x70, 0x12, 0x0e, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x1a, 0x0f, 0x2e, 0x47, 0x65, 0x74, 0x62, 0x69, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
0x12, 0x10, 0x2e, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x12, 0x10, 0x2e,
0x73, 0x74, 0x1a, 0x11, 0x2e, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x73, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x12, 0x11, 0x2e, 0x47, 0x65, 0x74, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x0e, 0x2e, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x12, 0x0e, 0x2e, 0x47,
0x0f, 0x2e, 0x47, 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x47,
0x12, 0x29, 0x0a, 0x06, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e, 0x12, 0x0e, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x74, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a,
0x6c, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x74, 0x72, 0x06, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e, 0x12, 0x0e, 0x2e, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e,
0x6c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x53, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x53, 0x74, 0x72, 0x6c, 0x65, 0x6e,
0x65, 0x74, 0x6e, 0x78, 0x12, 0x0d, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x71, 0x75, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x53, 0x65, 0x74, 0x6e,
0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x78, 0x12, 0x0d, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x6e, 0x73, 0x65, 0x42, 0x0b, 0x5a, 0x09, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0e, 0x2e, 0x53, 0x65, 0x74, 0x6e, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 0x12, 0x29, 0x0a, 0x06, 0x4c, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x0e, 0x2e, 0x4c, 0x69, 0x6e,
0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x4c, 0x69, 0x6e,
0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x4c,
0x6c, 0x65, 0x6e, 0x12, 0x0c, 0x2e, 0x4c, 0x6c, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
0x74, 0x1a, 0x0d, 0x2e, 0x4c, 0x6c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
0x12, 0x23, 0x0a, 0x04, 0x4c, 0x70, 0x6f, 0x70, 0x12, 0x0c, 0x2e, 0x4c, 0x70, 0x6f, 0x70, 0x52,
0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x4c, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x73,
0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x12, 0x0d,
0x2e, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e,
0x4c, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a,
0x06, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x78, 0x12, 0x0e, 0x2e, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x78,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x4c, 0x70, 0x75, 0x73, 0x68, 0x78,
0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x4c, 0x72, 0x61, 0x6e,
0x67, 0x65, 0x12, 0x0e, 0x2e, 0x4c, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x4c, 0x72, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x4c, 0x72, 0x65, 0x6d, 0x12, 0x0c, 0x2e, 0x4c, 0x72,
0x65, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x4c, 0x72, 0x65, 0x6d,
0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a, 0x04, 0x4c, 0x73, 0x65, 0x74,
0x12, 0x0c, 0x2e, 0x4c, 0x73, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d,
0x2e, 0x4c, 0x73, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x23, 0x0a,
0x04, 0x52, 0x70, 0x6f, 0x70, 0x12, 0x0c, 0x2e, 0x52, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x52, 0x70, 0x6f, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x4c, 0x74, 0x72, 0x69, 0x6d, 0x12, 0x0d, 0x2e, 0x4c, 0x74,
0x72, 0x69, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x4c, 0x74, 0x72,
0x69, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x05, 0x52, 0x70,
0x75, 0x73, 0x68, 0x12, 0x0d, 0x2e, 0x52, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65,
0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x52, 0x70, 0x75, 0x73, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x73, 0x65, 0x12, 0x29, 0x0a, 0x06, 0x52, 0x70, 0x75, 0x73, 0x68, 0x78, 0x12, 0x0e, 0x2e, 0x52,
0x70, 0x75, 0x73, 0x68, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0f, 0x2e, 0x52,
0x70, 0x75, 0x73, 0x68, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x0b, 0x5a,
0x09, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x33,
} }
var file_storage_proto_goTypes = []interface{}{ var file_storage_proto_goTypes = []interface{}{
@ -72,16 +103,40 @@ var file_storage_proto_goTypes = []interface{}{
(*GetsetRequest)(nil), // 7: GetsetRequest (*GetsetRequest)(nil), // 7: GetsetRequest
(*StrlenRequest)(nil), // 8: StrlenRequest (*StrlenRequest)(nil), // 8: StrlenRequest
(*SetnxRequest)(nil), // 9: SetnxRequest (*SetnxRequest)(nil), // 9: SetnxRequest
(*SetResponse)(nil), // 10: SetResponse (*LindexRequest)(nil), // 10: LindexRequest
(*GetResponse)(nil), // 11: GetResponse (*LlenRequest)(nil), // 11: LlenRequest
(*AddResponse)(nil), // 12: AddResponse (*LpopRequest)(nil), // 12: LpopRequest
(*ReduceResponse)(nil), // 13: ReduceResponse (*LpushRequest)(nil), // 13: LpushRequest
(*SetbitResponse)(nil), // 14: SetbitResponse (*LpushxRequest)(nil), // 14: LpushxRequest
(*GetbitResponse)(nil), // 15: GetbitResponse (*LrangeRequest)(nil), // 15: LrangeRequest
(*GetrangeResponse)(nil), // 16: GetrangeResponse (*LremRequest)(nil), // 16: LremRequest
(*GetsetResponse)(nil), // 17: GetsetResponse (*LsetRequest)(nil), // 17: LsetRequest
(*StrlenResponse)(nil), // 18: StrlenResponse (*RpopRequest)(nil), // 18: RpopRequest
(*SetnxResponse)(nil), // 19: SetnxResponse (*LtrimRequest)(nil), // 19: LtrimRequest
(*RpushRequest)(nil), // 20: RpushRequest
(*RpushxRequest)(nil), // 21: RpushxRequest
(*SetResponse)(nil), // 22: SetResponse
(*GetResponse)(nil), // 23: GetResponse
(*AddResponse)(nil), // 24: AddResponse
(*ReduceResponse)(nil), // 25: ReduceResponse
(*SetbitResponse)(nil), // 26: SetbitResponse
(*GetbitResponse)(nil), // 27: GetbitResponse
(*GetrangeResponse)(nil), // 28: GetrangeResponse
(*GetsetResponse)(nil), // 29: GetsetResponse
(*StrlenResponse)(nil), // 30: StrlenResponse
(*SetnxResponse)(nil), // 31: SetnxResponse
(*LindexResponse)(nil), // 32: LindexResponse
(*LlenResponse)(nil), // 33: LlenResponse
(*LpopResponse)(nil), // 34: LpopResponse
(*LpushResponse)(nil), // 35: LpushResponse
(*LpushxResponse)(nil), // 36: LpushxResponse
(*LrangeResponse)(nil), // 37: LrangeResponse
(*LremResponse)(nil), // 38: LremResponse
(*LsetResponse)(nil), // 39: LsetResponse
(*RpopResponse)(nil), // 40: RpopResponse
(*LtrimResponse)(nil), // 41: LtrimResponse
(*RpushResponse)(nil), // 42: RpushResponse
(*RpushxResponse)(nil), // 43: RpushxResponse
} }
var file_storage_proto_depIdxs = []int32{ var file_storage_proto_depIdxs = []int32{
0, // 0: CommServer.Set:input_type -> SetRequest 0, // 0: CommServer.Set:input_type -> SetRequest
@ -94,18 +149,42 @@ var file_storage_proto_depIdxs = []int32{
7, // 7: CommServer.Getset:input_type -> GetsetRequest 7, // 7: CommServer.Getset:input_type -> GetsetRequest
8, // 8: CommServer.Strlen:input_type -> StrlenRequest 8, // 8: CommServer.Strlen:input_type -> StrlenRequest
9, // 9: CommServer.Setnx:input_type -> SetnxRequest 9, // 9: CommServer.Setnx:input_type -> SetnxRequest
10, // 10: CommServer.Set:output_type -> SetResponse 10, // 10: CommServer.Lindex:input_type -> LindexRequest
11, // 11: CommServer.Get:output_type -> GetResponse 11, // 11: CommServer.Llen:input_type -> LlenRequest
12, // 12: CommServer.Add:output_type -> AddResponse 12, // 12: CommServer.Lpop:input_type -> LpopRequest
13, // 13: CommServer.Reduce:output_type -> ReduceResponse 13, // 13: CommServer.Lpush:input_type -> LpushRequest
14, // 14: CommServer.Setbit:output_type -> SetbitResponse 14, // 14: CommServer.Lpushx:input_type -> LpushxRequest
15, // 15: CommServer.Getbit:output_type -> GetbitResponse 15, // 15: CommServer.Lrange:input_type -> LrangeRequest
16, // 16: CommServer.Getrange:output_type -> GetrangeResponse 16, // 16: CommServer.Lrem:input_type -> LremRequest
17, // 17: CommServer.Getset:output_type -> GetsetResponse 17, // 17: CommServer.Lset:input_type -> LsetRequest
18, // 18: CommServer.Strlen:output_type -> StrlenResponse 18, // 18: CommServer.Rpop:input_type -> RpopRequest
19, // 19: CommServer.Setnx:output_type -> SetnxResponse 19, // 19: CommServer.Ltrim:input_type -> LtrimRequest
10, // [10:20] is the sub-list for method output_type 20, // 20: CommServer.Rpush:input_type -> RpushRequest
0, // [0:10] is the sub-list for method input_type 21, // 21: CommServer.Rpushx:input_type -> RpushxRequest
22, // 22: CommServer.Set:output_type -> SetResponse
23, // 23: CommServer.Get:output_type -> GetResponse
24, // 24: CommServer.Add:output_type -> AddResponse
25, // 25: CommServer.Reduce:output_type -> ReduceResponse
26, // 26: CommServer.Setbit:output_type -> SetbitResponse
27, // 27: CommServer.Getbit:output_type -> GetbitResponse
28, // 28: CommServer.Getrange:output_type -> GetrangeResponse
29, // 29: CommServer.Getset:output_type -> GetsetResponse
30, // 30: CommServer.Strlen:output_type -> StrlenResponse
31, // 31: CommServer.Setnx:output_type -> SetnxResponse
32, // 32: CommServer.Lindex:output_type -> LindexResponse
33, // 33: CommServer.Llen:output_type -> LlenResponse
34, // 34: CommServer.Lpop:output_type -> LpopResponse
35, // 35: CommServer.Lpush:output_type -> LpushResponse
36, // 36: CommServer.Lpushx:output_type -> LpushxResponse
37, // 37: CommServer.Lrange:output_type -> LrangeResponse
38, // 38: CommServer.Lrem:output_type -> LremResponse
39, // 39: CommServer.Lset:output_type -> LsetResponse
40, // 40: CommServer.Rpop:output_type -> RpopResponse
41, // 41: CommServer.Ltrim:output_type -> LtrimResponse
42, // 42: CommServer.Rpush:output_type -> RpushResponse
43, // 43: CommServer.Rpushx:output_type -> RpushxResponse
22, // [22:44] is the sub-list for method output_type
0, // [0:22] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name 0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee 0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name 0, // [0:0] is the sub-list for field type_name
@ -117,6 +196,7 @@ func file_storage_proto_init() {
return return
} }
file_stringx_proto_init() file_stringx_proto_init()
file_listx_proto_init()
type x struct{} type x struct{}
out := protoimpl.TypeBuilder{ out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{ File: protoimpl.DescBuilder{
@ -158,6 +238,18 @@ type CommServerClient interface {
Getset(ctx context.Context, in *GetsetRequest, opts ...grpc.CallOption) (*GetsetResponse, error) Getset(ctx context.Context, in *GetsetRequest, opts ...grpc.CallOption) (*GetsetResponse, error)
Strlen(ctx context.Context, in *StrlenRequest, opts ...grpc.CallOption) (*StrlenResponse, error) Strlen(ctx context.Context, in *StrlenRequest, opts ...grpc.CallOption) (*StrlenResponse, error)
Setnx(ctx context.Context, in *SetnxRequest, opts ...grpc.CallOption) (*SetnxResponse, error) Setnx(ctx context.Context, in *SetnxRequest, opts ...grpc.CallOption) (*SetnxResponse, error)
Lindex(ctx context.Context, in *LindexRequest, opts ...grpc.CallOption) (*LindexResponse, error)
Llen(ctx context.Context, in *LlenRequest, opts ...grpc.CallOption) (*LlenResponse, error)
Lpop(ctx context.Context, in *LpopRequest, opts ...grpc.CallOption) (*LpopResponse, error)
Lpush(ctx context.Context, in *LpushRequest, opts ...grpc.CallOption) (*LpushResponse, error)
Lpushx(ctx context.Context, in *LpushxRequest, opts ...grpc.CallOption) (*LpushxResponse, error)
Lrange(ctx context.Context, in *LrangeRequest, opts ...grpc.CallOption) (*LrangeResponse, error)
Lrem(ctx context.Context, in *LremRequest, opts ...grpc.CallOption) (*LremResponse, error)
Lset(ctx context.Context, in *LsetRequest, opts ...grpc.CallOption) (*LsetResponse, error)
Rpop(ctx context.Context, in *RpopRequest, opts ...grpc.CallOption) (*RpopResponse, error)
Ltrim(ctx context.Context, in *LtrimRequest, opts ...grpc.CallOption) (*LtrimResponse, error)
Rpush(ctx context.Context, in *RpushRequest, opts ...grpc.CallOption) (*RpushResponse, error)
Rpushx(ctx context.Context, in *RpushxRequest, opts ...grpc.CallOption) (*RpushxResponse, error)
} }
type commServerClient struct { type commServerClient struct {
@ -258,6 +350,114 @@ func (c *commServerClient) Setnx(ctx context.Context, in *SetnxRequest, opts ...
return out, nil return out, nil
} }
func (c *commServerClient) Lindex(ctx context.Context, in *LindexRequest, opts ...grpc.CallOption) (*LindexResponse, error) {
out := new(LindexResponse)
err := c.cc.Invoke(ctx, "/CommServer/Lindex", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Llen(ctx context.Context, in *LlenRequest, opts ...grpc.CallOption) (*LlenResponse, error) {
out := new(LlenResponse)
err := c.cc.Invoke(ctx, "/CommServer/Llen", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Lpop(ctx context.Context, in *LpopRequest, opts ...grpc.CallOption) (*LpopResponse, error) {
out := new(LpopResponse)
err := c.cc.Invoke(ctx, "/CommServer/Lpop", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Lpush(ctx context.Context, in *LpushRequest, opts ...grpc.CallOption) (*LpushResponse, error) {
out := new(LpushResponse)
err := c.cc.Invoke(ctx, "/CommServer/Lpush", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Lpushx(ctx context.Context, in *LpushxRequest, opts ...grpc.CallOption) (*LpushxResponse, error) {
out := new(LpushxResponse)
err := c.cc.Invoke(ctx, "/CommServer/Lpushx", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Lrange(ctx context.Context, in *LrangeRequest, opts ...grpc.CallOption) (*LrangeResponse, error) {
out := new(LrangeResponse)
err := c.cc.Invoke(ctx, "/CommServer/Lrange", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Lrem(ctx context.Context, in *LremRequest, opts ...grpc.CallOption) (*LremResponse, error) {
out := new(LremResponse)
err := c.cc.Invoke(ctx, "/CommServer/Lrem", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Lset(ctx context.Context, in *LsetRequest, opts ...grpc.CallOption) (*LsetResponse, error) {
out := new(LsetResponse)
err := c.cc.Invoke(ctx, "/CommServer/Lset", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Rpop(ctx context.Context, in *RpopRequest, opts ...grpc.CallOption) (*RpopResponse, error) {
out := new(RpopResponse)
err := c.cc.Invoke(ctx, "/CommServer/Rpop", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Ltrim(ctx context.Context, in *LtrimRequest, opts ...grpc.CallOption) (*LtrimResponse, error) {
out := new(LtrimResponse)
err := c.cc.Invoke(ctx, "/CommServer/Ltrim", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Rpush(ctx context.Context, in *RpushRequest, opts ...grpc.CallOption) (*RpushResponse, error) {
out := new(RpushResponse)
err := c.cc.Invoke(ctx, "/CommServer/Rpush", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *commServerClient) Rpushx(ctx context.Context, in *RpushxRequest, opts ...grpc.CallOption) (*RpushxResponse, error) {
out := new(RpushxResponse)
err := c.cc.Invoke(ctx, "/CommServer/Rpushx", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// CommServerServer is the server API for CommServer service. // CommServerServer is the server API for CommServer service.
type CommServerServer interface { type CommServerServer interface {
Set(context.Context, *SetRequest) (*SetResponse, error) Set(context.Context, *SetRequest) (*SetResponse, error)
@ -270,6 +470,18 @@ type CommServerServer interface {
Getset(context.Context, *GetsetRequest) (*GetsetResponse, error) Getset(context.Context, *GetsetRequest) (*GetsetResponse, error)
Strlen(context.Context, *StrlenRequest) (*StrlenResponse, error) Strlen(context.Context, *StrlenRequest) (*StrlenResponse, error)
Setnx(context.Context, *SetnxRequest) (*SetnxResponse, error) Setnx(context.Context, *SetnxRequest) (*SetnxResponse, error)
Lindex(context.Context, *LindexRequest) (*LindexResponse, error)
Llen(context.Context, *LlenRequest) (*LlenResponse, error)
Lpop(context.Context, *LpopRequest) (*LpopResponse, error)
Lpush(context.Context, *LpushRequest) (*LpushResponse, error)
Lpushx(context.Context, *LpushxRequest) (*LpushxResponse, error)
Lrange(context.Context, *LrangeRequest) (*LrangeResponse, error)
Lrem(context.Context, *LremRequest) (*LremResponse, error)
Lset(context.Context, *LsetRequest) (*LsetResponse, error)
Rpop(context.Context, *RpopRequest) (*RpopResponse, error)
Ltrim(context.Context, *LtrimRequest) (*LtrimResponse, error)
Rpush(context.Context, *RpushRequest) (*RpushResponse, error)
Rpushx(context.Context, *RpushxRequest) (*RpushxResponse, error)
} }
// UnimplementedCommServerServer can be embedded to have forward compatible implementations. // UnimplementedCommServerServer can be embedded to have forward compatible implementations.
@ -306,6 +518,42 @@ func (*UnimplementedCommServerServer) Strlen(context.Context, *StrlenRequest) (*
func (*UnimplementedCommServerServer) Setnx(context.Context, *SetnxRequest) (*SetnxResponse, error) { func (*UnimplementedCommServerServer) Setnx(context.Context, *SetnxRequest) (*SetnxResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Setnx not implemented") return nil, status.Errorf(codes.Unimplemented, "method Setnx not implemented")
} }
func (*UnimplementedCommServerServer) Lindex(context.Context, *LindexRequest) (*LindexResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Lindex not implemented")
}
func (*UnimplementedCommServerServer) Llen(context.Context, *LlenRequest) (*LlenResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Llen not implemented")
}
func (*UnimplementedCommServerServer) Lpop(context.Context, *LpopRequest) (*LpopResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Lpop not implemented")
}
func (*UnimplementedCommServerServer) Lpush(context.Context, *LpushRequest) (*LpushResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Lpush not implemented")
}
func (*UnimplementedCommServerServer) Lpushx(context.Context, *LpushxRequest) (*LpushxResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Lpushx not implemented")
}
func (*UnimplementedCommServerServer) Lrange(context.Context, *LrangeRequest) (*LrangeResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Lrange not implemented")
}
func (*UnimplementedCommServerServer) Lrem(context.Context, *LremRequest) (*LremResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Lrem not implemented")
}
func (*UnimplementedCommServerServer) Lset(context.Context, *LsetRequest) (*LsetResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Lset not implemented")
}
func (*UnimplementedCommServerServer) Rpop(context.Context, *RpopRequest) (*RpopResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Rpop not implemented")
}
func (*UnimplementedCommServerServer) Ltrim(context.Context, *LtrimRequest) (*LtrimResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Ltrim not implemented")
}
func (*UnimplementedCommServerServer) Rpush(context.Context, *RpushRequest) (*RpushResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Rpush not implemented")
}
func (*UnimplementedCommServerServer) Rpushx(context.Context, *RpushxRequest) (*RpushxResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Rpushx not implemented")
}
func RegisterCommServerServer(s *grpc.Server, srv CommServerServer) { func RegisterCommServerServer(s *grpc.Server, srv CommServerServer) {
s.RegisterService(&_CommServer_serviceDesc, srv) s.RegisterService(&_CommServer_serviceDesc, srv)
@ -491,6 +739,222 @@ func _CommServer_Setnx_Handler(srv interface{}, ctx context.Context, dec func(in
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _CommServer_Lindex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LindexRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Lindex(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Lindex",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Lindex(ctx, req.(*LindexRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Llen_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LlenRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Llen(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Llen",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Llen(ctx, req.(*LlenRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Lpop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LpopRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Lpop(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Lpop",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Lpop(ctx, req.(*LpopRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Lpush_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LpushRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Lpush(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Lpush",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Lpush(ctx, req.(*LpushRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Lpushx_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LpushxRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Lpushx(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Lpushx",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Lpushx(ctx, req.(*LpushxRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Lrange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LrangeRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Lrange(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Lrange",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Lrange(ctx, req.(*LrangeRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Lrem_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LremRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Lrem(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Lrem",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Lrem(ctx, req.(*LremRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Lset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LsetRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Lset(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Lset",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Lset(ctx, req.(*LsetRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Rpop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RpopRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Rpop(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Rpop",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Rpop(ctx, req.(*RpopRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Ltrim_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(LtrimRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Ltrim(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Ltrim",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Ltrim(ctx, req.(*LtrimRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Rpush_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RpushRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Rpush(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Rpush",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Rpush(ctx, req.(*RpushRequest))
}
return interceptor(ctx, in, info, handler)
}
func _CommServer_Rpushx_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(RpushxRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(CommServerServer).Rpushx(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/CommServer/Rpushx",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(CommServerServer).Rpushx(ctx, req.(*RpushxRequest))
}
return interceptor(ctx, in, info, handler)
}
var _CommServer_serviceDesc = grpc.ServiceDesc{ var _CommServer_serviceDesc = grpc.ServiceDesc{
ServiceName: "CommServer", ServiceName: "CommServer",
HandlerType: (*CommServerServer)(nil), HandlerType: (*CommServerServer)(nil),
@ -535,6 +999,54 @@ var _CommServer_serviceDesc = grpc.ServiceDesc{
MethodName: "Setnx", MethodName: "Setnx",
Handler: _CommServer_Setnx_Handler, Handler: _CommServer_Setnx_Handler,
}, },
{
MethodName: "Lindex",
Handler: _CommServer_Lindex_Handler,
},
{
MethodName: "Llen",
Handler: _CommServer_Llen_Handler,
},
{
MethodName: "Lpop",
Handler: _CommServer_Lpop_Handler,
},
{
MethodName: "Lpush",
Handler: _CommServer_Lpush_Handler,
},
{
MethodName: "Lpushx",
Handler: _CommServer_Lpushx_Handler,
},
{
MethodName: "Lrange",
Handler: _CommServer_Lrange_Handler,
},
{
MethodName: "Lrem",
Handler: _CommServer_Lrem_Handler,
},
{
MethodName: "Lset",
Handler: _CommServer_Lset_Handler,
},
{
MethodName: "Rpop",
Handler: _CommServer_Rpop_Handler,
},
{
MethodName: "Ltrim",
Handler: _CommServer_Ltrim_Handler,
},
{
MethodName: "Rpush",
Handler: _CommServer_Rpush_Handler,
},
{
MethodName: "Rpushx",
Handler: _CommServer_Rpushx_Handler,
},
}, },
Streams: []grpc.StreamDesc{}, Streams: []grpc.StreamDesc{},
Metadata: "storage.proto", Metadata: "storage.proto",

37
pkg/structure/const.gen.go
View File

@ -7,6 +7,7 @@ const (
DEFAULT_KEY = iota DEFAULT_KEY = iota
STRING_X STRING_X
LIST_X
) )
const ( const (
@ -21,6 +22,18 @@ const (
GETSET GETSET
STRLEN STRLEN
SETNX SETNX
LINDEX
LLEN
LPOP
LPUSH
LPUSHX
LRANGE
LREM
LSET
RPOP
LTRIM
RPUSH
RPUSHX
) )
var CommKeyString = map[string]int{"set": STRING_X, var CommKeyString = map[string]int{"set": STRING_X,
@ -33,6 +46,18 @@ var CommKeyString = map[string]int{"set": STRING_X,
"getset": STRING_X, "getset": STRING_X,
"strlen": STRING_X, "strlen": STRING_X,
"setnx": STRING_X, "setnx": STRING_X,
"lindex": LIST_X,
"llen": LIST_X,
"lpop": LIST_X,
"lpush": LIST_X,
"lpushx": LIST_X,
"lrange": LIST_X,
"lrem": LIST_X,
"lset": LIST_X,
"rpop": LIST_X,
"ltrim": LIST_X,
"rpush": LIST_X,
"rpushx": LIST_X,
} }
var CommKey = map[int]int{SET: STRING_X, var CommKey = map[int]int{SET: STRING_X,
@ -45,4 +70,16 @@ var CommKey = map[int]int{SET: STRING_X,
GETSET: STRING_X, GETSET: STRING_X,
STRLEN: STRING_X, STRLEN: STRING_X,
SETNX: STRING_X, SETNX: STRING_X,
LINDEX: LIST_X,
LLEN: LIST_X,
LPOP: LIST_X,
LPUSH: LIST_X,
LPUSHX: LIST_X,
LRANGE: LIST_X,
LREM: LIST_X,
LSET: LIST_X,
RPOP: LIST_X,
LTRIM: LIST_X,
RPUSH: LIST_X,
RPUSHX: LIST_X,
} }

16
pkg/structure/generate/tem.yaml
View File

@ -11,4 +11,18 @@ STRING_X:
- getrange - getrange
- getset - getset
- strlen - strlen
- setnx - setnx
LIST_X:
- lindex
- llen
- lpop
- lpush
- lpushx # 列表不存在则不插入
- lrange
- lrem
- lset
- rpop
- ltrim # 对列表进行切片
- rpush
- rpushx # 对已经存在的列表尾插

87
protobuf/listx.proto Normal file
View File

@ -0,0 +1,87 @@
syntax = "proto3";
import "base.proto";
option go_package = "pkg/proto";
message LindexRequest {
BaseKey key = 1;
}
message LindexResponse {
}
message LlenRequest {
BaseKey key = 1;
}
message LlenResponse {
}
message LpopRequest {
BaseKey key = 1;
}
message LpopResponse {
}
message LpushRequest {
BaseKey key = 1;
}
message LpushResponse {
}
message LpushxRequest {
BaseKey key = 1;
}
message LpushxResponse {
}
message LrangeRequest {
BaseKey key = 1;
}
message LrangeResponse {
}
message LremRequest {
BaseKey key = 1;
}
message LremResponse {
}
message LsetRequest {
BaseKey key = 1;
}
message LsetResponse {
}
message RpopRequest {
BaseKey key = 1;
}
message RpopResponse {
}
message LtrimRequest {
BaseKey key = 1;
}
message LtrimResponse {
}
message RpushRequest {
BaseKey key = 1;
}
message RpushResponse {
}
message RpushxRequest {
BaseKey key = 1;
}
message RpushxResponse {
}

13
protobuf/storage.proto
View File

@ -6,6 +6,7 @@ syntax = "proto3";
option go_package = "pkg/proto"; option go_package = "pkg/proto";
import "stringx.proto"; import "stringx.proto";
import "listx.proto";
service CommServer { service CommServer {
@ -19,4 +20,16 @@ service CommServer {
rpc Getset (GetsetRequest) returns (GetsetResponse); rpc Getset (GetsetRequest) returns (GetsetResponse);
rpc Strlen (StrlenRequest) returns (StrlenResponse); rpc Strlen (StrlenRequest) returns (StrlenResponse);
rpc Setnx (SetnxRequest) returns (SetnxResponse); rpc Setnx (SetnxRequest) returns (SetnxResponse);
rpc Lindex (LindexRequest) returns (LindexResponse);
rpc Llen (LlenRequest) returns (LlenResponse);
rpc Lpop (LpopRequest) returns (LpopResponse);
rpc Lpush (LpushRequest) returns (LpushResponse);
rpc Lpushx (LpushxRequest) returns (LpushxResponse);
rpc Lrange (LrangeRequest) returns (LrangeResponse);
rpc Lrem (LremRequest) returns (LremResponse);
rpc Lset (LsetRequest) returns (LsetResponse);
rpc Rpop (RpopRequest) returns (RpopResponse);
rpc Ltrim (LtrimRequest) returns (LtrimResponse);
rpc Rpush (RpushRequest) returns (RpushResponse);
rpc Rpushx (RpushxRequest) returns (RpushxResponse);
} }