Intelligent streaming framework
The present invention analyzes a user's or client application's requirements and searches for a solution based on the end-to-end latency requirements (requested or derived), data formats, control protocols, timing and synchronization, local streaming, and resource availability. The search for a solution is tracked to allow backtracking from the point of no solution. Once a solution is determined, the system translates the solution into requirements for the individual components of the graph.
1. A method for connecting a plurality of streaming nodes in a streaming graph in a network environment comprising the steps of:
determining a set of connection constraints for a connection between streaming nodes;
selecting at least one performance parameter to optimize for the streaming graph;
connecting the streaming nodes if the set of connection constraints is satisfied;
optimizing the at least one performance parameter; and
determining if each streaming node resides on a first bus;
for each streaming node that resides on a second bus:
determining if at least one first gateway exists to connect the first bus to the second bus; and
if at least one first gateway exists:
connecting the first bus and the second bus to the first gateway if the set of connection constraints is satisfied.
2. The method of claim 1 further comprising the steps of: if there is no first gateway: determining if there is a second gateway to connect the first bus to a common bus; determining if there is a third gateway to connect the second bus to the common bus; and if at least one common bus exists: connecting the second gateway to the first bus and the common bus and connecting the third gateway to the second bus and the common bus if the set of connection constraints is satisfied.
3. The method of claim 2 wherein at least one of the streaming nodes has a plurality of bus types, the method further comprising the step of: if one of the bus types and common bus is an IP bus: using the IP bus if the set of connection constraints is satisfied.
4. The method of claim 3 wherein the step of connecting the second gateway to the first bus and the common bus and connecting the third gateway to the second bus and the common bus if the set of connection constraints is satisfied further comprises the step of selecting the common bus corresponding to a latency that is closest to a target latency.
5. The method of claim 1 wherein the streaming nodes and connections between streaming nodes form a topology and wherein a record is kept of a change to the topology when a connection is made and when a connection is broken such that if the set of connection constraints is not satisfied, the topology prior to the change is recovered.