core

package
v0.0.26 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 18, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Directories

Path Synopsis
integration
aws
storage
db

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL