core

type QueuedMessage interface {
	Bytes() []byte
}

type Worker interface {
	// Run is called to start the worker
	Run(ctx context.Context, task QueuedMessage) error
	// Shutdown is called if stop all worker
	Shutdown() error
	// Queue to send message in Queue
	Queue(task QueuedMessage) error
	// Request to get message from Queue
	Request() (QueuedMessage, error)
}