jobs

Documentation

Index

• type Jobs
  • func New(hub websocket.Hub, svcs lifecycle.ServiceLifecycle, queue *queue.Queue, ...) Jobs

Types

type Jobs

type Jobs interface {
	Info() []task.Info

	Get(id uuid.UUID) (taskInfo task.Info, err error)

	Start(ctx context.Context, id uuid.UUID) (err error)
	Stop(ctx context.Context, id uuid.UUID) (err error)

	Enable(id uuid.UUID) (err error)
	Disable(id uuid.UUID) (err error)

	StartAll(ctx context.Context) (err error)

	Close()
}

func New

func New(
	hub websocket.Hub,
	svcs lifecycle.ServiceLifecycle,
	queue *queue.Queue,
	fs *fs.FileSystem,
	feed feed.Feed,
	cfg configmodels.Jobs,
) Jobs