diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
index 88db6e8..3679a0e 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
@@ -120,6 +120,11 @@ public static void registerAllExtensions(
static final
com.google.protobuf.GeneratedMessage.FieldAccessorTable
internal_static_cloudquery_plugin_v3_Sync_MessageDeleteRecord_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_cloudquery_plugin_v3_Sync_MessageError_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internal_static_cloudquery_plugin_v3_Sync_MessageError_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_cloudquery_plugin_v3_Sync_BackendOptions_descriptor;
static final
@@ -286,94 +291,96 @@ public static void registerAllExtensions(
"ponse\"v\n\tGetTables\032M\n\007Request\022\016\n\006tables\030" +
"\001 \003(\t\022\023\n\013skip_tables\030\002 \003(\t\022\035\n\025skip_depen" +
"dent_tables\030\003 \001(\010\032\032\n\010Response\022\016\n\006tables\030" +
- "\001 \003(\014\"\252\006\n\004Sync\032\037\n\rMessageInsert\022\016\n\006recor" +
+ "\001 \003(\014\"\227\007\n\004Sync\032\037\n\rMessageInsert\022\016\n\006recor" +
"d\030\001 \001(\014\032$\n\023MessageMigrateTable\022\r\n\005table\030" +
"\001 \001(\014\032\244\001\n\023MessageDeleteRecord\022\022\n\ntable_n" +
"ame\030\001 \001(\t\022;\n\014where_clause\030\002 \003(\0132%.cloudq" +
"uery.plugin.v3.PredicatesGroup\022<\n\017table_" +
"relations\030\003 \003(\0132#.cloudquery.plugin.v3.T" +
- "ableRelation\0328\n\016BackendOptions\022\022\n\ntable_" +
- "name\030\001 \001(\t\022\022\n\nconnection\030\002 \001(\t\032\223\002\n\007Reque" +
- "st\022\016\n\006tables\030\001 \003(\t\022\023\n\013skip_tables\030\002 \003(\t\022" +
- "\035\n\025skip_dependent_tables\030\003 \001(\010\022\033\n\023determ" +
- "inistic_cq_id\030\004 \001(\010\022:\n\007backend\030\005 \001(\0132).c" +
- "loudquery.plugin.v3.Sync.BackendOptions\022" +
- "<\n\005shard\030\006 \001(\0132(.cloudquery.plugin.v3.Sy" +
- "nc.Request.ShardH\000\210\001\001\032#\n\005Shard\022\013\n\003num\030\001 " +
- "\001(\005\022\r\n\005total\030\002 \001(\005B\010\n\006_shard\032\343\001\n\010Respons" +
- "e\022G\n\rmigrate_table\030\001 \001(\0132..cloudquery.pl" +
- "ugin.v3.Sync.MessageMigrateTableH\000\022:\n\006in" +
- "sert\030\002 \001(\0132(.cloudquery.plugin.v3.Sync.M" +
- "essageInsertH\000\022G\n\rdelete_record\030\003 \001(\0132.." +
- "cloudquery.plugin.v3.Sync.MessageDeleteR" +
- "ecordH\000B\t\n\007message\"<\n\004Read\032\030\n\007Request\022\r\n" +
- "\005table\030\001 \001(\014\032\032\n\010Response\022\016\n\006record\030\001 \001(\014" +
- "\"9\n\rTableRelation\022\022\n\ntable_name\030\001 \001(\t\022\024\n" +
- "\014parent_table\030\002 \001(\t\"{\n\tPredicate\022:\n\010oper" +
- "ator\030\001 \001(\0162(.cloudquery.plugin.v3.Predic" +
- "ate.Operator\022\016\n\006column\030\002 \001(\t\022\016\n\006record\030\003" +
- " \001(\014\"\022\n\010Operator\022\006\n\002EQ\020\000\"\262\001\n\017PredicatesG" +
- "roup\022I\n\rgrouping_type\030\001 \001(\01622.cloudquery" +
- ".plugin.v3.PredicatesGroup.GroupingType\022" +
- "3\n\npredicates\030\002 \003(\0132\037.cloudquery.plugin." +
- "v3.Predicate\"\037\n\014GroupingType\022\007\n\003AND\020\000\022\006\n" +
- "\002OR\020\001\"\303\005\n\005Write\032;\n\023MessageMigrateTable\022\r" +
- "\n\005table\030\001 \001(\014\022\025\n\rmigrate_force\030\002 \001(\010\032\037\n\r" +
- "MessageInsert\022\016\n\006record\030\001 \001(\014\032\177\n\022Message" +
- "DeleteStale\022\021\n\005table\030\001 \001(\014B\002\030\001\022\023\n\013source" +
- "_name\030\002 \001(\t\022-\n\tsync_time\030\003 \001(\0132\032.google." +
- "protobuf.Timestamp\022\022\n\ntable_name\030\004 \001(\t\032\244" +
- "\001\n\023MessageDeleteRecord\022\022\n\ntable_name\030\001 \001" +
- "(\t\022;\n\014where_clause\030\002 \003(\0132%.cloudquery.pl" +
- "ugin.v3.PredicatesGroup\022<\n\017table_relatio" +
- "ns\030\003 \003(\0132#.cloudquery.plugin.v3.TableRel" +
- "ation\032\247\002\n\007Request\022H\n\rmigrate_table\030\001 \001(\013" +
- "2/.cloudquery.plugin.v3.Write.MessageMig" +
- "rateTableH\000\022;\n\006insert\030\002 \001(\0132).cloudquery" +
- ".plugin.v3.Write.MessageInsertH\000\022@\n\006dele" +
- "te\030\003 \001(\0132..cloudquery.plugin.v3.Write.Me" +
- "ssageDeleteStaleH\000\022H\n\rdelete_record\030\004 \001(" +
- "\0132/.cloudquery.plugin.v3.Write.MessageDe" +
- "leteRecordH\000B\t\n\007message\032\n\n\010Response\"B\n\tT" +
- "ransform\032\031\n\007Request\022\016\n\006record\030\001 \001(\014\032\032\n\010R" +
- "esponse\022\016\n\006record\030\001 \001(\014\"H\n\017TransformSche" +
- "ma\032\031\n\007Request\022\016\n\006schema\030\001 \001(\014\032\032\n\010Respons" +
- "e\022\016\n\006schema\030\001 \001(\014\"\036\n\005Close\032\t\n\007Request\032\n\n" +
- "\010Response\"y\n\016TestConnection\032\027\n\007Request\022\014" +
- "\n\004spec\030\001 \001(\014\032N\n\010Response\022\017\n\007success\030\001 \001(" +
- "\010\022\024\n\014failure_code\030\002 \001(\t\022\033\n\023failure_descr" +
- "iption\030\003 \001(\t2\367\010\n\006Plugin\022X\n\007GetName\022%.clo" +
- "udquery.plugin.v3.GetName.Request\032&.clou" +
- "dquery.plugin.v3.GetName.Response\022a\n\nGet" +
- "Version\022(.cloudquery.plugin.v3.GetVersio" +
- "n.Request\032).cloudquery.plugin.v3.GetVers" +
- "ion.Response\022j\n\rGetSpecSchema\022+.cloudque" +
- "ry.plugin.v3.GetSpecSchema.Request\032,.clo" +
- "udquery.plugin.v3.GetSpecSchema.Response" +
- "\022O\n\004Init\022\".cloudquery.plugin.v3.Init.Req" +
- "uest\032#.cloudquery.plugin.v3.Init.Respons" +
- "e\022^\n\tGetTables\022\'.cloudquery.plugin.v3.Ge" +
- "tTables.Request\032(.cloudquery.plugin.v3.G" +
- "etTables.Response\022Q\n\004Sync\022\".cloudquery.p" +
- "lugin.v3.Sync.Request\032#.cloudquery.plugi" +
- "n.v3.Sync.Response0\001\022Q\n\004Read\022\".cloudquer" +
- "y.plugin.v3.Read.Request\032#.cloudquery.pl" +
- "ugin.v3.Read.Response0\001\022T\n\005Write\022#.cloud" +
- "query.plugin.v3.Write.Request\032$.cloudque" +
- "ry.plugin.v3.Write.Response(\001\022b\n\tTransfo" +
- "rm\022\'.cloudquery.plugin.v3.Transform.Requ" +
- "est\032(.cloudquery.plugin.v3.Transform.Res" +
- "ponse(\0010\001\022p\n\017TransformSchema\022-.cloudquer" +
- "y.plugin.v3.TransformSchema.Request\032..cl" +
- "oudquery.plugin.v3.TransformSchema.Respo" +
- "nse\022R\n\005Close\022#.cloudquery.plugin.v3.Clos" +
- "e.Request\032$.cloudquery.plugin.v3.Close.R" +
- "esponse\022m\n\016TestConnection\022,.cloudquery.p" +
- "lugin.v3.TestConnection.Request\032-.cloudq" +
- "uery.plugin.v3.TestConnection.ResponseBS" +
- "\n\027io.cloudquery.plugin.v3P\001Z6github.com/" +
- "cloudquery/plugin-pb-go/pb/plugin/v3;plu" +
- "ginb\006proto3"
+ "ableRelation\0321\n\014MessageError\022\022\n\ntable_na" +
+ "me\030\001 \001(\t\022\r\n\005error\030\002 \001(\t\0328\n\016BackendOption" +
+ "s\022\022\n\ntable_name\030\001 \001(\t\022\022\n\nconnection\030\002 \001(" +
+ "\t\032\223\002\n\007Request\022\016\n\006tables\030\001 \003(\t\022\023\n\013skip_ta" +
+ "bles\030\002 \003(\t\022\035\n\025skip_dependent_tables\030\003 \001(" +
+ "\010\022\033\n\023deterministic_cq_id\030\004 \001(\010\022:\n\007backen" +
+ "d\030\005 \001(\0132).cloudquery.plugin.v3.Sync.Back" +
+ "endOptions\022<\n\005shard\030\006 \001(\0132(.cloudquery.p" +
+ "lugin.v3.Sync.Request.ShardH\000\210\001\001\032#\n\005Shar" +
+ "d\022\013\n\003num\030\001 \001(\005\022\r\n\005total\030\002 \001(\005B\010\n\006_shard\032" +
+ "\235\002\n\010Response\022G\n\rmigrate_table\030\001 \001(\0132..cl" +
+ "oudquery.plugin.v3.Sync.MessageMigrateTa" +
+ "bleH\000\022:\n\006insert\030\002 \001(\0132(.cloudquery.plugi" +
+ "n.v3.Sync.MessageInsertH\000\022G\n\rdelete_reco" +
+ "rd\030\003 \001(\0132..cloudquery.plugin.v3.Sync.Mes" +
+ "sageDeleteRecordH\000\0228\n\005error\030\004 \001(\0132\'.clou" +
+ "dquery.plugin.v3.Sync.MessageErrorH\000B\t\n\007" +
+ "message\"<\n\004Read\032\030\n\007Request\022\r\n\005table\030\001 \001(" +
+ "\014\032\032\n\010Response\022\016\n\006record\030\001 \001(\014\"9\n\rTableRe" +
+ "lation\022\022\n\ntable_name\030\001 \001(\t\022\024\n\014parent_tab" +
+ "le\030\002 \001(\t\"{\n\tPredicate\022:\n\010operator\030\001 \001(\0162" +
+ "(.cloudquery.plugin.v3.Predicate.Operato" +
+ "r\022\016\n\006column\030\002 \001(\t\022\016\n\006record\030\003 \001(\014\"\022\n\010Ope" +
+ "rator\022\006\n\002EQ\020\000\"\262\001\n\017PredicatesGroup\022I\n\rgro" +
+ "uping_type\030\001 \001(\01622.cloudquery.plugin.v3." +
+ "PredicatesGroup.GroupingType\0223\n\npredicat" +
+ "es\030\002 \003(\0132\037.cloudquery.plugin.v3.Predicat" +
+ "e\"\037\n\014GroupingType\022\007\n\003AND\020\000\022\006\n\002OR\020\001\"\303\005\n\005W" +
+ "rite\032;\n\023MessageMigrateTable\022\r\n\005table\030\001 \001" +
+ "(\014\022\025\n\rmigrate_force\030\002 \001(\010\032\037\n\rMessageInse" +
+ "rt\022\016\n\006record\030\001 \001(\014\032\177\n\022MessageDeleteStale" +
+ "\022\021\n\005table\030\001 \001(\014B\002\030\001\022\023\n\013source_name\030\002 \001(\t" +
+ "\022-\n\tsync_time\030\003 \001(\0132\032.google.protobuf.Ti" +
+ "mestamp\022\022\n\ntable_name\030\004 \001(\t\032\244\001\n\023MessageD" +
+ "eleteRecord\022\022\n\ntable_name\030\001 \001(\t\022;\n\014where" +
+ "_clause\030\002 \003(\0132%.cloudquery.plugin.v3.Pre" +
+ "dicatesGroup\022<\n\017table_relations\030\003 \003(\0132#." +
+ "cloudquery.plugin.v3.TableRelation\032\247\002\n\007R" +
+ "equest\022H\n\rmigrate_table\030\001 \001(\0132/.cloudque" +
+ "ry.plugin.v3.Write.MessageMigrateTableH\000" +
+ "\022;\n\006insert\030\002 \001(\0132).cloudquery.plugin.v3." +
+ "Write.MessageInsertH\000\022@\n\006delete\030\003 \001(\0132.." +
+ "cloudquery.plugin.v3.Write.MessageDelete" +
+ "StaleH\000\022H\n\rdelete_record\030\004 \001(\0132/.cloudqu" +
+ "ery.plugin.v3.Write.MessageDeleteRecordH" +
+ "\000B\t\n\007message\032\n\n\010Response\"B\n\tTransform\032\031\n" +
+ "\007Request\022\016\n\006record\030\001 \001(\014\032\032\n\010Response\022\016\n\006" +
+ "record\030\001 \001(\014\"H\n\017TransformSchema\032\031\n\007Reque" +
+ "st\022\016\n\006schema\030\001 \001(\014\032\032\n\010Response\022\016\n\006schema" +
+ "\030\001 \001(\014\"\036\n\005Close\032\t\n\007Request\032\n\n\010Response\"y" +
+ "\n\016TestConnection\032\027\n\007Request\022\014\n\004spec\030\001 \001(" +
+ "\014\032N\n\010Response\022\017\n\007success\030\001 \001(\010\022\024\n\014failur" +
+ "e_code\030\002 \001(\t\022\033\n\023failure_description\030\003 \001(" +
+ "\t2\367\010\n\006Plugin\022X\n\007GetName\022%.cloudquery.plu" +
+ "gin.v3.GetName.Request\032&.cloudquery.plug" +
+ "in.v3.GetName.Response\022a\n\nGetVersion\022(.c" +
+ "loudquery.plugin.v3.GetVersion.Request\032)" +
+ ".cloudquery.plugin.v3.GetVersion.Respons" +
+ "e\022j\n\rGetSpecSchema\022+.cloudquery.plugin.v" +
+ "3.GetSpecSchema.Request\032,.cloudquery.plu" +
+ "gin.v3.GetSpecSchema.Response\022O\n\004Init\022\"." +
+ "cloudquery.plugin.v3.Init.Request\032#.clou" +
+ "dquery.plugin.v3.Init.Response\022^\n\tGetTab" +
+ "les\022\'.cloudquery.plugin.v3.GetTables.Req" +
+ "uest\032(.cloudquery.plugin.v3.GetTables.Re" +
+ "sponse\022Q\n\004Sync\022\".cloudquery.plugin.v3.Sy" +
+ "nc.Request\032#.cloudquery.plugin.v3.Sync.R" +
+ "esponse0\001\022Q\n\004Read\022\".cloudquery.plugin.v3" +
+ ".Read.Request\032#.cloudquery.plugin.v3.Rea" +
+ "d.Response0\001\022T\n\005Write\022#.cloudquery.plugi" +
+ "n.v3.Write.Request\032$.cloudquery.plugin.v" +
+ "3.Write.Response(\001\022b\n\tTransform\022\'.cloudq" +
+ "uery.plugin.v3.Transform.Request\032(.cloud" +
+ "query.plugin.v3.Transform.Response(\0010\001\022p" +
+ "\n\017TransformSchema\022-.cloudquery.plugin.v3" +
+ ".TransformSchema.Request\032..cloudquery.pl" +
+ "ugin.v3.TransformSchema.Response\022R\n\005Clos" +
+ "e\022#.cloudquery.plugin.v3.Close.Request\032$" +
+ ".cloudquery.plugin.v3.Close.Response\022m\n\016" +
+ "TestConnection\022,.cloudquery.plugin.v3.Te" +
+ "stConnection.Request\032-.cloudquery.plugin" +
+ ".v3.TestConnection.ResponseBS\n\027io.cloudq" +
+ "uery.plugin.v3P\001Z6github.com/cloudquery/" +
+ "plugin-pb-go/pb/plugin/v3;pluginb\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
@@ -494,14 +501,20 @@ public static void registerAllExtensions(
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_cloudquery_plugin_v3_Sync_MessageDeleteRecord_descriptor,
new java.lang.String[] { "TableName", "WhereClause", "TableRelations", });
- internal_static_cloudquery_plugin_v3_Sync_BackendOptions_descriptor =
+ internal_static_cloudquery_plugin_v3_Sync_MessageError_descriptor =
internal_static_cloudquery_plugin_v3_Sync_descriptor.getNestedTypes().get(3);
+ internal_static_cloudquery_plugin_v3_Sync_MessageError_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessage.FieldAccessorTable(
+ internal_static_cloudquery_plugin_v3_Sync_MessageError_descriptor,
+ new java.lang.String[] { "TableName", "Error", });
+ internal_static_cloudquery_plugin_v3_Sync_BackendOptions_descriptor =
+ internal_static_cloudquery_plugin_v3_Sync_descriptor.getNestedTypes().get(4);
internal_static_cloudquery_plugin_v3_Sync_BackendOptions_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_cloudquery_plugin_v3_Sync_BackendOptions_descriptor,
new java.lang.String[] { "TableName", "Connection", });
internal_static_cloudquery_plugin_v3_Sync_Request_descriptor =
- internal_static_cloudquery_plugin_v3_Sync_descriptor.getNestedTypes().get(4);
+ internal_static_cloudquery_plugin_v3_Sync_descriptor.getNestedTypes().get(5);
internal_static_cloudquery_plugin_v3_Sync_Request_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_cloudquery_plugin_v3_Sync_Request_descriptor,
@@ -513,11 +526,11 @@ public static void registerAllExtensions(
internal_static_cloudquery_plugin_v3_Sync_Request_Shard_descriptor,
new java.lang.String[] { "Num", "Total", });
internal_static_cloudquery_plugin_v3_Sync_Response_descriptor =
- internal_static_cloudquery_plugin_v3_Sync_descriptor.getNestedTypes().get(5);
+ internal_static_cloudquery_plugin_v3_Sync_descriptor.getNestedTypes().get(6);
internal_static_cloudquery_plugin_v3_Sync_Response_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_cloudquery_plugin_v3_Sync_Response_descriptor,
- new java.lang.String[] { "MigrateTable", "Insert", "DeleteRecord", "Message", });
+ new java.lang.String[] { "MigrateTable", "Insert", "DeleteRecord", "Error", "Message", });
internal_static_cloudquery_plugin_v3_Read_descriptor =
getDescriptor().getMessageTypes().get(6);
internal_static_cloudquery_plugin_v3_Read_fieldAccessorTable = new
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java
index 3723b1a..fe09417 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java
@@ -2214,6 +2214,664 @@ public io.cloudquery.plugin.v3.Sync.MessageDeleteRecord getDefaultInstanceForTyp
}
+ public interface MessageErrorOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Sync.MessageError)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * string table_name = 1;
+ * @return The tableName.
+ */
+ java.lang.String getTableName();
+ /**
+ * string table_name = 1;
+ * @return The bytes for tableName.
+ */
+ com.google.protobuf.ByteString
+ getTableNameBytes();
+
+ /**
+ * string error = 2;
+ * @return The error.
+ */
+ java.lang.String getError();
+ /**
+ * string error = 2;
+ * @return The bytes for error.
+ */
+ com.google.protobuf.ByteString
+ getErrorBytes();
+ }
+ /**
+ * Protobuf type {@code cloudquery.plugin.v3.Sync.MessageError}
+ */
+ public static final class MessageError extends
+ com.google.protobuf.GeneratedMessage implements
+ // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Sync.MessageError)
+ MessageErrorOrBuilder {
+ private static final long serialVersionUID = 0L;
+ static {
+ com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
+ com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
+ /* major= */ 4,
+ /* minor= */ 30,
+ /* patch= */ 2,
+ /* suffix= */ "",
+ MessageError.class.getName());
+ }
+ // Use MessageError.newBuilder() to construct.
+ private MessageError(com.google.protobuf.GeneratedMessage.Builder builder) {
+ super(builder);
+ }
+ private MessageError() {
+ tableName_ = "";
+ error_ = "";
+ }
+
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_Sync_MessageError_descriptor;
+ }
+
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_Sync_MessageError_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ io.cloudquery.plugin.v3.Sync.MessageError.class, io.cloudquery.plugin.v3.Sync.MessageError.Builder.class);
+ }
+
+ public static final int TABLE_NAME_FIELD_NUMBER = 1;
+ @SuppressWarnings("serial")
+ private volatile java.lang.Object tableName_ = "";
+ /**
+ * string table_name = 1;
+ * @return The tableName.
+ */
+ @java.lang.Override
+ public java.lang.String getTableName() {
+ java.lang.Object ref = tableName_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ tableName_ = s;
+ return s;
+ }
+ }
+ /**
+ * string table_name = 1;
+ * @return The bytes for tableName.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getTableNameBytes() {
+ java.lang.Object ref = tableName_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ tableName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int ERROR_FIELD_NUMBER = 2;
+ @SuppressWarnings("serial")
+ private volatile java.lang.Object error_ = "";
+ /**
+ * string error = 2;
+ * @return The error.
+ */
+ @java.lang.Override
+ public java.lang.String getError() {
+ java.lang.Object ref = error_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ error_ = s;
+ return s;
+ }
+ }
+ /**
+ * string error = 2;
+ * @return The bytes for error.
+ */
+ @java.lang.Override
+ public com.google.protobuf.ByteString
+ getErrorBytes() {
+ java.lang.Object ref = error_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ error_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (!com.google.protobuf.GeneratedMessage.isStringEmpty(tableName_)) {
+ com.google.protobuf.GeneratedMessage.writeString(output, 1, tableName_);
+ }
+ if (!com.google.protobuf.GeneratedMessage.isStringEmpty(error_)) {
+ com.google.protobuf.GeneratedMessage.writeString(output, 2, error_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!com.google.protobuf.GeneratedMessage.isStringEmpty(tableName_)) {
+ size += com.google.protobuf.GeneratedMessage.computeStringSize(1, tableName_);
+ }
+ if (!com.google.protobuf.GeneratedMessage.isStringEmpty(error_)) {
+ size += com.google.protobuf.GeneratedMessage.computeStringSize(2, error_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof io.cloudquery.plugin.v3.Sync.MessageError)) {
+ return super.equals(obj);
+ }
+ io.cloudquery.plugin.v3.Sync.MessageError other = (io.cloudquery.plugin.v3.Sync.MessageError) obj;
+
+ if (!getTableName()
+ .equals(other.getTableName())) return false;
+ if (!getError()
+ .equals(other.getError())) return false;
+ if (!getUnknownFields().equals(other.getUnknownFields())) return false;
+ return true;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + TABLE_NAME_FIELD_NUMBER;
+ hash = (53 * hash) + getTableName().hashCode();
+ hash = (37 * hash) + ERROR_FIELD_NUMBER;
+ hash = (53 * hash) + getError().hashCode();
+ hash = (29 * hash) + getUnknownFields().hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessage
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessage
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessage
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessage
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessage
+ .parseWithIOException(PARSER, input);
+ }
+ public static io.cloudquery.plugin.v3.Sync.MessageError parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessage
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(io.cloudquery.plugin.v3.Sync.MessageError prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code cloudquery.plugin.v3.Sync.MessageError}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builder implements
+ // @@protoc_insertion_point(builder_implements:cloudquery.plugin.v3.Sync.MessageError)
+ io.cloudquery.plugin.v3.Sync.MessageErrorOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_Sync_MessageError_descriptor;
+ }
+
+ @java.lang.Override
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_Sync_MessageError_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ io.cloudquery.plugin.v3.Sync.MessageError.class, io.cloudquery.plugin.v3.Sync.MessageError.Builder.class);
+ }
+
+ // Construct using io.cloudquery.plugin.v3.Sync.MessageError.newBuilder()
+ private Builder() {
+
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ super(parent);
+
+ }
+ @java.lang.Override
+ public Builder clear() {
+ super.clear();
+ bitField0_ = 0;
+ tableName_ = "";
+ error_ = "";
+ return this;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return io.cloudquery.plugin.v3.PluginOuterClass.internal_static_cloudquery_plugin_v3_Sync_MessageError_descriptor;
+ }
+
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageError getDefaultInstanceForType() {
+ return io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance();
+ }
+
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageError build() {
+ io.cloudquery.plugin.v3.Sync.MessageError result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageError buildPartial() {
+ io.cloudquery.plugin.v3.Sync.MessageError result = new io.cloudquery.plugin.v3.Sync.MessageError(this);
+ if (bitField0_ != 0) { buildPartial0(result); }
+ onBuilt();
+ return result;
+ }
+
+ private void buildPartial0(io.cloudquery.plugin.v3.Sync.MessageError result) {
+ int from_bitField0_ = bitField0_;
+ if (((from_bitField0_ & 0x00000001) != 0)) {
+ result.tableName_ = tableName_;
+ }
+ if (((from_bitField0_ & 0x00000002) != 0)) {
+ result.error_ = error_;
+ }
+ }
+
+ @java.lang.Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof io.cloudquery.plugin.v3.Sync.MessageError) {
+ return mergeFrom((io.cloudquery.plugin.v3.Sync.MessageError)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(io.cloudquery.plugin.v3.Sync.MessageError other) {
+ if (other == io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance()) return this;
+ if (!other.getTableName().isEmpty()) {
+ tableName_ = other.tableName_;
+ bitField0_ |= 0x00000001;
+ onChanged();
+ }
+ if (!other.getError().isEmpty()) {
+ error_ = other.error_;
+ bitField0_ |= 0x00000002;
+ onChanged();
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ onChanged();
+ return this;
+ }
+
+ @java.lang.Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @java.lang.Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ if (extensionRegistry == null) {
+ throw new java.lang.NullPointerException();
+ }
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ tableName_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000001;
+ break;
+ } // case 10
+ case 18: {
+ error_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000002;
+ break;
+ } // case 18
+ default: {
+ if (!super.parseUnknownField(input, extensionRegistry, tag)) {
+ done = true; // was an endgroup tag
+ }
+ break;
+ } // default:
+ } // switch (tag)
+ } // while (!done)
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.unwrapIOException();
+ } finally {
+ onChanged();
+ } // finally
+ return this;
+ }
+ private int bitField0_;
+
+ private java.lang.Object tableName_ = "";
+ /**
+ * string table_name = 1;
+ * @return The tableName.
+ */
+ public java.lang.String getTableName() {
+ java.lang.Object ref = tableName_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ tableName_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * string table_name = 1;
+ * @return The bytes for tableName.
+ */
+ public com.google.protobuf.ByteString
+ getTableNameBytes() {
+ java.lang.Object ref = tableName_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ tableName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * string table_name = 1;
+ * @param value The tableName to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTableName(
+ java.lang.String value) {
+ if (value == null) { throw new NullPointerException(); }
+ tableName_ = value;
+ bitField0_ |= 0x00000001;
+ onChanged();
+ return this;
+ }
+ /**
+ * string table_name = 1;
+ * @return This builder for chaining.
+ */
+ public Builder clearTableName() {
+ tableName_ = getDefaultInstance().getTableName();
+ bitField0_ = (bitField0_ & ~0x00000001);
+ onChanged();
+ return this;
+ }
+ /**
+ * string table_name = 1;
+ * @param value The bytes for tableName to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTableNameBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) { throw new NullPointerException(); }
+ checkByteStringIsUtf8(value);
+ tableName_ = value;
+ bitField0_ |= 0x00000001;
+ onChanged();
+ return this;
+ }
+
+ private java.lang.Object error_ = "";
+ /**
+ * string error = 2;
+ * @return The error.
+ */
+ public java.lang.String getError() {
+ java.lang.Object ref = error_;
+ if (!(ref instanceof java.lang.String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ error_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * string error = 2;
+ * @return The bytes for error.
+ */
+ public com.google.protobuf.ByteString
+ getErrorBytes() {
+ java.lang.Object ref = error_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ error_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * string error = 2;
+ * @param value The error to set.
+ * @return This builder for chaining.
+ */
+ public Builder setError(
+ java.lang.String value) {
+ if (value == null) { throw new NullPointerException(); }
+ error_ = value;
+ bitField0_ |= 0x00000002;
+ onChanged();
+ return this;
+ }
+ /**
+ * string error = 2;
+ * @return This builder for chaining.
+ */
+ public Builder clearError() {
+ error_ = getDefaultInstance().getError();
+ bitField0_ = (bitField0_ & ~0x00000002);
+ onChanged();
+ return this;
+ }
+ /**
+ * string error = 2;
+ * @param value The bytes for error to set.
+ * @return This builder for chaining.
+ */
+ public Builder setErrorBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) { throw new NullPointerException(); }
+ checkByteStringIsUtf8(value);
+ error_ = value;
+ bitField0_ |= 0x00000002;
+ onChanged();
+ return this;
+ }
+
+ // @@protoc_insertion_point(builder_scope:cloudquery.plugin.v3.Sync.MessageError)
+ }
+
+ // @@protoc_insertion_point(class_scope:cloudquery.plugin.v3.Sync.MessageError)
+ private static final io.cloudquery.plugin.v3.Sync.MessageError DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new io.cloudquery.plugin.v3.Sync.MessageError();
+ }
+
+ public static io.cloudquery.plugin.v3.Sync.MessageError getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @java.lang.Override
+ public MessageError parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ Builder builder = newBuilder();
+ try {
+ builder.mergeFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(builder.buildPartial());
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(e)
+ .setUnfinishedMessage(builder.buildPartial());
+ }
+ return builder.buildPartial();
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Parser getParserForType() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageError getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+ }
+
public interface BackendOptionsOrBuilder extends
// @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Sync.BackendOptions)
com.google.protobuf.MessageOrBuilder {
@@ -4843,6 +5501,21 @@ public interface ResponseOrBuilder extends
*/
io.cloudquery.plugin.v3.Sync.MessageDeleteRecordOrBuilder getDeleteRecordOrBuilder();
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ * @return Whether the error field is set.
+ */
+ boolean hasError();
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ * @return The error.
+ */
+ io.cloudquery.plugin.v3.Sync.MessageError getError();
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ io.cloudquery.plugin.v3.Sync.MessageErrorOrBuilder getErrorOrBuilder();
+
io.cloudquery.plugin.v3.Sync.Response.MessageCase getMessageCase();
}
/**
@@ -4891,6 +5564,7 @@ public enum MessageCase
MIGRATE_TABLE(1),
INSERT(2),
DELETE_RECORD(3),
+ ERROR(4),
MESSAGE_NOT_SET(0);
private final int value;
private MessageCase(int value) {
@@ -4911,6 +5585,7 @@ public static MessageCase forNumber(int value) {
case 1: return MIGRATE_TABLE;
case 2: return INSERT;
case 3: return DELETE_RECORD;
+ case 4: return ERROR;
case 0: return MESSAGE_NOT_SET;
default: return null;
}
@@ -5019,6 +5694,37 @@ public io.cloudquery.plugin.v3.Sync.MessageDeleteRecordOrBuilder getDeleteRecord
return io.cloudquery.plugin.v3.Sync.MessageDeleteRecord.getDefaultInstance();
}
+ public static final int ERROR_FIELD_NUMBER = 4;
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ * @return Whether the error field is set.
+ */
+ @java.lang.Override
+ public boolean hasError() {
+ return messageCase_ == 4;
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ * @return The error.
+ */
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageError getError() {
+ if (messageCase_ == 4) {
+ return (io.cloudquery.plugin.v3.Sync.MessageError) message_;
+ }
+ return io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance();
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageErrorOrBuilder getErrorOrBuilder() {
+ if (messageCase_ == 4) {
+ return (io.cloudquery.plugin.v3.Sync.MessageError) message_;
+ }
+ return io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance();
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
public final boolean isInitialized() {
@@ -5042,6 +5748,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
if (messageCase_ == 3) {
output.writeMessage(3, (io.cloudquery.plugin.v3.Sync.MessageDeleteRecord) message_);
}
+ if (messageCase_ == 4) {
+ output.writeMessage(4, (io.cloudquery.plugin.v3.Sync.MessageError) message_);
+ }
getUnknownFields().writeTo(output);
}
@@ -5063,6 +5772,10 @@ public int getSerializedSize() {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(3, (io.cloudquery.plugin.v3.Sync.MessageDeleteRecord) message_);
}
+ if (messageCase_ == 4) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(4, (io.cloudquery.plugin.v3.Sync.MessageError) message_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
@@ -5092,6 +5805,10 @@ public boolean equals(final java.lang.Object obj) {
if (!getDeleteRecord()
.equals(other.getDeleteRecord())) return false;
break;
+ case 4:
+ if (!getError()
+ .equals(other.getError())) return false;
+ break;
case 0:
default:
}
@@ -5119,6 +5836,10 @@ public int hashCode() {
hash = (37 * hash) + DELETE_RECORD_FIELD_NUMBER;
hash = (53 * hash) + getDeleteRecord().hashCode();
break;
+ case 4:
+ hash = (37 * hash) + ERROR_FIELD_NUMBER;
+ hash = (53 * hash) + getError().hashCode();
+ break;
case 0:
default:
}
@@ -5262,6 +5983,9 @@ public Builder clear() {
if (deleteRecordBuilder_ != null) {
deleteRecordBuilder_.clear();
}
+ if (errorBuilder_ != null) {
+ errorBuilder_.clear();
+ }
messageCase_ = 0;
message_ = null;
return this;
@@ -5315,6 +6039,10 @@ private void buildPartialOneofs(io.cloudquery.plugin.v3.Sync.Response result) {
deleteRecordBuilder_ != null) {
result.message_ = deleteRecordBuilder_.build();
}
+ if (messageCase_ == 4 &&
+ errorBuilder_ != null) {
+ result.message_ = errorBuilder_.build();
+ }
}
@java.lang.Override
@@ -5342,6 +6070,10 @@ public Builder mergeFrom(io.cloudquery.plugin.v3.Sync.Response other) {
mergeDeleteRecord(other.getDeleteRecord());
break;
}
+ case ERROR: {
+ mergeError(other.getError());
+ break;
+ }
case MESSAGE_NOT_SET: {
break;
}
@@ -5393,6 +6125,13 @@ public Builder mergeFrom(
messageCase_ = 3;
break;
} // case 26
+ case 34: {
+ input.readMessage(
+ internalGetErrorFieldBuilder().getBuilder(),
+ extensionRegistry);
+ messageCase_ = 4;
+ break;
+ } // case 34
default: {
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
done = true; // was an endgroup tag
@@ -5851,6 +6590,148 @@ public io.cloudquery.plugin.v3.Sync.MessageDeleteRecordOrBuilder getDeleteRecord
return deleteRecordBuilder_;
}
+ private com.google.protobuf.SingleFieldBuilder<
+ io.cloudquery.plugin.v3.Sync.MessageError, io.cloudquery.plugin.v3.Sync.MessageError.Builder, io.cloudquery.plugin.v3.Sync.MessageErrorOrBuilder> errorBuilder_;
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ * @return Whether the error field is set.
+ */
+ @java.lang.Override
+ public boolean hasError() {
+ return messageCase_ == 4;
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ * @return The error.
+ */
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageError getError() {
+ if (errorBuilder_ == null) {
+ if (messageCase_ == 4) {
+ return (io.cloudquery.plugin.v3.Sync.MessageError) message_;
+ }
+ return io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance();
+ } else {
+ if (messageCase_ == 4) {
+ return errorBuilder_.getMessage();
+ }
+ return io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance();
+ }
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ public Builder setError(io.cloudquery.plugin.v3.Sync.MessageError value) {
+ if (errorBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ message_ = value;
+ onChanged();
+ } else {
+ errorBuilder_.setMessage(value);
+ }
+ messageCase_ = 4;
+ return this;
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ public Builder setError(
+ io.cloudquery.plugin.v3.Sync.MessageError.Builder builderForValue) {
+ if (errorBuilder_ == null) {
+ message_ = builderForValue.build();
+ onChanged();
+ } else {
+ errorBuilder_.setMessage(builderForValue.build());
+ }
+ messageCase_ = 4;
+ return this;
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ public Builder mergeError(io.cloudquery.plugin.v3.Sync.MessageError value) {
+ if (errorBuilder_ == null) {
+ if (messageCase_ == 4 &&
+ message_ != io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance()) {
+ message_ = io.cloudquery.plugin.v3.Sync.MessageError.newBuilder((io.cloudquery.plugin.v3.Sync.MessageError) message_)
+ .mergeFrom(value).buildPartial();
+ } else {
+ message_ = value;
+ }
+ onChanged();
+ } else {
+ if (messageCase_ == 4) {
+ errorBuilder_.mergeFrom(value);
+ } else {
+ errorBuilder_.setMessage(value);
+ }
+ }
+ messageCase_ = 4;
+ return this;
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ public Builder clearError() {
+ if (errorBuilder_ == null) {
+ if (messageCase_ == 4) {
+ messageCase_ = 0;
+ message_ = null;
+ onChanged();
+ }
+ } else {
+ if (messageCase_ == 4) {
+ messageCase_ = 0;
+ message_ = null;
+ }
+ errorBuilder_.clear();
+ }
+ return this;
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ public io.cloudquery.plugin.v3.Sync.MessageError.Builder getErrorBuilder() {
+ return internalGetErrorFieldBuilder().getBuilder();
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ @java.lang.Override
+ public io.cloudquery.plugin.v3.Sync.MessageErrorOrBuilder getErrorOrBuilder() {
+ if ((messageCase_ == 4) && (errorBuilder_ != null)) {
+ return errorBuilder_.getMessageOrBuilder();
+ } else {
+ if (messageCase_ == 4) {
+ return (io.cloudquery.plugin.v3.Sync.MessageError) message_;
+ }
+ return io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance();
+ }
+ }
+ /**
+ * .cloudquery.plugin.v3.Sync.MessageError error = 4;
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ io.cloudquery.plugin.v3.Sync.MessageError, io.cloudquery.plugin.v3.Sync.MessageError.Builder, io.cloudquery.plugin.v3.Sync.MessageErrorOrBuilder>
+ internalGetErrorFieldBuilder() {
+ if (errorBuilder_ == null) {
+ if (!(messageCase_ == 4)) {
+ message_ = io.cloudquery.plugin.v3.Sync.MessageError.getDefaultInstance();
+ }
+ errorBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ io.cloudquery.plugin.v3.Sync.MessageError, io.cloudquery.plugin.v3.Sync.MessageError.Builder, io.cloudquery.plugin.v3.Sync.MessageErrorOrBuilder>(
+ (io.cloudquery.plugin.v3.Sync.MessageError) message_,
+ getParentForChildren(),
+ isClean());
+ message_ = null;
+ }
+ messageCase_ = 4;
+ onChanged();
+ return errorBuilder_;
+ }
+
// @@protoc_insertion_point(builder_scope:cloudquery.plugin.v3.Sync.Response)
}
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
index 7c644a1..5998f84 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
@@ -1036,7 +1036,7 @@ public interface MessageDeleteStaleOrBuilder extends
*
* bytes table = 1 [deprecated = true];
* @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
- * See cloudquery/plugin/v3/plugin.proto;l=180
+ * See cloudquery/plugin/v3/plugin.proto;l=186
* @return The table.
*/
@java.lang.Deprecated com.google.protobuf.ByteString getTable();
@@ -1130,7 +1130,7 @@ private MessageDeleteStale() {
*
* bytes table = 1 [deprecated = true];
* @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
- * See cloudquery/plugin/v3/plugin.proto;l=180
+ * See cloudquery/plugin/v3/plugin.proto;l=186
* @return The table.
*/
@java.lang.Override
@@ -1636,7 +1636,7 @@ public Builder mergeFrom(
*
* bytes table = 1 [deprecated = true];
* @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
- * See cloudquery/plugin/v3/plugin.proto;l=180
+ * See cloudquery/plugin/v3/plugin.proto;l=186
* @return The table.
*/
@java.lang.Override
@@ -1650,7 +1650,7 @@ public Builder mergeFrom(
*
* bytes table = 1 [deprecated = true];
* @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
- * See cloudquery/plugin/v3/plugin.proto;l=180
+ * See cloudquery/plugin/v3/plugin.proto;l=186
* @param value The table to set.
* @return This builder for chaining.
*/
@@ -1668,7 +1668,7 @@ public Builder mergeFrom(
*
* bytes table = 1 [deprecated = true];
* @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
- * See cloudquery/plugin/v3/plugin.proto;l=180
+ * See cloudquery/plugin/v3/plugin.proto;l=186
* @return This builder for chaining.
*/
@java.lang.Deprecated public Builder clearTable() {
diff --git a/src/main/proto/cloudquery/plugin/v3/plugin.proto b/src/main/proto/cloudquery/plugin/v3/plugin.proto
index 62050ed..fd423aa 100644
--- a/src/main/proto/cloudquery/plugin/v3/plugin.proto
+++ b/src/main/proto/cloudquery/plugin/v3/plugin.proto
@@ -95,6 +95,11 @@ message Sync {
repeated PredicatesGroup where_clause = 2;
repeated TableRelation table_relations = 3;
}
+ message MessageError {
+ string table_name = 1;
+ string error = 2;
+ }
+
message BackendOptions {
// table name to use for state backend
@@ -119,6 +124,7 @@ message Sync {
Sync.MessageMigrateTable migrate_table = 1;
Sync.MessageInsert insert = 2;
Sync.MessageDeleteRecord delete_record = 3;
+ Sync.MessageError error = 4;
}
}
}