workq

type Handler interface {
	PerformJob(jobType string, data []byte) error
}

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

type Job struct {
	Id      []byte `gorm:"primary_key"`
	Queue   string
	Status  string
	JobType string
	Payload []byte

	CoolOffUntil *time.Time
	Attempts     int

	CreatedAt time.Time
}

type PeriodicJob struct {
	Id      int `gorm:"primary_key"`
	Name    string
	Queue   string
	JobType string
	Payload []byte
	Period  string
	NextRun time.Time

	CreatedAt time.Time
}

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

type RunConfig struct {
	ConnInfo     string
	PopInterval  time.Duration
	Concurrency  int
	CleanupCheck time.Duration
	Handler      func(ctx context.Context, j *Job) error
}

type RunningJob struct {
	Job
	L hclog.Logger
	// contains filtered or unexported fields
}

type Worker struct {
	L hclog.Logger

	Validate func(job *Job) (bool, error)

	Stats struct {
		ListenWakeups int64
	}
	// contains filtered or unexported fields
}