provider

type ExecutionProvider interface {
	Execute(interface{}, *Response) error
}

type Response struct {
	StatusCode int    `json:"status_code"`
	Response   []byte `json:"response"`
}

type SourceProvider interface {
	Read() error
	OnTaskUpdate(func(*Task) error)
	Stop() error
	TaskStarted(*Task) error
	TaskDone(*Task) error
	TaskError(*Task, error) error
}

type Task struct {
	Name              string         `json:"name"`
	Running           bool           `json:"is_running,omitempty"`
	Expression        string         `json:"schedule,omitempty"`
	LastRunAt         time.Time      `json:"last_run_at,omitempty"`
	AfterTask         string         `json:"after_task,omitempty"`
	Key               string         `json:"-"`
	SourceProvider    SourceProvider `json:"-"`
	Executor          string         `json:"executor"`
	ExecutionConfig   interface{}    `json:"execution_config"`
	LastError         string         `json:"last_error"`
	CurrentRetryCount int            `json:"current_retry_counter"`
	MaxRetries        int            `json:"max_retries"`
}