core

Documentation

Index

• type Extension
• type MainProcessor
  • func NewMainProcessor(extensions []Extension) *MainProcessor
  • func (h *MainProcessor) Start() error
  • func (h *MainProcessor) Stop() error
• type Scheduler
  • func NewScheduler(extensions []Extension) *Scheduler
  • func (h *Scheduler) Start() error
  • func (h *Scheduler) Stop() error

Types

type Extension

type Extension interface {
	Name() string
	Start() error
	AddGenericProcessors(processingContext *processor.ProcessingContext, genericProcessors []*common.GenericProcessor, accountContext *model2.AccountContext, accountIndex int, organizationContext *model2.OrganizationContext, err error) (error, []*common.GenericProcessor)
	Stop() error
}

type MainProcessor

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

func NewMainProcessor

func NewMainProcessor(extensions []Extension) *MainProcessor

func (*MainProcessor) Start

func (h *MainProcessor) Start() error

func (*MainProcessor) Stop

func (h *MainProcessor) Stop() error

type Scheduler

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

func NewScheduler

func NewScheduler(extensions []Extension) *Scheduler

func (*Scheduler) Start

func (h *Scheduler) Start() error

func (*Scheduler) Stop

func (h *Scheduler) Stop() error