dispatchservice

Documentation

Index

• func New(dbInstance libdb.DBManager, config *serverops.Config) *service
• type JobInfo
• type Service
  • func NewService(dbInstance libdb.DBManager) Service

Functions

func New

func New(dbInstance libdb.DBManager, config *serverops.Config) *service

Types

type JobInfo

type JobInfo struct {
	ID           string    `json:"id"`
	TaskType     string    `json:"taskType"`
	ScheduledFor time.Time `json:"scheduledFor"`
	ValidUntil   time.Time `json:"validUntil"`
	CreatedAt    time.Time `json:"createdAt"`
}

type Service

type Service interface {
	PendingJobs(ctx context.Context, createdAtCursor *time.Time) ([]*store.Job, error)
	InProgressJobs(ctx context.Context, createdAtCursor *time.Time) ([]*store.LeasedJob, error)

	AssignPendingJob(ctx context.Context, leaserID string, leaseDuration *time.Duration, jobTypes ...string) (*store.LeasedJob, error)
	MarkJobAsDone(ctx context.Context, jobID string, leaserID string) error
	MarkJobAsFailed(ctx context.Context, jobID string, leaserID string) error

	serverops.ServiceMeta
}

func NewService

func NewService(dbInstance libdb.DBManager) Service