SYSTEMS AND METHODS FOR EVENT STREAM MANAGEMENT
First Claim
1. A method comprising:
- receiving, by a processor, data of an event stream, each event in the event stream to be delivered electronically to a client device over a network;
storing a data structure indicative of one or more events in the event stream that are not yet delivered to the client device, wherein the event stream is assigned a unique conversation identifier, and wherein the data structure includes;
one or more entries corresponding to the one or more events in the event stream, wherein each of the one or more entries includes a communication number, a recipient identifier associated with a recipient, and a status; and
content of a most recent event of the one or more events in the event stream labeled with the communication number for the most recent event and a sender identifier associated with the most recent event;
retrieving, by the processor, from the data structure, data indicative of a current state of the event stream, wherein the current state of the event stream includes a number of events not yet delivered to the client device and the content of the most recent event in the event stream; and
sending, by the processor, the retrieved data indicative of the current state of the event stream to the client device.
2 Assignments
0 Petitions
Accused Products
Abstract
A system for managing event streams is provided that includes a volatile memory, a non-volatile memory, and a processor. The volatile memory is configured to store, for each of a plurality of event streams associated with the client device, metadata indicative of events not yet delivered to a client device and the content associated with only a most recent event of the event stream. The non-volatile memory is configured to store the content associated with each of undelivered events. The processor is configured to, upon receiving a request from the client device, retrieve from the volatile memory, without accessing the non-volatile memory, data indicative of a current state of an event stream associated with the client device. The processor is further configured to deliver the retrieved data indicative of the current state of the event stream.
-
Citations
20 Claims
-
1. A method comprising:
-
receiving, by a processor, data of an event stream, each event in the event stream to be delivered electronically to a client device over a network; storing a data structure indicative of one or more events in the event stream that are not yet delivered to the client device, wherein the event stream is assigned a unique conversation identifier, and wherein the data structure includes; one or more entries corresponding to the one or more events in the event stream, wherein each of the one or more entries includes a communication number, a recipient identifier associated with a recipient, and a status; and content of a most recent event of the one or more events in the event stream labeled with the communication number for the most recent event and a sender identifier associated with the most recent event; retrieving, by the processor, from the data structure, data indicative of a current state of the event stream, wherein the current state of the event stream includes a number of events not yet delivered to the client device and the content of the most recent event in the event stream; and sending, by the processor, the retrieved data indicative of the current state of the event stream to the client device. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 13, 14, 15)
-
-
11. A system comprising:
-
one or more processors; and a non-transitory computer-readable medium including instructions that when operated upon by the one or more processors cause the one or more processors to perform operations comprising; receiving data of an event stream, each event in the event stream to be delivered electronically to a client device over a network; storing a data structure indicative of one or more events in the event stream that are not yet delivered to the client device, wherein the event stream is assigned a unique conversation identifier, and wherein the data structure includes; one or more entries corresponding to the one or more events in the event stream, wherein each of the one or more entries includes a communication number, a recipient identifier associated with a recipient, and a status; and content of a most recent event of the one or more events in the event stream labeled with the communication number for the most recent event and a sender identifier associated with the most recent event; retrieving from the data structure, data indicative of a current state of the event stream, wherein the current state of the event stream includes a number of events not yet delivered to the client device and the content of the most recent event in the event stream; and sending the retrieved data indicative of the current state of the event stream to the client device.
-
-
16. A non-transitory computer-readable medium storing a computer program that is executable by at least one processor, the computer program including instructions that cause the at least one processor to perform operations comprising:
-
receiving data of an event stream, each event in the event stream to be delivered electronically to a client device over a network; storing a data structure indicative of one or more events in the event stream that are not yet delivered to the client device, wherein the event stream is assigned a unique conversation identifier, and wherein the data structure includes; one or more entries corresponding to the one or more events in the event stream, wherein each of the one or more entries includes a communication number, a recipient identifier associated with a recipient, and a status; and content of a most recent event of the one or more events in the event stream labeled with the communication number for the most recent event and a sender identifier associated with the most recent event; retrieving from the data structure, data indicative of a current state of the event stream, wherein the current state of the event stream includes a number of events not yet delivered to the client device and the content of the most recent event in the event stream; and sending the retrieved data indicative of the current state of the event stream to the client device. - View Dependent Claims (17, 18, 19, 20)
-
Specification