goflow icon indicating copy to clipboard operation
goflow copied to clipboard

[Code Quality] Abstract Queue Worker

Open s8sg opened this issue 1 year ago • 0 comments

Queue Worker is mainly used to handle async operations. Queue working internally uses RMQ - which internally uses Redis

The goal is to abstract the queue-worker in a way so that all RMQ specific details gets abstracted into Queue Worker interface QueueWorker in theory should abstract

  1. Enqueue Workload Tasks (WorkloadRequest)
  2. Enqueue Flow Operations Tasks (NewRequest, PartialRequest, Stop, Pause, Resume)
  3. Consume handler func(task *Task) error for NewRequest, PartialRequest, Stop, Pause, Resume, WorkloadResponse

s8sg avatar Jun 25 '23 08:06 s8sg