Observable feature configuration delivery
A system and a method for observable configuration delivery include, for each target tenants of a plurality of target tenants, determining a corresponding last unicast configuration change request (CCR) received; determining a number of previously unbooked unicast CCRs for the plurality of target tenants, a previously unbooked unicast CCR being a last unicast CCR received that has not been booked into a distribution to be submitted to a headend service (HES); booking the previously unbooked unicast CCRs into one or more distributions based on the number of the previously unbooked unicast CCRs and a configured capacity of each distribution of the one or more distributions; and sending the one or more distributions to the HES for sending the booked previously unbooked unicast CCRs to the plurality of target tenants.
1 . A method comprising:
determining, for each target tenant of a plurality of target tenants, a corresponding last unicast configuration change request (CCR) received;
determining a number of previously unbooked unicast CCRs for the plurality of target tenants, a previously unbooked unicast CCR being a last unicast CCR received that has not been booked into a first distribution to be submitted to a headend service (HES);
booking the previously unbooked unicast CCRs into one or more distributions based on the number of the previously unbooked unicast CCRs and a configured capacity of each distribution of the one or more distributions;
sending the one or more distributions to the HES for sending the booked previously unbooked unicast CCRs to the plurality of target tenants; and
identifying a current distribution, the current distribution being a second distribution submitted to the HES and unconfirmed for completion, the current distribution unconfirmed for completion including at least one of:
failing to receive asynchronous status messages associated with the current distribution from the HES, or
failing to meet a predetermined policy condition associated with the current distribution.
2 . The method of claim 1 , wherein determining, for each target tenant of the plurality of target tenants, the corresponding last unicast CCR received includes:
determining an operation identification (ID) of the corresponding last unicast CCR; and
setting a boundary, based on the operation ID, for refraining from booking a CCR arriving after the boundary into the first distribution.
3 . The method of claim 1 , further comprising:
creating an under-full distribution associated with the one or more distributions, the under-full distribution being a third distribution having a number of booked previously unbooked CCRs that is less than the configured capacity; and
sending the under-full distribution to the HES responsive to at least one of:
configuration send channels of the plurality of target tenants include no in-flight distributions, or
the under-full distribution is known to be a last remaining portion of the one or more distributions.
4 . The method of claim 1 , further comprising:
identifying a next distribution based, at least in part, on:
priority of candidate operations associated with a next set of CCRs,
priority of candidate distributions booked with the next set of CCRs, and
a wait time of booked unicast CCRs for a unicast batch distribution.
5 . The method of claim 4 , wherein identifying the next distribution includes:
identifying the next distribution yet to have CCRs assigned, and
proposing a new configured capacity for the next distribution.
6 . The method of claim 4 , wherein identifying the next distribution includes:
determining that the next distribution invalidates an existing distribution, the existing distribution having existing CCRs booked and yet to be submitted to the HES,
clearing the existing CCRs, and
re-proposing the existing distribution.
7 . The method of claim 4 , further comprising:
in response to identifying the next distribution and failing to identify the current distribution, submitting the next distribution to the HES.
8 . A system comprising:
one or more processors; and
memory coupled to the one or more processors, the memory storing thereon computer-executable instructions that, when executed by the one or more processors, cause the one or more processors to perform operations, the operations comprising:
determining, for each target tenant of a plurality of target tenants, a corresponding last unicast configuration change request (CCR) received;
determining a number of previously unbooked unicast CCRs for the plurality of target tenants, a previously unbooked unicast CCR being a last unicast CCR received that has not been booked into a first distribution to be submitted to a headend service (HES);
booking the previously unbooked unicast CCRs into one or more distributions based on the number of the previously unbooked unicast CCRs and a configured capacity of each distribution of the one or more distributions;
sending the one or more distributions to the HES for sending the booked previously unbooked unicast CCRs to the plurality of target tenants; and
identifying a current distribution, the current distribution being a second distribution submitted to the HES and unconfirmed for completion,
wherein the current distribution unconfirmed for completion includes at least one of:
failing to receive asynchronous status messages associated with the current distribution from the HES, or
failing to meet a predetermined policy condition associated with the current distribution.
9 . The system of claim 8 , wherein determining, for each target tenant of the plurality of target tenants, the corresponding last unicast CCR received includes:
determining an operation identification (ID) of the corresponding last unicast CCR; and
setting a boundary, based on the operation ID, for refraining from booking a CCR arriving after the boundary into the first distribution.
10 . The system of claim 8 , wherein the operations further comprise:
creating an under-full distribution associated with the one or more distributions, the under-full distribution being a third distribution having a number of booked previously unbooked CCRs that is less than the configured capacity; and
sending the under-full distribution to the HES responsive to at least one of:
configuration send channels of the plurality of target tenants include no in-flight distributions, or
the under-full distribution is known to be a last remaining portion of the one or more distributions.
11 . The system of claim 8 , wherein the operations further comprise:
identifying a next distribution based, at least in part, on:
priority of candidate operations associated with a next set of CCRs,
priority of candidate distributions booked with the next set of CCRs, and
a wait time of booked unicast CCRs for a unicast batch distribution.
12 . The system of claim 11 , wherein identifying the next distribution includes:
identifying the next distribution yet to have CCRs assigned, and
proposing a new configured capacity for the next distribution.
13 . The system of claim 11 , wherein identifying the next distribution includes:
determining that the next distribution invalidates an existing distribution, the existing distribution having existing CCRs booked and yet to be submitted to the HES,
clearing the existing CCRs, and
re-proposing the existing distribution.
14 . The system of claim 11 , wherein the operations further comprise:
in response to identifying the next distribution and failing to identify the current distribution, submitting the next distribution to the HES.
15 . A non-transitory computer-readable storage medium storing thereon computer executable instructions that, when executed by one or more processors, cause the one or more processors to perform operations, the operations comprising:
determining, for each target tenant of a plurality of target tenants, a corresponding last unicast configuration change request (CCR) received;
determining a number of previously unbooked unicast CCRs for the plurality of target tenants, a previously unbooked unicast CCR being a last unicast CCR received that has not been booked into a first distribution to be submitted to a headend service (HES);
booking the previously unbooked unicast CCRs into one or more distributions based on the number of the previously unbooked unicast CCRs and a configured capacity of each distribution of the one or more distributions; sending the one or more distributions to the HES for sending the booked previously unbooked unicast CCRs to the plurality of target tenants; and
identifying a current distribution, the current distribution being a second distribution submitted to the HES and unconfirmed for completion,
wherein the current distribution unconfirmed for completion includes at least one of:
failing to receive asynchronous status messages associated with the current distribution from the HES, or
failing to meet a predetermined policy condition associated with the current distribution.
16 . The non-transitory computer-readable storage medium of claim 15 , wherein determining, for each target tenant of the plurality of target tenants, the corresponding last unicast CCR received includes:
determining an operation identification (ID) of the corresponding last unicast CCR; and
setting a boundary, based on the operation ID, for refraining from booking a CCR arriving after the boundary into the first distribution.
17 . The non-transitory computer-readable storage medium of claim 15 , wherein the operations further comprise:
creating an under-full distribution associated with the one or more distributions, the under-full distribution being a third distribution having a number of booked previously unbooked CCRs that is less than the configured capacity; and
sending the under-full distribution to the HES responsive to at least one of:
configuration send channels of the plurality of target tenants include no in-flight distributions, or
the under-full distribution is known to be a last remaining portion of the one or more distributions.
18 . The non-transitory computer-readable storage medium of claim 15 , wherein the operations further comprise:
identifying a next distribution based, at least in part, on:
priority of candidate operations associated with a next set of CCRs,
priority of candidate distributions booked with the next set of CCRs, and
a wait time of booked unicast CCRs for a unicast batch distribution.
19 . The non-transitory computer-readable storage medium of claim 18 , wherein identifying the next distribution includes:
determining that the next distribution invalidates an existing distribution, the existing distribution having existing CCRs booked and yet to be submitted to the HES,
clearing the existing CCRs, and
re-proposing the existing distribution.
20 . The non-transitory computer-readable storage medium of claim 15 , wherein the operations further comprise:
in response to identifying a next distribution and failing to identify the current distribution, submitting the next distribution to the HES.