From f9abd97cd28a1151d338b13d7a400844039922fe Mon Sep 17 00:00:00 2001 From: cq-bot Date: Wed, 25 Jun 2025 10:57:53 +0000 Subject: [PATCH] fix: Generate Java Code from `plugin-pb` --- .../plugin/v3/PluginOuterClass.java | 187 ++-- .../java/io/cloudquery/plugin/v3/Sync.java | 881 ++++++++++++++++++ .../java/io/cloudquery/plugin/v3/Write.java | 10 +- .../proto/cloudquery/plugin/v3/plugin.proto | 6 + 4 files changed, 992 insertions(+), 92 deletions(-) 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; } } }