Data forwarder prioritizing live data
First Claim
1. A computer-implemented method comprising:
- generating, at a data forwarder, a backup of live data received by the data forwarder while the live data is provided to a real-time data pipeline for forwarding from the data forwarder;
recovering a first portion of the live data from the backup to a stale data pipeline of the data forwarder;
receiving, by the data forwarder, a request to forward the live data to a destination node; and
forwarding data to the destination node in response to the request, wherein the first portion of the live data from the stale data pipeline is added to a second portion of the live data from the real-time data pipeline in the response based on determining headroom remains to reach an amount of the data identified to include in the response.
2 Assignments
0 Petitions
Accused Products
Abstract
In accordance with implementations of the present disclosure, a backup of live data received by a data forwarder is generated at the data forwarder while the live data is provided to a real-time data pipeline for forwarding from the data forwarder. A a first portion of the live data is recovered from the backup to a stale data pipeline of the data forwarder. A request to forward the live data to a destination node is received by the data forwarder. In response to the request data is forwarded to the destination node, where the first portion of the live data from the stale data pipeline is added to a second portion of the live data from the real-time data pipeline in the response based on determining headroom remains to reach an amount of the data identified to include in the response.
99 Citations
30 Claims
-
1. A computer-implemented method comprising:
-
generating, at a data forwarder, a backup of live data received by the data forwarder while the live data is provided to a real-time data pipeline for forwarding from the data forwarder; recovering a first portion of the live data from the backup to a stale data pipeline of the data forwarder; receiving, by the data forwarder, a request to forward the live data to a destination node; and forwarding data to the destination node in response to the request, wherein the first portion of the live data from the stale data pipeline is added to a second portion of the live data from the real-time data pipeline in the response based on determining headroom remains to reach an amount of the data identified to include in the response. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20)
-
-
21. A system for forwarding data, the system comprising:
-
one or more data processors; and one or more computer-readable storage media containing instructions which when executed on the one or more data processors, cause the one or more processors to perform operations including; generating, at a data forwarder, a backup of live data received by the data forwarder while the live data is provided to a real-time data pipeline for forwarding from the data forwarder; recovering a first portion of the live data from the backup to a stale data pipeline of the data forwarder; receiving, by the data forwarder, a request to forward the live data to a destination node; and forwarding data to the destination node in response to the request, wherein the first portion of the live data from the stale data pipeline is added to a second portion of the live data from the real-time data pipeline in the response based on determining headroom remains to reach an amount of the data identified to include in the response. - View Dependent Claims (22, 23, 24, 25, 26)
-
-
27. One or more non-transitory computer-storage media storing computer-useable instructions that, when executed by a computing device, perform a method for forwarding data, the method comprising:
-
generating, at a data forwarder, a backup of live data received by the data forwarder while the live data is provided to a real-time data pipeline for forwarding from the data forwarder; recovering a first portion of the live data from the backup to a stale data pipeline of the data forwarder; receiving, by the data forwarder, a request to forward the live data to a destination node; and forwarding data to the destination node in response to the request, wherein the first portion of the live data from the stale data pipeline is added to a second portion of the live data from the real-time data pipeline in the response based on determining headroom remains to reach an amount of the data identified to include in the response. - View Dependent Claims (28, 29, 30)
-
Specification