@@ -165,6 +165,76 @@ def update!(**args)
165165 end
166166 end
167167
168+ # Request for archiving resource events.
169+ class GoogleCloudAssuredworkloadsV1ArchiveResourceEventsRequest
170+ include Google ::Apis ::Core ::Hashable
171+
172+ # Optional. Time to set as ArchiveTime in the archive table. If not provided,
173+ # the current time is used.
174+ # Corresponds to the JSON property `archiveTime`
175+ # @return [String]
176+ attr_accessor :archive_time
177+
178+ # Required. The number of events to process in a single transaction batch.
179+ # Corresponds to the JSON property `batchSize`
180+ # @return [Fixnum]
181+ attr_accessor :batch_size
182+
183+ # Required. Only events with EventTime earlier than this cutoff will be archived.
184+ # Corresponds to the JSON property `eventCutoffTime`
185+ # @return [String]
186+ attr_accessor :event_cutoff_time
187+
188+ # Required. The maximum total number of events to move in this request.
189+ # Corresponds to the JSON property `maxEventsMove`
190+ # @return [Fixnum]
191+ attr_accessor :max_events_move
192+
193+ # Required. The organization ID for which to archive events.
194+ # Corresponds to the JSON property `organizationId`
195+ # @return [Fixnum]
196+ attr_accessor :organization_id
197+
198+ # Required. The region of the workload(s) whose events should be archived. This
199+ # is used to filter workloads based on AssurantWorkloadData.region.
200+ # Corresponds to the JSON property `region`
201+ # @return [String]
202+ attr_accessor :region
203+
204+ def initialize ( **args )
205+ update! ( **args )
206+ end
207+
208+ # Update properties of this object
209+ def update! ( **args )
210+ @archive_time = args [ :archive_time ] if args . key? ( :archive_time )
211+ @batch_size = args [ :batch_size ] if args . key? ( :batch_size )
212+ @event_cutoff_time = args [ :event_cutoff_time ] if args . key? ( :event_cutoff_time )
213+ @max_events_move = args [ :max_events_move ] if args . key? ( :max_events_move )
214+ @organization_id = args [ :organization_id ] if args . key? ( :organization_id )
215+ @region = args [ :region ] if args . key? ( :region )
216+ end
217+ end
218+
219+ # Response for archiving resource events.
220+ class GoogleCloudAssuredworkloadsV1ArchiveResourceEventsResponse
221+ include Google ::Apis ::Core ::Hashable
222+
223+ # The total number of events successfully moved to the archive table.
224+ # Corresponds to the JSON property `movedEventsCount`
225+ # @return [Fixnum]
226+ attr_accessor :moved_events_count
227+
228+ def initialize ( **args )
229+ update! ( **args )
230+ end
231+
232+ # Update properties of this object
233+ def update! ( **args )
234+ @moved_events_count = args [ :moved_events_count ] if args . key? ( :moved_events_count )
235+ end
236+ end
237+
168238 # Represents move analysis results for an asset.
169239 class GoogleCloudAssuredworkloadsV1AssetMoveAnalysis
170240 include Google ::Apis ::Core ::Hashable
@@ -636,6 +706,77 @@ def update!(**args)
636706 end
637707 end
638708
709+ # Request for reverting archived resource events.
710+ class GoogleCloudAssuredworkloadsV1RevertArchivedResourceEventsRequest
711+ include Google ::Apis ::Core ::Hashable
712+
713+ # Required. Only events within this time range will be reverted. This helps
714+ # prevent reverting everything when something goes wrong.
715+ # Corresponds to the JSON property `archiveEndTime`
716+ # @return [String]
717+ attr_accessor :archive_end_time
718+
719+ # Required. Only events within this time range will be reverted. This helps
720+ # prevent reverting everything when something goes wrong.
721+ # Corresponds to the JSON property `archiveStartTime`
722+ # @return [String]
723+ attr_accessor :archive_start_time
724+
725+ # Required. The number of events to process in a single transaction batch.
726+ # Corresponds to the JSON property `batchSize`
727+ # @return [Fixnum]
728+ attr_accessor :batch_size
729+
730+ # Required. The maximum total number of events to move in this request.
731+ # Corresponds to the JSON property `maxEventsMove`
732+ # @return [Fixnum]
733+ attr_accessor :max_events_move
734+
735+ # Required. The organization ID for which to revert events.
736+ # Corresponds to the JSON property `organizationId`
737+ # @return [Fixnum]
738+ attr_accessor :organization_id
739+
740+ # Required. The region of the workload(s) whose events should be reverted. This
741+ # is used to filter workloads based on AssurantWorkloadData.region.
742+ # Corresponds to the JSON property `region`
743+ # @return [String]
744+ attr_accessor :region
745+
746+ def initialize ( **args )
747+ update! ( **args )
748+ end
749+
750+ # Update properties of this object
751+ def update! ( **args )
752+ @archive_end_time = args [ :archive_end_time ] if args . key? ( :archive_end_time )
753+ @archive_start_time = args [ :archive_start_time ] if args . key? ( :archive_start_time )
754+ @batch_size = args [ :batch_size ] if args . key? ( :batch_size )
755+ @max_events_move = args [ :max_events_move ] if args . key? ( :max_events_move )
756+ @organization_id = args [ :organization_id ] if args . key? ( :organization_id )
757+ @region = args [ :region ] if args . key? ( :region )
758+ end
759+ end
760+
761+ # Response for reverting archived resource events.
762+ class GoogleCloudAssuredworkloadsV1RevertArchivedResourceEventsResponse
763+ include Google ::Apis ::Core ::Hashable
764+
765+ # The total number of events successfully moved to the original table.
766+ # Corresponds to the JSON property `movedEventsCount`
767+ # @return [Fixnum]
768+ attr_accessor :moved_events_count
769+
770+ def initialize ( **args )
771+ update! ( **args )
772+ end
773+
774+ # Update properties of this object
775+ def update! ( **args )
776+ @moved_events_count = args [ :moved_events_count ] if args . key? ( :moved_events_count )
777+ end
778+ end
779+
639780 # The details of the update.
640781 class GoogleCloudAssuredworkloadsV1UpdateDetails
641782 include Google ::Apis ::Core ::Hashable
0 commit comments