jobs

type ExecutorFunc func(ctx context.Context, j *Job) error

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

type JSONResponse struct {
	ID            uuid.UUID `json:"jobId"`
	Type          string    `json:"type"`
	State         State     `json:"state"`
	Error         string    `json:"error"`
	Errors        []string  `json:"errors"`
	Result        string    `json:"result"`
	TransactionID string    `json:"transactionId"`
	CreatedAt     time.Time `json:"createdAt"`
	UpdatedAt     time.Time `json:"updatedAt"`
}

type Job struct {
	ID                     uuid.UUID      `gorm:"column:id;primary_key;type:uuid;"`
	Type                   string         `gorm:"column:type"`
	State                  State          `gorm:"column:state;default:INIT;index:idx_jobs_state_updated_at"`
	Error                  string         `gorm:"column:error"`
	Errors                 pq.StringArray `gorm:"column:errors;type:text[]"`
	Result                 string         `gorm:"column:result"`
	TransactionID          string         `gorm:"column:transaction_id"`
	ExecCount              int            `gorm:"column:exec_count;default:0"`
	CreatedAt              time.Time      `gorm:"column:created_at"`
	UpdatedAt              time.Time      `gorm:"column:updated_at;index:idx_jobs_state_updated_at"`
	DeletedAt              gorm.DeletedAt `gorm:"column:deleted_at;index"`
	ShouldSendNotification bool           `gorm:"-"` // Whether or not to notify admin (via webhook for example)
	Attributes             datatypes.JSON `gorm:"attributes"`
}

type JobOption func(*Job)

type JobQueueStatus struct {
	JobsInit        int `json:"jobsInit"`
	JobsNotAccepted int `json:"jobsNotAccepted"`
	JobsAccepted    int `json:"jobsAccepted"`
	JobsErrored     int `json:"jobsErrored"`
	JobsFailed      int `json:"jobsFailed"`
	JobsCompleted   int `json:"jobsCompleted"`
}

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

type Result struct {
	Result        string
	TransactionID string
}

type Service interface {
	List(limit, offset int) (*[]Job, error)
	Details(jobID string) (*Job, error)
}

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

type State string

type StatusQuery struct {
	State State
	Count int
}

type Store interface {
	Jobs(datastore.ListOptions) ([]Job, error)
	Job(id uuid.UUID) (Job, error)
	InsertJob(*Job) error
	UpdateJob(*Job) error
	AcceptJob(j *Job, acceptedGracePeriod time.Duration) error
	SchedulableJobs(acceptedGracePeriod, reSchedulableGracePeriod time.Duration, o datastore.ListOptions) ([]Job, error)
	Status() ([]StatusQuery, error)
}

type WorkerPool interface {
	RegisterExecutor(jobType string, executorF ExecutorFunc)
	CreateJob(jobType, txID string, opts ...JobOption) (*Job, error)
	Schedule(j *Job) error
	Status() (WorkerPoolStatus, error)
	Start()
	Stop(wait bool)
	Capacity() uint
	QueueSize() uint
}

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

type WorkerPoolOption func(*WorkerPoolImpl)

type WorkerPoolStatus struct {
	JobQueueStatus
	Capacity    int `json:"poolCapacity"`
	WorkerCount int `json:"workerCount"`
}