Deferred scaling of an ordered event stream
Deferred scaling of an ordered event stream (OES) is disclosed. In contrast to conventional scaling of an OES, the disclosed deferred scaling can defer a scaling event where an impediment/condition to committing the scaling event is determined. This can comprise storing information corresponding to the scaling event as a virtual scaling event. The virtual scaling vent in some embodiments can be converted to an implemented scaling event at a later time. In a further embodiment, the virtual scaling event can be abandoned and the OES can continue to operate according to a last committed OES topology. In other embodiments, the virtual scaling event can be employed in determining a subsequent scaling event. Optionally, the subsequent scaling event can be an implemented scaling event or another deferred scaling event.
1. A system, comprising:
a processor; and
a memory that stores executable instructions that, when executed by the processor, facilitate performance of operations, comprising:
receiving an indication corresponding to a threshold amount of resource demand occurring in an existing portion of an ordered event stream of an ordered event stream storage system;
determining an alternate ordered event stream topology for the ordered event stream; and
deferring implementation of the alternate ordered event stream topology based on identifying an implementation condition; and
in response to receiving an indication that the implementation condition has been resolved, implementing the alternate ordered event stream topology for the ordered event stream.
2. The system of claim 1 , wherein the deferring of the implementation of the alternate ordered event stream topology comprises storing information correspond to the alternate ordered event stream topology.
3. The system of claim 2 , wherein the storing is via an event stored by the ordered event stream.
4. The system of claim 2 , wherein the storing is via an event stored by another ordered event stream.
5. The system of claim 1 , wherein the deferring of the implementation of the alternate ordered event stream topology comprises mapping ordered event stream operations between a virtual implementation of the alternate ordered event stream topology and a last committed ordered event stream topology.
6. The system of claim 1 , wherein the operations further comprise, in response to receiving an indication that the threshold amount of resource demand has reverted, discarding the alternate ordered event stream topology.
7. The system of claim 1 , wherein the operations further comprise, in response to receiving a subsequent indication corresponding to another threshold amount of resource demand occurring in the existing portion of the ordered event stream of the ordered event stream storage system after deferring the implementation of the alternate ordered event stream topology, determining a subsequent alternate ordered event stream topology based on the alternate ordered event stream topology.
8. The system of claim 7 , wherein the operations further comprise deferring implementation of the subsequent alternate ordered event stream topology based on identifying another implementation condition.
9. The system of claim 8 , wherein the subsequent alternate ordered event stream topology is based on the alternate ordered event stream topology, and wherein the alternate ordered event stream topology is based on an ordered event stream topology.
10. The system of claim 7 , wherein the operations further comprise scaling the ordered event stream from an ordered event stream topology prior to the alternate ordered event stream topology to the subsequent alternate ordered event stream topology in a manner that bypasses implementing the alternate ordered event stream topology.
11. The system of claim 10 , wherein the subsequent alternate ordered event stream topology is based on the alternate ordered event stream topology, and wherein the alternate ordered event stream topology is based on the ordered event stream topology.
12. A method, comprising:
determining, by a system comprising a processor, a change in a performance of an ordered event stream of an ordered event stream storage system;
determining, by the system, an alternate ordered event stream topology for the ordered event stream based on the change in performance of the ordered event stream;
in response to determining, by the system, an occurrence of an implementation condition corresponding to implementing the alternate ordered event stream topology, deferring implementation of the alternate ordered event stream topology; and
in response to receiving, by the system, an indication that the implementation condition has been cured, permitting the alternate ordered event stream topology to be committed to the ordered event stream.
13. The method of claim 12 , wherein the deferring implementation of the alternate ordered event stream topology comprises storing a representation of the alternate ordered event stream topology.
14. The method of claim 12 , wherein the deferring of the implementation of the alternate ordered event stream topology comprises mapping ordered event stream operations between a virtual representation of the alternate ordered event stream topology and a last committed ordered event stream topology.
15. The method of claim 12 , further comprising, in response to receiving, by the system, an indication that the change in the performance of the ordered event stream has reverted to past performance from before the change, discarding the alternate ordered event stream topology.
16. The method of claim 12 , wherein the operations further comprise, in response to receiving, by the system, an indication of a subsequent change in the performance of the ordered event stream occurring after the deferring of the implementation of the alternate ordered event stream topology, implementing a subsequent alternate ordered event stream topology based on the alternate ordered event stream topology.
17. A non-transitory machine-readable medium, comprising executable instructions that, when executed by a processor, facilitate performance of operations, comprising:
in response to determining a change in a performance of an ordered event stream of an ordered event stream storage system, determining an alternate ordered event stream topology based on the change in performance of the ordered event stream;
in response to determining an occurrence of an implementation condition corresponding to an impediment to implementing the alternate ordered event stream topology, deferring implementation of the alternate ordered event stream topology; and
in response to receiving an indication that the implementation condition has been resolved, facilitating committing of the alternate ordered event stream topology to the ordered event stream.
18. The non-transitory machine-readable medium of claim 17 , wherein the deferring of the implementation of the alternate ordered event stream topology comprises mapping ordered event stream operations between a virtual representation of the alternate ordered event stream topology and a last committed ordered event stream topology.
19. The non-transitory machine-readable medium of claim 17 , wherein the operations further comprise discarding the alternate ordered event stream topology in response to determining that the change in the performance of the ordered event stream has reverted.
20. The non-transitory machine-readable medium of claim 17 , wherein the operations further comprise implementing a subsequent alternate ordered event stream topology based on the alternate ordered event stream topology in response to determining a subsequent change in the performance of the ordered event stream occurring after the deferring of the implementation of the alternate ordered event stream topology.