classes.rb in google-apis-datastream_v1-0.37.0

- old
+ new

@@ -2379,10 +2379,23 @@
           @mysql_log_position = args[:mysql_log_position] if args.key?(:mysql_log_position)
           @oracle_scn_position = args[:oracle_scn_position] if args.key?(:oracle_scn_position)
         end
       end
       
+      # Configuration to use Change Tables CDC read method.
+      class SqlServerChangeTables
+        include Google::Apis::Core::Hashable
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
+        end
+      end
+      
       # SQLServer Column.
       class SqlServerColumn
         include Google::Apis::Core::Hashable
       
         # Column name.
@@ -2558,10 +2571,15 @@
       
       # SQLServer data source configuration
       class SqlServerSourceConfig
         include Google::Apis::Core::Hashable
       
+        # Configuration to use Change Tables CDC read method.
+        # Corresponds to the JSON property `changeTables`
+        # @return [Google::Apis::DatastreamV1::SqlServerChangeTables]
+        attr_accessor :change_tables
+      
         # SQLServer database structure.
         # Corresponds to the JSON property `excludeObjects`
         # @return [Google::Apis::DatastreamV1::SqlServerRdbms]
         attr_accessor :exclude_objects
       
@@ -2578,20 +2596,27 @@
         # Max concurrent CDC tasks.
         # Corresponds to the JSON property `maxConcurrentCdcTasks`
         # @return [Fixnum]
         attr_accessor :max_concurrent_cdc_tasks
       
+        # Configuration to use Transaction Logs CDC read method.
+        # Corresponds to the JSON property `transactionLogs`
+        # @return [Google::Apis::DatastreamV1::SqlServerTransactionLogs]
+        attr_accessor :transaction_logs
+      
         def initialize(**args)
            update!(**args)
         end
       
         # Update properties of this object
         def update!(**args)
+          @change_tables = args[:change_tables] if args.key?(:change_tables)
           @exclude_objects = args[:exclude_objects] if args.key?(:exclude_objects)
           @include_objects = args[:include_objects] if args.key?(:include_objects)
           @max_concurrent_backfill_tasks = args[:max_concurrent_backfill_tasks] if args.key?(:max_concurrent_backfill_tasks)
           @max_concurrent_cdc_tasks = args[:max_concurrent_cdc_tasks] if args.key?(:max_concurrent_cdc_tasks)
+          @transaction_logs = args[:transaction_logs] if args.key?(:transaction_logs)
         end
       end
       
       # SQLServer table.
       class SqlServerTable
@@ -2614,9 +2639,22 @@
       
         # Update properties of this object
         def update!(**args)
           @columns = args[:columns] if args.key?(:columns)
           @table = args[:table] if args.key?(:table)
+        end
+      end
+      
+      # Configuration to use Transaction Logs CDC read method.
+      class SqlServerTransactionLogs
+        include Google::Apis::Core::Hashable
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
         end
       end
       
       # Request for manually initiating a backfill job for a specific stream object.
       class StartBackfillJobRequest