Error notification mechanism for streaming events
A method for failure event notification in an event recordation and distribution system. The method including monitoring each stage of processing of an event by an event publisher manager, detecting a failure of the event to publish in the event recordation and distribution system, and publishing an error event notification to a status stream in response to detecting the failure.
1. A method of failure event notification in an event recordation and distribution system, the method comprising:
monitoring each stage of processing of an event by an event publisher manager;
detecting a failure of the event to publish in the event recordation and distribution system; and
publishing an error event notification to a status stream in response to detecting the failure, wherein the status stream may be subscribed to by one or more event producers,
wherein an event producer is notified of the failure if the event producer is subscribed to the status stream, and not notified of the failure if the event producer is not subscribed to the status stream.
2. The method of claim 1 , further comprising:
detecting initiation of processing of the event by the event publisher manager.
3. The method of claim 1 , wherein the error event notification includes a unique identifier for the event.
4. The method of claim 1 , further comprising:
generating a unique identifier for the event by an event producer manager.
5. The method of claim 4 , further comprising:
storing the event with the unique identifier into a buffer to be processed by the event publisher manager.
6. The method of claim 4 , further comprising:
sending a reply to an event producer with the unique identifier in response to receiving the event.
7. The method of claim 1 , wherein the error event notification includes a payload of the event.
8. A non-transitory machine-readable storage medium that provides instructions that, if executed by a processor, will cause said processor to perform operations of a method of failure event notification in an event recordation and distribution system, the operations comprising:
monitoring each stage of processing of an event by an event publisher manager;
detecting a failure of the event to publish in the event recordation and distribution system; and
publishing an error event notification to a status stream in response to detecting the failure, wherein the status stream may be subscribed to by one or more event producers,
wherein an event producer is notified of the failure if the event producer is subscribed to the status stream, and not notified of the failure if the event producer is not subscribed to the status stream.
9. The non-transitory machine-readable medium of claim 8 , wherein the operations further comprise:
detecting initiation of processing of the event by the event publisher manager.
10. The non-transitory machine-readable medium of claim 8 , wherein the error event notification includes a unique identifier for the event.
11. The non-transitory machine-readable medium of claim 8 , wherein the operations further comprise:
generating a unique identifier for the event by an event producer manager.
12. The non-transitory machine-readable medium of claim 11 , wherein the operations further comprise:
storing the event with the unique identifier into a buffer to be processed by the event publisher manager.
13. The non-transitory machine-readable medium of claim 11 , wherein the operations further comprise:
sending a reply to an event producer with the unique identifier in response to receiving the event.
14. The non-transitory machine-readable medium of claim 8 , wherein the error event notification includes a payload of the event.
15. A computing device to implement a method of failure event notification in an event recordation and distribution system, the computing device comprising:
a non-transitory computer-readable medium having stored therein a publication observer; and
a processor coupled to the non-transitory computer-readable medium, the processor to execute the publication observer, the publication observer to monitor each stage of processing of an event by an event publisher manager, to detect a failure of the event to publish in the event recordation and distribution system, and to publish an error event notification to a status stream in response to detecting the failure, wherein the status stream may be subscribed to by one or more event producers, wherein an event producer is notified of the failure if the event producer is subscribed to the status stream, and not notified of the failure if the event producer is not subscribed to the status stream.
16. The computing device of claim 15 , wherein the publication observer is further to detect initiation of processing of the event by the event publisher manager.
17. The computing device of claim 15 , wherein the error event notification includes a unique identifier for the event.
18. The computing device of claim 15 , wherein the non-transitory computer-readable medium is further to store an event producer manager, the processor to execute the event producer manager, the event producer manager to generate a unique identifier for the event.
19. The computing device of claim 18 , wherein the event producer manager is further to store the event with the unique identifier into a buffer to be processed by the event publisher manager.
20. The computing device of claim 18 , wherein the event producer manager is further to send a reply to an event producer with the unique identifier in response to receiving the event.
21. The computing device of claim 15 , wherein the error event notification includes a payload of the event.