worker

Aug 14, 2020

Changes in this version

type WorkerSpec

+ ExitOnEmptyGracePeriod time.Duration

Jun 24, 2020

Changes in this version

+ var RegisterValidator = func(v *validator.Validate)

+ var Validator = func() *validator.Validate { ... }()

+ var WorkerPhaseFailed WorkerPhase = "Failed"

+ var WorkerPhaseRunning WorkerPhase = "Running"

+ var WorkerPhaseSucceeded WorkerPhase = "Succeeded"

+ var WorkerReasonFailure WorkerReason = "Failure"

+ var WorkerReasonLost WorkerReason = "Lost"

+ var WorkerReasonSalvaged WorkerReason = "Salvaged"

+ var WorkerReasonSuccess WorkerReason = "Success"

+ func IsWorkDirValid(fl validator.FieldLevel) bool

+ type HeartBeatSpec struct

+ ExpirationDuration time.Duration

+ Interval time.Duration

+ SalvageDuration time.Duration

+ type TaskHandlerSpec struct

+ Commands []string

+ DefaultCommandTimeout time.Duration

+ type Worker struct

+ QueueUID uuid.UUID

+ Spec WorkerSpec

+ Status WorkerStatus

+ UID uuid.UUID

+ func NewWorker(spec WorkerSpec, queueUID uuid.UUID) *Worker

+ func (w *Worker) AllowToSalvageOn(t time.Time) bool

+ func (w *Worker) IsLostOn(t time.Time) bool

+ func (w *Worker) SetFailed(t time.Time, reason WorkerReason) error

+ func (w *Worker) SetLastHeartBeatAt(t time.Time) error

+ func (w *Worker) SetSalvagedByAndOn(by uuid.UUID, on time.Time)

+ func (w *Worker) SetSucceeded(t time.Time) error

+ func (w *Worker) UpdateStatusIfLostOn(t time.Time)

+ type WorkerPhase string

+ type WorkerReason string

+ type WorkerSpec struct

+ Concurrency int

+ ExitOnEmpty bool

+ ExitOnSuspend bool

+ HeartBeat HeartBeatSpec

+ Name string

+ NumTasks int

+ TaskHandler TaskHandlerSpec

+ WorkDir string

+ func (spec WorkerSpec) Validate() error

+ type WorkerStatus struct

+ FinishedAt time.Time

+ LastHeartBeatAt time.Time

+ Phase WorkerPhase

+ Reason WorkerReason

+ SalvagedAt *time.Time

+ SalvagedBy *uuid.UUID

+ StartedAt time.Time