@@ -205,6 +205,44 @@ def update!(**args)
205205 end
206206 end
207207
208+ # Configuration to use Binary Log Parser CDC technique.
209+ class BinaryLogParser
210+ include Google ::Apis ::Core ::Hashable
211+
212+ # Configuration to specify the Oracle directories to access the log files.
213+ # Corresponds to the JSON property `logFileDirectories`
214+ # @return [Google::Apis::DatastreamV1::LogFileDirectories]
215+ attr_accessor :log_file_directories
216+
217+ # Configuration to use Oracle ASM to access the log files.
218+ # Corresponds to the JSON property `oracleAsmLogFileAccess`
219+ # @return [Google::Apis::DatastreamV1::OracleAsmLogFileAccess]
220+ attr_accessor :oracle_asm_log_file_access
221+
222+ def initialize ( **args )
223+ update! ( **args )
224+ end
225+
226+ # Update properties of this object
227+ def update! ( **args )
228+ @log_file_directories = args [ :log_file_directories ] if args . key? ( :log_file_directories )
229+ @oracle_asm_log_file_access = args [ :oracle_asm_log_file_access ] if args . key? ( :oracle_asm_log_file_access )
230+ end
231+ end
232+
233+ # Use Binary log position based replication.
234+ class BinaryLogPosition
235+ include Google ::Apis ::Core ::Hashable
236+
237+ def initialize ( **args )
238+ update! ( **args )
239+ end
240+
241+ # Update properties of this object
242+ def update! ( **args )
243+ end
244+ end
245+
208246 # The request message for Operations.CancelOperation.
209247 class CancelOperationRequest
210248 include Google ::Apis ::Core ::Hashable
@@ -300,7 +338,7 @@ class ConnectionProfile
300338 # @return [Google::Apis::DatastreamV1::OracleProfile]
301339 attr_accessor :oracle_profile
302340
303- # PostgreSQL database profile. Next ID: 7.
341+ # PostgreSQL database profile.
304342 # Corresponds to the JSON property `postgresqlProfile`
305343 # @return [Google::Apis::DatastreamV1::PostgresqlProfile]
306344 attr_accessor :postgresql_profile
@@ -733,6 +771,19 @@ def update!(**args)
733771 end
734772 end
735773
774+ # Use GTID based replication.
775+ class Gtid
776+ include Google ::Apis ::Core ::Hashable
777+
778+ def initialize ( **args )
779+ update! ( **args )
780+ end
781+
782+ # Update properties of this object
783+ def update! ( **args )
784+ end
785+ end
786+
736787 # JSON file format configuration.
737788 class JsonFileFormat
738789 include Google ::Apis ::Core ::Hashable
@@ -1008,6 +1059,44 @@ def update!(**args)
10081059 end
10091060 end
10101061
1062+ # Configuration to specify the Oracle directories to access the log files.
1063+ class LogFileDirectories
1064+ include Google ::Apis ::Core ::Hashable
1065+
1066+ # Required. Oracle directory for archived logs.
1067+ # Corresponds to the JSON property `archivedLogDirectory`
1068+ # @return [String]
1069+ attr_accessor :archived_log_directory
1070+
1071+ # Required. Oracle directory for online logs.
1072+ # Corresponds to the JSON property `onlineLogDirectory`
1073+ # @return [String]
1074+ attr_accessor :online_log_directory
1075+
1076+ def initialize ( **args )
1077+ update! ( **args )
1078+ end
1079+
1080+ # Update properties of this object
1081+ def update! ( **args )
1082+ @archived_log_directory = args [ :archived_log_directory ] if args . key? ( :archived_log_directory )
1083+ @online_log_directory = args [ :online_log_directory ] if args . key? ( :online_log_directory )
1084+ end
1085+ end
1086+
1087+ # Configuration to use LogMiner CDC method.
1088+ class LogMiner
1089+ include Google ::Apis ::Core ::Hashable
1090+
1091+ def initialize ( **args )
1092+ update! ( **args )
1093+ end
1094+
1095+ # Update properties of this object
1096+ def update! ( **args )
1097+ end
1098+ end
1099+
10111100 # Request for looking up a specific stream object by its source object
10121101 # identifier.
10131102 class LookupStreamObjectRequest
@@ -1267,11 +1356,21 @@ def update!(**args)
12671356 class MysqlSourceConfig
12681357 include Google ::Apis ::Core ::Hashable
12691358
1359+ # Use Binary log position based replication.
1360+ # Corresponds to the JSON property `binaryLogPosition`
1361+ # @return [Google::Apis::DatastreamV1::BinaryLogPosition]
1362+ attr_accessor :binary_log_position
1363+
12701364 # MySQL database structure
12711365 # Corresponds to the JSON property `excludeObjects`
12721366 # @return [Google::Apis::DatastreamV1::MysqlRdbms]
12731367 attr_accessor :exclude_objects
12741368
1369+ # Use GTID based replication.
1370+ # Corresponds to the JSON property `gtid`
1371+ # @return [Google::Apis::DatastreamV1::Gtid]
1372+ attr_accessor :gtid
1373+
12751374 # MySQL database structure
12761375 # Corresponds to the JSON property `includeObjects`
12771376 # @return [Google::Apis::DatastreamV1::MysqlRdbms]
@@ -1295,7 +1394,9 @@ def initialize(**args)
12951394
12961395 # Update properties of this object
12971396 def update! ( **args )
1397+ @binary_log_position = args [ :binary_log_position ] if args . key? ( :binary_log_position )
12981398 @exclude_objects = args [ :exclude_objects ] if args . key? ( :exclude_objects )
1399+ @gtid = args [ :gtid ] if args . key? ( :gtid )
12991400 @include_objects = args [ :include_objects ] if args . key? ( :include_objects )
13001401 @max_concurrent_backfill_tasks = args [ :max_concurrent_backfill_tasks ] if args . key? ( :max_concurrent_backfill_tasks )
13011402 @max_concurrent_cdc_tasks = args [ :max_concurrent_cdc_tasks ] if args . key? ( :max_concurrent_cdc_tasks )
@@ -1526,6 +1627,74 @@ def update!(**args)
15261627 end
15271628 end
15281629
1630+ # Configuration for Oracle Automatic Storage Management (ASM) connection.
1631+ class OracleAsmConfig
1632+ include Google ::Apis ::Core ::Hashable
1633+
1634+ # Required. ASM service name for the Oracle ASM connection.
1635+ # Corresponds to the JSON property `asmService`
1636+ # @return [String]
1637+ attr_accessor :asm_service
1638+
1639+ # Optional. Connection string attributes
1640+ # Corresponds to the JSON property `connectionAttributes`
1641+ # @return [Hash<String,String>]
1642+ attr_accessor :connection_attributes
1643+
1644+ # Required. Hostname for the Oracle ASM connection.
1645+ # Corresponds to the JSON property `hostname`
1646+ # @return [String]
1647+ attr_accessor :hostname
1648+
1649+ # Oracle SSL configuration information.
1650+ # Corresponds to the JSON property `oracleSslConfig`
1651+ # @return [Google::Apis::DatastreamV1::OracleSslConfig]
1652+ attr_accessor :oracle_ssl_config
1653+
1654+ # Required. Password for the Oracle ASM connection.
1655+ # Corresponds to the JSON property `password`
1656+ # @return [String]
1657+ attr_accessor :password
1658+
1659+ # Required. Port for the Oracle ASM connection.
1660+ # Corresponds to the JSON property `port`
1661+ # @return [Fixnum]
1662+ attr_accessor :port
1663+
1664+ # Required. Username for the Oracle ASM connection.
1665+ # Corresponds to the JSON property `username`
1666+ # @return [String]
1667+ attr_accessor :username
1668+
1669+ def initialize ( **args )
1670+ update! ( **args )
1671+ end
1672+
1673+ # Update properties of this object
1674+ def update! ( **args )
1675+ @asm_service = args [ :asm_service ] if args . key? ( :asm_service )
1676+ @connection_attributes = args [ :connection_attributes ] if args . key? ( :connection_attributes )
1677+ @hostname = args [ :hostname ] if args . key? ( :hostname )
1678+ @oracle_ssl_config = args [ :oracle_ssl_config ] if args . key? ( :oracle_ssl_config )
1679+ @password = args [ :password ] if args . key? ( :password )
1680+ @port = args [ :port ] if args . key? ( :port )
1681+ @username = args [ :username ] if args . key? ( :username )
1682+ end
1683+ end
1684+
1685+ # Configuration to use Oracle ASM to access the log files.
1686+ class OracleAsmLogFileAccess
1687+ include Google ::Apis ::Core ::Hashable
1688+
1689+ def initialize ( **args )
1690+ update! ( **args )
1691+ end
1692+
1693+ # Update properties of this object
1694+ def update! ( **args )
1695+ end
1696+ end
1697+
15291698 # Oracle Column.
15301699 class OracleColumn
15311700 include Google ::Apis ::Core ::Hashable
@@ -1639,6 +1808,11 @@ class OracleProfile
16391808 # @return [String]
16401809 attr_accessor :hostname
16411810
1811+ # Configuration for Oracle Automatic Storage Management (ASM) connection.
1812+ # Corresponds to the JSON property `oracleAsmConfig`
1813+ # @return [Google::Apis::DatastreamV1::OracleAsmConfig]
1814+ attr_accessor :oracle_asm_config
1815+
16421816 # Oracle SSL configuration information.
16431817 # Corresponds to the JSON property `oracleSslConfig`
16441818 # @return [Google::Apis::DatastreamV1::OracleSslConfig]
@@ -1655,6 +1829,12 @@ class OracleProfile
16551829 # @return [Fixnum]
16561830 attr_accessor :port
16571831
1832+ # Optional. A reference to a Secret Manager resource name storing the Oracle
1833+ # connection password. Mutually exclusive with the `password` field.
1834+ # Corresponds to the JSON property `secretManagerStoredPassword`
1835+ # @return [String]
1836+ attr_accessor :secret_manager_stored_password
1837+
16581838 # Required. Username for the Oracle connection.
16591839 # Corresponds to the JSON property `username`
16601840 # @return [String]
@@ -1669,9 +1849,11 @@ def update!(**args)
16691849 @connection_attributes = args [ :connection_attributes ] if args . key? ( :connection_attributes )
16701850 @database_service = args [ :database_service ] if args . key? ( :database_service )
16711851 @hostname = args [ :hostname ] if args . key? ( :hostname )
1852+ @oracle_asm_config = args [ :oracle_asm_config ] if args . key? ( :oracle_asm_config )
16721853 @oracle_ssl_config = args [ :oracle_ssl_config ] if args . key? ( :oracle_ssl_config )
16731854 @password = args [ :password ] if args . key? ( :password )
16741855 @port = args [ :port ] if args . key? ( :port )
1856+ @secret_manager_stored_password = args [ :secret_manager_stored_password ] if args . key? ( :secret_manager_stored_password )
16751857 @username = args [ :username ] if args . key? ( :username )
16761858 end
16771859 end
@@ -1743,6 +1925,11 @@ def update!(**args)
17431925 class OracleSourceConfig
17441926 include Google ::Apis ::Core ::Hashable
17451927
1928+ # Configuration to use Binary Log Parser CDC technique.
1929+ # Corresponds to the JSON property `binaryLogParser`
1930+ # @return [Google::Apis::DatastreamV1::BinaryLogParser]
1931+ attr_accessor :binary_log_parser
1932+
17461933 # Configuration to drop large object values.
17471934 # Corresponds to the JSON property `dropLargeObjects`
17481935 # @return [Google::Apis::DatastreamV1::DropLargeObjects]
@@ -1758,6 +1945,11 @@ class OracleSourceConfig
17581945 # @return [Google::Apis::DatastreamV1::OracleRdbms]
17591946 attr_accessor :include_objects
17601947
1948+ # Configuration to use LogMiner CDC method.
1949+ # Corresponds to the JSON property `logMiner`
1950+ # @return [Google::Apis::DatastreamV1::LogMiner]
1951+ attr_accessor :log_miner
1952+
17611953 # Maximum number of concurrent backfill tasks. The number should be non-negative.
17621954 # If not set (or set to 0), the system's default value is used.
17631955 # Corresponds to the JSON property `maxConcurrentBackfillTasks`
@@ -1781,9 +1973,11 @@ def initialize(**args)
17811973
17821974 # Update properties of this object
17831975 def update! ( **args )
1976+ @binary_log_parser = args [ :binary_log_parser ] if args . key? ( :binary_log_parser )
17841977 @drop_large_objects = args [ :drop_large_objects ] if args . key? ( :drop_large_objects )
17851978 @exclude_objects = args [ :exclude_objects ] if args . key? ( :exclude_objects )
17861979 @include_objects = args [ :include_objects ] if args . key? ( :include_objects )
1980+ @log_miner = args [ :log_miner ] if args . key? ( :log_miner )
17871981 @max_concurrent_backfill_tasks = args [ :max_concurrent_backfill_tasks ] if args . key? ( :max_concurrent_backfill_tasks )
17881982 @max_concurrent_cdc_tasks = args [ :max_concurrent_cdc_tasks ] if args . key? ( :max_concurrent_cdc_tasks )
17891983 @stream_large_objects = args [ :stream_large_objects ] if args . key? ( :stream_large_objects )
@@ -1932,7 +2126,7 @@ def update!(**args)
19322126 end
19332127 end
19342128
1935- # PostgreSQL database profile. Next ID: 7.
2129+ # PostgreSQL database profile.
19362130 class PostgresqlProfile
19372131 include Google ::Apis ::Core ::Hashable
19382132
0 commit comments