definition

type Consumer struct {
	Handler     func(ctx context.Context, payload []byte) error
	Concurrency int
	MaxRetry    int
	Timeout     time.Duration
}

type ProducerOption struct {
	Tx *query.Query
}

type WorkQueueProducer interface {
	// Produce ...
	Produce(ctx context.Context, topic enums.Daemon, payload any, option ProducerOption) error
}