Abstract
A method for processing one or more user events is described. The method comprises creating a data ingestor instance to process the one or more user events. A user event data associated with a tenant is retrieved, wherein the user event data is retrieved by polling a message store. Further, processing demand for the retrieved user event data is determined. Furthermore, a number of the data ingestor instance required to accommodate the processing demand is predicted. One or more clone ingestor instances are created dynamically based on the predicted number of data ingestor instance. Finally, allocate one or more clone ingestor instances for processing the one or more user events.
Full Text
What is claimed is:
A method for processing one or more user events is described. The method comprises creating a data ingestor instance to process the one or more user events. A user event data associated with a tenant is retrieved, wherein the user event data is retrieved by polling a message store. Further, processing demand for the retrieved user event data is determined. Furthermore, a number of the data ingestor instance required to accommodate the processing demand is predicted. One or more clone ingestor instances are created dynamically based on the predicted number of data ingestor instance. Finally, allocate one or more clone ingestor instances for processing the one or more user events.
Timeline
Filed
02/18/2026Published
06/25/2026Granted
Not AvailableIPC Codes(1)
G06F 9/54:Interprogram communication