jobscheduler

Documentation

Index

• Variables
• type JobMsbHandler
  • func (h JobMsbHandler) CallProcess(process string, param interface{}) (interface{}, error)
• type JobScheduler
  • func NewJobScheduler(config config.MsbConfig) *JobScheduler
  • func (this *JobScheduler) BuildJobs(jobs []api.SchedulingJob)
  • func (this *JobScheduler) ReloadJobs(jobs []api.SchedulingJob)
  • func (this *JobScheduler) Start() error

Variables

var LOGGER *logrus.Logger

Types

type JobMsbHandler

type JobMsbHandler struct {
}

func (JobMsbHandler) CallProcess

func (h JobMsbHandler) CallProcess(process string, param interface{}) (interface{}, error)

type JobScheduler

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

func NewJobScheduler

func NewJobScheduler(config config.MsbConfig) *JobScheduler

func (*JobScheduler) BuildJobs

func (this *JobScheduler) BuildJobs(jobs []api.SchedulingJob)

func (*JobScheduler) ReloadJobs

func (this *JobScheduler) ReloadJobs(jobs []api.SchedulingJob)

func (*JobScheduler) Start

func (this *JobScheduler) Start() error