mstar/linstrom
1
0
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Wiki Activity Actions

more comment work

Browse source
This commit is contained in:
Melody Becker 2024-09-13 16:58:22 +02:00
parent efc0b2e28e
commit 0ec0ad42bc
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
outgoingEventQueue/queue.go
View file

@ -10,9 +10,12 @@ Should preferably also be able to tell when a server is just gone and stop bothe
Implementation idea: New job gets send to queue (via function call). Queue then launches a new goroutine for that job Implementation idea: New job gets send to queue (via function call). Queue then launches a new goroutine for that job
Goroutine then launches multiple new goroutines, one per targeted inbox Goroutine then launches multiple new goroutines, one per targeted inbox, filtered by blocked targets
Each of those will wait for a ticker or a stop signal Each of those will wait for a ticker or a stop signal
On each ticker they'll try to deliver the payload to the target inbox On each ticker they'll try to deliver the payload to the target inbox
If a stop signal comes in, push the payload and goal into the db to pick up again later If a stop signal comes in, push the payload and goal into the db to pick up again later
On stop or sucessful delivery, exit the goroutine On stop or sucessful delivery, exit the goroutine
Stop can also be used to suspend outbound traffic to another instance to help reduce the load on them
TODO: Think of ways to make this more configurable for how data is being sent how fast
*/ */