jobs

type Job struct {
	Id           string        `json:"Id"`
	TaskName     string        `json:"TaskName"`
	Args         JobParameters `json:"Args"`
	State        string        `json:"State"`
	CreatedAt    time.Time     `json:"CreatedAt"`
	UpdatedAt    time.Time     `json:"UpdatedAt"`
	Result       string        `json:"Result"`
	MaxRetry     int64         `json:"MaxRetry"`
	CurrentRetry int64         `json:"CurrentRetry"`
	Errors       []string      `json:"Errors"`
	// attached to the job when picked up by the consumer
	ConsumerName string `json:"ConsumerName"`
}

type JobHandler interface {
	Handle(jobStore JobStore, j *Job, logger *logrus.Entry) error
}

type JobParameters map[string]interface{}

type JobStore interface {
	Get(ctx context.Context, jobId string) (*Job, error)
	MarkFinished(ctx context.Context, jobId string) error
	MarkFailed(ctx context.Context, jobId string, err error) error
	SaveResult(ctx context.Context, jobId string, result interface{}) error
	MarkRunning(ctx context.Context, jobId string) error
	// Touch only updates the UpdatedAt field of the job it doesn't affect any other fields
	Touch(ctx context.Context, jobId string) error
}

type Producer interface {
	Submit(ctx context.Context, taskName string, args JobParameters) (string, error)
	SubmitRaw(ctx context.Context, job *Job) error
	SubmitWithRetry(ctx context.Context, taskName string, args JobParameters, maxRetry int) (string, error)
}

type Progress struct {
	// contains filtered or unexported fields
}

type RunOption func(*progressOption)

type StreamConsumerConfiguration struct {
	Path         string `validate:"required" yaml:"Path"`
	ConsumerName string `validate:"required" yaml:"ConsumerName"`
	Concurrency  int    `validate:"required" yaml:"Concurrency"`
	// optional defaults to 5ecs
	NextRetry       time.Duration `yaml:"NextRetry"`
	RunningNoUpdate time.Duration `yaml:"RunningNoUpdate"`
	FromEnd         bool          `yaml:"FromEnd"`
	// how often to set the job.UpdateAt field to keep the job running
	HeartBeatInterval time.Duration `yaml:"HeartBeatInterval"`
	RetentionPeriod   time.Duration `yaml:"RetentionPeriod"`
}