You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Main changes: focus on individual streams and embrace a distributed structure.
Formatters and processors will maintain their distinction: formatters are stateless and can be replicated indiscriminately whereas processors are assumed to be stateful and cannot just be replicated.
Formatters will conceptually stay the same. But they will also have to provide what the source of packets is (rabbitmq, some other queue or something) and where that is located. This way some other computer can handle reception and put the packets in a queue and the formatter can then pull from that. The queue could also be in the local server/cloud.
The output of formatters will go into two queues: 1) headed to the DB and 2) headed to any processors. Not sure exactly how to implement the second queue. Would love for the queue to maintain packets (at least for a while) in case the processor goes down.
Each formatter will have its own queues to take from and put into. This will separate streams.
Each profile will have its own archive DB and short-term streaming DB.
Processors will operate on the queue from its formatter or another processor.
Streamers will still work as DB queries.
Processors will push into the same DB queue as the formatter for that profile does.
Receivers will change too. Receivers will be responsible for separating streams and putting the data they receive into profile-specific queues.
Receivers will note the destination IP address of the incoming packet. There will be generic addresses where the 10 byte (or whatever) id will be used and there will be profile specific addresses that wont have the 10 byte id.
Getting streaming data from multiple profiles will probably need its own block.
The text was updated successfully, but these errors were encountered:
Main changes: focus on individual streams and embrace a distributed structure.
The text was updated successfully, but these errors were encountered: