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

Merge pull request #1 from stevensurgnier/master 

clean up
pull/1/head
Xavier 2014-10-16 14:53:15 -07:00
parent cc0b8d56cb 7b7cd4e43a
commit 08803b8c92
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
proto/pg_logicaldec.proto
View File

@ -1,6 +1,6 @@
package decoderbufs; package decoderbufs;
option java_package="dedoderbufs.proto"; option java_package="decoderbufs.proto";
option java_outer_classname = "PgldProto"; option java_outer_classname = "PgldProto";
option optimize_for = SPEED; option optimize_for = SPEED;
@ -11,20 +11,20 @@ enum Op {
} }
message DatumMessage { message DatumMessage {
optional string column_name = 1; optional string column_name = 1;
optional int64 column_type = 2; optional int64 column_type = 2;
optional int32 datum_int32 = 3; optional int32 datum_int32 = 3;
optional int64 datum_int64 = 4; optional int64 datum_int64 = 4;
optional float datum_float = 5; optional float datum_float = 5;
optional double datum_double = 6; optional double datum_double = 6;
optional bool datum_bool = 7; optional bool datum_bool = 7;
optional string datum_string = 8; optional string datum_string = 8;
optional bytes datum_bytes = 9; optional bytes datum_bytes = 9;
} }
message RowMessage { message RowMessage {
optional sint64 commit_time = 1; optional sint64 commit_time = 1;
optional string table = 2; optional string table = 2;
optional Op op = 3; optional Op op = 3;
repeated DatumMessage new_tuple = 4; repeated DatumMessage new_tuple = 4;
repeated DatumMessage old_tuple = 5; repeated DatumMessage old_tuple = 5;