external
/
postgres-decoderbufs
mirror of https://github.com/debezium/postgres-decoderbufs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DBZ-1052 DBZ-1746 Add unknown message type

pull/25/head v1.0.1.Final
Jiri Pechanec 2020-01-30 12:20:40 +01:00 committed by Gunnar Morling
parent 870ecfa976
commit e29a2580a5
3 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
proto/pg_logicaldec.proto
View File

@ -5,6 +5,7 @@ option java_outer_classname = "PgProto";
option optimize_for = SPEED; option optimize_for = SPEED;
enum Op { enum Op {
UNKNOWN = -1;
INSERT = 0; INSERT = 0;
UPDATE = 1; UPDATE = 1;
DELETE = 2; DELETE = 2;

22
src/proto/pg_logicaldec.pb-c.c
View File

@ -565,8 +565,9 @@ const ProtobufCMessageDescriptor decoderbufs__row_message__descriptor =
(ProtobufCMessageInit) decoderbufs__row_message__init, (ProtobufCMessageInit) decoderbufs__row_message__init,
NULL,NULL,NULL /* reserved[123] */ NULL,NULL,NULL /* reserved[123] */
}; };
static const ProtobufCEnumValue decoderbufs__op__enum_values_by_number[5] = static const ProtobufCEnumValue decoderbufs__op__enum_values_by_number[6] =
{ {
{ "UNKNOWN", "DECODERBUFS__OP__UNKNOWN", -1 },
{ "INSERT", "DECODERBUFS__OP__INSERT", 0 }, { "INSERT", "DECODERBUFS__OP__INSERT", 0 },
{ "UPDATE", "DECODERBUFS__OP__UPDATE", 1 }, { "UPDATE", "DECODERBUFS__OP__UPDATE", 1 },
{ "DELETE", "DECODERBUFS__OP__DELETE", 2 }, { "DELETE", "DECODERBUFS__OP__DELETE", 2 },
@ -574,15 +575,16 @@ static const ProtobufCEnumValue decoderbufs__op__enum_values_by_number[5] =
{ "COMMIT", "DECODERBUFS__OP__COMMIT", 4 }, { "COMMIT", "DECODERBUFS__OP__COMMIT", 4 },
}; };
static const ProtobufCIntRange decoderbufs__op__value_ranges[] = { static const ProtobufCIntRange decoderbufs__op__value_ranges[] = {
{0, 0},{0, 5} {-1, 0},{0, 6}
}; };
static const ProtobufCEnumValueIndex decoderbufs__op__enum_values_by_name[5] = static const ProtobufCEnumValueIndex decoderbufs__op__enum_values_by_name[6] =
{ {
{ "BEGIN", 3 }, { "BEGIN", 4 },
{ "COMMIT", 4 }, { "COMMIT", 5 },
{ "DELETE", 2 }, { "DELETE", 3 },
{ "INSERT", 0 }, { "INSERT", 1 },
{ "UPDATE", 1 }, { "UNKNOWN", 0 },
{ "UPDATE", 2 },
}; };
const ProtobufCEnumDescriptor decoderbufs__op__descriptor = const ProtobufCEnumDescriptor decoderbufs__op__descriptor =
{ {
@ -591,9 +593,9 @@ const ProtobufCEnumDescriptor decoderbufs__op__descriptor =
"Op", "Op",
"Decoderbufs__Op", "Decoderbufs__Op",
"decoderbufs", "decoderbufs",
5, 6,
decoderbufs__op__enum_values_by_number, decoderbufs__op__enum_values_by_number,
5, 6,
decoderbufs__op__enum_values_by_name, decoderbufs__op__enum_values_by_name,
1, 1,
decoderbufs__op__value_ranges, decoderbufs__op__value_ranges,

1
src/proto/pg_logicaldec.pb-c.h
View File

@ -24,6 +24,7 @@ typedef struct _Decoderbufs__RowMessage Decoderbufs__RowMessage;
/* --- enums --- */ /* --- enums --- */
typedef enum _Decoderbufs__Op { typedef enum _Decoderbufs__Op {
DECODERBUFS__OP__UNKNOWN = -1,
DECODERBUFS__OP__INSERT = 0, DECODERBUFS__OP__INSERT = 0,
DECODERBUFS__OP__UPDATE = 1, DECODERBUFS__OP__UPDATE = 1,
DECODERBUFS__OP__DELETE = 2, DECODERBUFS__OP__DELETE = 2,