Coalescing publication events based on subscriber tolerances
Systems and methods for coalescing and/or aligning publications in a publication/subscription architecture to reduce the number of publication events and to improve the performance of microservices in a communications network are provided. A method, according to one implementation, includes the step of obtaining client-based tolerance input with respect to a plurality of subscriptions requested by a plurality of clients in a publication/subscription system. Based on the client-based tolerance input, the method also includes the step of adjusting the timing of publications to reduce the phase variability of the plurality of subscriptions.
1 . A system comprising:
a processing device, and
a memory device configured to store a computer program having instructions that, when executed, enable the processing device to
for a plurality of subscriptions, obtain client-based tolerance input and group information, wherein the plurality of subscriptions are from a plurality of microservices operating in a network or a network element, wherein the group information includes one or more of path information and Network Element (NE) information in a communications network for grouping corresponding subscriptions of the plurality of subscriptions, and wherein the client-based tolerance input includes (1) timing information for grouping corresponding subscriptions, (2) a phase alignment tolerance whereby a given subscription can be delayed by an amount to align with similar subscriptions, and (3) a jitter tolerance whereby the given subscription that has its own publicatoin cycle can be grouped with another subscription either before or after the own publication cycle, and
based on the client-based tolerance input and the group information, adjust timing of publications to reduce phase variability of the plurality of subscriptions.
2 . The system of claim 1 , wherein the timing of the publications is adjusted by reducing a number of publication submissions without reducing data provided by the publication submissions.
3 . The system of claim 1 , wherein the timing of the publications is adjusted by aligning publications that are offset but have the same frequency.
4 . The system of claim 1 , wherein the timing of the publications is adjusted by utilizing a wall clock as a reference.
5 . The system of claim 1 , wherein the instructions further enable the processing device to offer configuration options to a plurality of clients for obtaining the client-based tolerance input.
6 . The system of claim 1 , wherein the subscriptions include Performance Monitoring (PM) data received by one or more binning applications associated with one or more of a plurality of clients.
7 . A non-transitory computer-readable medium configured to store computer logic having instructions that, when executed, cause one or more processing devices to:
for a plurality of subscriptions, obtain client-based tolerance input and group information, wherein the plurality of subscriptions are from a plurality of microservices operating in a network or a network element, wherein the group information includes one or more of path information and Network Element (NE) information in a communications network for grouping corresponding subscriptions of the plurality of subscriptions, and wherein the client-based tolerance input includes (1) timing information for grouping corresponding subscriptions, (2) a phase alignment tolerance whereby a given subscription can be delayed by an amount to align with similar subscriptions, and (3) a litter tolerance whereby the given subscription that has its own publication cycle can be grouped with another subscription either before or after the own publication cycle, and
based on the client-based tolerance input and the group information, adjust timing of publications to reduce phase variability of the plurality of subscriptions.
8 . The non-transitory computer-readable medium of claim 7 , wherein the timing of the publications is adjusted by one or more steps of:
reducing the number of publication submissions without reducing data provided by the publication submissions.
9 . The non-transitory computer-readable medium of claim 7 , wherein the timing of the publications is adjusted by one or more steps of:
aligning publications that are offset but have the same frequency.
10 . A method comprising the steps of:
for a plurality of subscriptions, obtaining client-based tolerance input and group information, wherein the plurality of subscriptions are from a plurality of microservices operating in a network or a network element, wherein the group information includes one or more of path information and Network Element (NE) information in a communications network for grouping corresponding subscriptions, and wherein the client-based tolerance input includes (1) timing information for grouping corresponding subscriptions of the plurality of subscriptions, (2) a phase alignment tolerance whereby a given subscription can be delayed by an amount to align with similar subscriptions, and (3) a litter tolerance whereby the given subscription that has its own publication cycle can be grouped with another subscription either before or after the own publication cycle; and
based on the client-based tolerance input and the group information, adjusting timing of publications to reduce phase variability of the plurality of subscriptions.
11 . The method of claim 10 , wherein adjusting the timing of the publications includes reducing the number of publication submissions without reducing data provided by the publication submissions.
12 . The method of claim 10 , wherein adjusting the timing of the publications includes aligning publications that are offset but have the same frequency.
13 . The method of claim 10 , wherein adjusting the timing of the publications includes utilizing a wall clock as a reference.
14 . The method of claim 10 , further comprising offering configuration options to the plurality of clients for obtaining the client-based tolerance input.