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

Claim 0:
1. A computer-implemented method, comprising:
receiving, by an aggregation system of a cloud system and from a data catalog, one or more events from one or more data sources of the cloud system, the one or more data sources having one or more resource types;
storing, by the aggregation system, event data to a message queue;
separating, by the aggregation system, the event data in the message queue into a set of processed events and a set of unprocessed events;
processing, 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 subsets 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 subsets 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, sending 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.