classes.rb in google-apis-datastream_v1-0.13.0

- old
+ new

@@ -1001,18 +1001,25 @@
         # MySQL database structure
         # Corresponds to the JSON property `includeObjects`
         # @return [Google::Apis::DatastreamV1::MysqlRdbms]
         attr_accessor :include_objects
       
+        # Maximum number of concurrent CDC tasks. The number should be non negative. If
+        # not set (or set to 0), the system's default value will be used.
+        # Corresponds to the JSON property `maxConcurrentCdcTasks`
+        # @return [Fixnum]
+        attr_accessor :max_concurrent_cdc_tasks
+      
         def initialize(**args)
            update!(**args)
         end
       
         # Update properties of this object
         def update!(**args)
           @exclude_objects = args[:exclude_objects] if args.key?(:exclude_objects)
           @include_objects = args[:include_objects] if args.key?(:include_objects)
+          @max_concurrent_cdc_tasks = args[:max_concurrent_cdc_tasks] if args.key?(:max_concurrent_cdc_tasks)
         end
       end
       
       # MySQL SSL configuration information.
       class MysqlSslConfig
@@ -1428,19 +1435,32 @@
         # Oracle database structure.
         # Corresponds to the JSON property `includeObjects`
         # @return [Google::Apis::DatastreamV1::OracleRdbms]
         attr_accessor :include_objects
       
+        # Maximum number of concurrent CDC tasks. The number should be non negative. If
+        # not set (or set to 0), the system's default value will be used.
+        # Corresponds to the JSON property `maxConcurrentCdcTasks`
+        # @return [Fixnum]
+        attr_accessor :max_concurrent_cdc_tasks
+      
+        # Configuration to stream large object values.
+        # Corresponds to the JSON property `streamLargeObjects`
+        # @return [Google::Apis::DatastreamV1::StreamLargeObjects]
+        attr_accessor :stream_large_objects
+      
         def initialize(**args)
            update!(**args)
         end
       
         # Update properties of this object
         def update!(**args)
           @drop_large_objects = args[:drop_large_objects] if args.key?(:drop_large_objects)
           @exclude_objects = args[:exclude_objects] if args.key?(:exclude_objects)
           @include_objects = args[:include_objects] if args.key?(:include_objects)
+          @max_concurrent_cdc_tasks = args[:max_concurrent_cdc_tasks] if args.key?(:max_concurrent_cdc_tasks)
+          @stream_large_objects = args[:stream_large_objects] if args.key?(:stream_large_objects)
         end
       end
       
       # Oracle table.
       class OracleTable
@@ -1864,9 +1884,22 @@
           @labels = args[:labels] if args.key?(:labels)
           @name = args[:name] if args.key?(:name)
           @source_config = args[:source_config] if args.key?(:source_config)
           @state = args[:state] if args.key?(:state)
           @update_time = args[:update_time] if args.key?(:update_time)
+        end
+      end
+      
+      # Configuration to stream large object values.
+      class StreamLargeObjects
+        include Google::Apis::Core::Hashable
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
         end
       end
       
       # A specific stream object (e.g a specific DB table).
       class StreamObject