diff --git a/outgoingEventQueue/queue.go b/outgoingEventQueue/queue.go index 14c2291..51974c1 100644 --- a/outgoingEventQueue/queue.go +++ b/outgoingEventQueue/queue.go @@ -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 -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 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 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 */