Framework for time-associated data stream storage, processing, and replication

A system, comprising:

• at least one computing device;
• and
• at least one application executable in the at least one computing device, wherein when executed the at least one application causes the at least one computing device to at least:
• receive a plurality of streams of time-associated data from a plurality of sources via a network using a protocol, wherein each of the plurality of streams is divided into a plurality of fragments;
• send a plurality of acknowledgments to each of the plurality of sources for each of the plurality of fragments via the network using the protocol, wherein the plurality of acknowledgements comprises a first acknowledgment that data from a respective fragment has begun to be received, a second acknowledgement that the data from the respective fragment has been completely received, and a third acknowledgement that the respective fragment has been persisted in a data store;
• perform a processing of each of the plurality of fragments for individual ones of the plurality of streams;
• and
• implement an action relative to a respective fragment based at least in part on a result of the processing.

A method, comprising:

• generating, by a mobile computing device, a video stream;
• determining, by the mobile computing device, a condition of a network;
• generating, by the mobile computing device, a first fragment of the video stream based at least in part on a predefined time length;
• assigning, by the mobile computing device, a first unique fragment identifier and a first timestamp to the first fragment;
• determining, by the mobile computing device, that the condition of the network does not meet a predefined criterion;
• holding, by the mobile computing device, the first fragment in a buffer until the condition of the network meets the predefined criterion;
• sending, by the mobile computing device, the first fragment via the network using a protocol to an endpoint on a second computing device, the first fragment being identified as having the first unique fragment identifier and the first timestamp;
• and
• receiving, by the mobile computing device, a plurality of acknowledgements for the first fragment from the endpoint via the network using the protocol, wherein the plurality of acknowledgements comprises a first acknowledgment that data from the respective fragment has begun to be received, a second acknowledgement that the data from the respective fragment has been completely received, and a third acknowledgement that the respective fragment has been persisted in a data store.