|
|
@ -23,28 +23,28 @@ const ( |
|
|
|
type OffsetType int32 |
|
|
|
|
|
|
|
const ( |
|
|
|
OffsetType_RESET_TO_EARLIEST OffsetType = 0 |
|
|
|
OffsetType_RESET_TO_LATEST OffsetType = 2 |
|
|
|
OffsetType_EXACT_TS_NS OffsetType = 3 |
|
|
|
OffsetType_RESUME_OR_EARLIEST OffsetType = 4 |
|
|
|
OffsetType_RESUME_OR_LATEST OffsetType = 5 |
|
|
|
OffsetType_RESUME_OR_EARLIEST OffsetType = 0 |
|
|
|
OffsetType_RESET_TO_EARLIEST OffsetType = 5 |
|
|
|
OffsetType_EXACT_TS_NS OffsetType = 10 |
|
|
|
OffsetType_RESET_TO_LATEST OffsetType = 15 |
|
|
|
OffsetType_RESUME_OR_LATEST OffsetType = 20 |
|
|
|
) |
|
|
|
|
|
|
|
// Enum value maps for OffsetType.
|
|
|
|
var ( |
|
|
|
OffsetType_name = map[int32]string{ |
|
|
|
0: "RESET_TO_EARLIEST", |
|
|
|
2: "RESET_TO_LATEST", |
|
|
|
3: "EXACT_TS_NS", |
|
|
|
4: "RESUME_OR_EARLIEST", |
|
|
|
5: "RESUME_OR_LATEST", |
|
|
|
0: "RESUME_OR_EARLIEST", |
|
|
|
5: "RESET_TO_EARLIEST", |
|
|
|
10: "EXACT_TS_NS", |
|
|
|
15: "RESET_TO_LATEST", |
|
|
|
20: "RESUME_OR_LATEST", |
|
|
|
} |
|
|
|
OffsetType_value = map[string]int32{ |
|
|
|
"RESET_TO_EARLIEST": 0, |
|
|
|
"RESET_TO_LATEST": 2, |
|
|
|
"EXACT_TS_NS": 3, |
|
|
|
"RESUME_OR_EARLIEST": 4, |
|
|
|
"RESUME_OR_LATEST": 5, |
|
|
|
"RESUME_OR_EARLIEST": 0, |
|
|
|
"RESET_TO_EARLIEST": 5, |
|
|
|
"EXACT_TS_NS": 10, |
|
|
|
"RESET_TO_LATEST": 15, |
|
|
|
"RESUME_OR_LATEST": 20, |
|
|
|
} |
|
|
|
) |
|
|
|
|
|
|
@ -1014,14 +1014,14 @@ var file_mq_schema_proto_rawDesc = []byte{ |
|
|
|
0x12, 0x28, 0x0a, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, |
|
|
|
0x32, 0x10, 0x2e, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x70, 0x62, 0x2e, 0x56, 0x61, 0x6c, |
|
|
|
0x75, 0x65, 0x52, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x2a, 0x77, 0x0a, 0x0a, 0x4f, 0x66, |
|
|
|
0x66, 0x73, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x15, 0x0a, 0x11, 0x52, 0x45, 0x53, 0x45, |
|
|
|
0x54, 0x5f, 0x54, 0x4f, 0x5f, 0x45, 0x41, 0x52, 0x4c, 0x49, 0x45, 0x53, 0x54, 0x10, 0x00, 0x12, |
|
|
|
0x13, 0x0a, 0x0f, 0x52, 0x45, 0x53, 0x45, 0x54, 0x5f, 0x54, 0x4f, 0x5f, 0x4c, 0x41, 0x54, 0x45, |
|
|
|
0x53, 0x54, 0x10, 0x02, 0x12, 0x0f, 0x0a, 0x0b, 0x45, 0x58, 0x41, 0x43, 0x54, 0x5f, 0x54, 0x53, |
|
|
|
0x5f, 0x4e, 0x53, 0x10, 0x03, 0x12, 0x16, 0x0a, 0x12, 0x52, 0x45, 0x53, 0x55, 0x4d, 0x45, 0x5f, |
|
|
|
0x4f, 0x52, 0x5f, 0x45, 0x41, 0x52, 0x4c, 0x49, 0x45, 0x53, 0x54, 0x10, 0x04, 0x12, 0x14, 0x0a, |
|
|
|
0x66, 0x73, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x16, 0x0a, 0x12, 0x52, 0x45, 0x53, 0x55, |
|
|
|
0x4d, 0x45, 0x5f, 0x4f, 0x52, 0x5f, 0x45, 0x41, 0x52, 0x4c, 0x49, 0x45, 0x53, 0x54, 0x10, 0x00, |
|
|
|
0x12, 0x15, 0x0a, 0x11, 0x52, 0x45, 0x53, 0x45, 0x54, 0x5f, 0x54, 0x4f, 0x5f, 0x45, 0x41, 0x52, |
|
|
|
0x4c, 0x49, 0x45, 0x53, 0x54, 0x10, 0x05, 0x12, 0x0f, 0x0a, 0x0b, 0x45, 0x58, 0x41, 0x43, 0x54, |
|
|
|
0x5f, 0x54, 0x53, 0x5f, 0x4e, 0x53, 0x10, 0x0a, 0x12, 0x13, 0x0a, 0x0f, 0x52, 0x45, 0x53, 0x45, |
|
|
|
0x54, 0x5f, 0x54, 0x4f, 0x5f, 0x4c, 0x41, 0x54, 0x45, 0x53, 0x54, 0x10, 0x0f, 0x12, 0x14, 0x0a, |
|
|
|
0x10, 0x52, 0x45, 0x53, 0x55, 0x4d, 0x45, 0x5f, 0x4f, 0x52, 0x5f, 0x4c, 0x41, 0x54, 0x45, 0x53, |
|
|
|
0x54, 0x10, 0x05, 0x2a, 0x5a, 0x0a, 0x0a, 0x53, 0x63, 0x61, 0x6c, 0x61, 0x72, 0x54, 0x79, 0x70, |
|
|
|
0x54, 0x10, 0x14, 0x2a, 0x5a, 0x0a, 0x0a, 0x53, 0x63, 0x61, 0x6c, 0x61, 0x72, 0x54, 0x79, 0x70, |
|
|
|
0x65, 0x12, 0x08, 0x0a, 0x04, 0x42, 0x4f, 0x4f, 0x4c, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x49, |
|
|
|
0x4e, 0x54, 0x33, 0x32, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x54, 0x36, 0x34, 0x10, |
|
|
|
0x03, 0x12, 0x09, 0x0a, 0x05, 0x46, 0x4c, 0x4f, 0x41, 0x54, 0x10, 0x04, 0x12, 0x0a, 0x0a, 0x06, |
|
|
|