worksrv

Documentation

Index

• Constants
• func New(storage port.Storage, taskrepo *taskrepo.TaskRepository, time rtime.Time, ...) *workservice

Constants

const (
	WorkTypeTask                    = "task"
	WorkTypePipeline                = "pipeline"
	DefaultJobTimeout time.Duration = 84600 * time.Second
)

Functions

func New

func New(
	storage port.Storage,
	taskrepo *taskrepo.TaskRepository,
	time rtime.Time, timeoutUnit time.Duration,
	workers, queue_capacity int, logger *logrus.Logger) *workservice

New creates a new work service.