Patent ID: 11876875
Assignee: ORACLE INTERNATIONAL CORPORATION
Field: Digital communication (Electrical engineering)
Classification: CPC H | IPC H

Claim 13:
14. An aggregation system, comprising:
memory storing computer-executable instructions; and
one or more processors configured to access the memory, and execute the computer-executable instructions to at least:
receive from a data catalog one or more events from one or more data sources of a cloud system, the data sources having one or more resource types;
store event data to a message queue;
separate the event data in the message queue into a set of processed events and a set of unprocessed events;
process, by one or more workers of the cloud system, subsets of the set of unprocessed events from the event data in the message queue, where the processing of the subset of the set of unprocessed events by the one or more workers is coordinated using a high watermark that indicates a point in the message queue separating the set of processed events from the set of unprocessed events;
for each event in each of the subset of the set of unprocessed events:
determining whether an event source has been updated based on information in the event;

in accordance with a determination that the event source has been updated, send an updated status to a dashboard, the dashboard configured to be displayed on a user device; and
moving, by at least one of the one or more workers of the cloud system, the high watermark in response to processing the subset of the set of unprocessed events.