@@ -1331,6 +1331,25 @@ def update!(**args)
13311331 end
13321332 end
13331333
1334+ # MongoDB change stream position
1335+ class MongodbChangeStreamPosition
1336+ include Google ::Apis ::Core ::Hashable
1337+
1338+ # Required. The timestamp (in epoch seconds) to start change stream from.
1339+ # Corresponds to the JSON property `startTime`
1340+ # @return [String]
1341+ attr_accessor :start_time
1342+
1343+ def initialize ( **args )
1344+ update! ( **args )
1345+ end
1346+
1347+ # Update properties of this object
1348+ def update! ( **args )
1349+ @start_time = args [ :start_time ] if args . key? ( :start_time )
1350+ end
1351+ end
1352+
13341353 # MongoDB Cluster structure.
13351354 class MongodbCluster
13361355 include Google ::Apis ::Core ::Hashable
@@ -3488,6 +3507,11 @@ def update!(**args)
34883507 class SpecificStartPosition
34893508 include Google ::Apis ::Core ::Hashable
34903509
3510+ # MongoDB change stream position
3511+ # Corresponds to the JSON property `mongodbChangeStreamPosition`
3512+ # @return [Google::Apis::DatastreamV1::MongodbChangeStreamPosition]
3513+ attr_accessor :mongodb_change_stream_position
3514+
34913515 # MySQL GTID position
34923516 # Corresponds to the JSON property `mysqlGtidPosition`
34933517 # @return [Google::Apis::DatastreamV1::MysqlGtidPosition]
@@ -3514,6 +3538,7 @@ def initialize(**args)
35143538
35153539 # Update properties of this object
35163540 def update! ( **args )
3541+ @mongodb_change_stream_position = args [ :mongodb_change_stream_position ] if args . key? ( :mongodb_change_stream_position )
35173542 @mysql_gtid_position = args [ :mysql_gtid_position ] if args . key? ( :mysql_gtid_position )
35183543 @mysql_log_position = args [ :mysql_log_position ] if args . key? ( :mysql_log_position )
35193544 @oracle_scn_position = args [ :oracle_scn_position ] if args . key? ( :oracle_scn_position )
0 commit comments