run

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Cleanup()
  • func (m *Manager) Run(ctx context.Context)
  • func (m *Manager) Start(job jobpkg.Job)
  • func (m *Manager) Stop(fullName string)

Types

type Manager

type Manager struct {
	*logger.Logger
	// contains filtered or unexported fields
}

func NewManager

func NewManager() *Manager

func (*Manager) Cleanup

func (m *Manager) Cleanup()

Cleanup stops all jobs in the queue.

func (*Manager) Run

func (m *Manager) Run(ctx context.Context)

func (*Manager) Start

func (m *Manager) Start(job jobpkg.Job)

Starts starts a job and adds it to the job queue.

func (*Manager) Stop

func (m *Manager) Stop(fullName string)

Stop stops a job and removes it from the job queue.