job_manager

Documentation

Index

• type CreateJobFunc
• type Factory
  • func NewJobFactory() *Factory
  • func (f *Factory) CreateJob(name string, conf IsConfig, logger *logrus.Entry, resultChan chan Result) (Job, error)
  • func (f *Factory) Register(name string, createJobFunc CreateJobFunc)
• type IsConfig
• type Job
• type Manager
  • func New(jobNames []string, config IsConfig, logger *logrus.Entry, factory *Factory) *Manager
  • func (m *Manager) Run(ctx context.Context, sourceType utils.SourceType, userInput string) (map[string]Result, error)
• type Result

Types

type CreateJobFunc

type CreateJobFunc func(name string, conf IsConfig, logger *logrus.Entry, resultChan chan Result) Job

type Factory

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

func NewJobFactory

func NewJobFactory() *Factory

func (*Factory) CreateJob

func (f *Factory) CreateJob(name string, conf IsConfig, logger *logrus.Entry, resultChan chan Result) (Job, error)

func (*Factory) Register

func (f *Factory) Register(name string, createJobFunc CreateJobFunc)

type IsConfig

type IsConfig interface {
	IsConfig()
}

type Job

type Job interface {
	Run(ctx context.Context, sourceType utils.SourceType, source string) error
}

type Manager

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

func New

func New(jobNames []string, config IsConfig, logger *logrus.Entry, factory *Factory) *Manager

func (*Manager) Run

func (m *Manager) Run(ctx context.Context, sourceType utils.SourceType, userInput string) (map[string]Result, error)

type Result

type Result interface {
	GetError() error
}