executor

type DispatchQueue interface {
	// Next, returns next dispatched job
	// It won't block if dispatch queue is empty
	// Returns true if job is populated in given pointer
	Next(*jm.Job) bool
}

type Executor interface {

	// Run adds the job to the execution queue.
	// Internally it is added in a time.After function
	Run(job jm.Job) error

	// Update updates the job details after the job is queued.
	// If the job is not queued, it will return ErrJobNotFound
	Update(job jm.Job) error

	// Delete deletes the queued job.
	// If the job is not queued, it will return ErrJobNotFound
	Delete(jobID string) error

	DispatchQueue
}

type ExecutorOptions struct {
	RequestTimeout  time.Duration
	IdleConnTimeout time.Duration
	// Go-Routine pool size
	PoolSize int
}