che

Documentation

Index

• Constants
• func NewEngine(ctx context.Context, options Options, mongoClient mongo.DbClient, ...) libengine.Engine
• func NewEventfilterIntervalsWorker(client mongo.DbClient, provider config.TimezoneConfigProvider, ...) engine.PeriodicalWorker
• func NewInfosDictionaryPeriodicalWorker(client mongo.DbClient, periodicalInterval time.Duration, logger zerolog.Logger) engine.PeriodicalWorker
• type DependencyMaker
• type Options
  • func ParseOptions() Options

Constants

const ResolveDeletedEventWaitTime = time.Hour

Functions

func NewEngine

func NewEngine(
	ctx context.Context,
	options Options,
	mongoClient mongo.DbClient,
	cfg config.CanopsisConf,
	metricsSender metrics.Sender,
	metricsEntityMetaUpdater metrics.MetaUpdater,
	externalDataContainer *eventfilter.ExternalDataContainer,
	timezoneConfigProvider *config.BaseTimezoneConfigProvider,
	templateConfigProvider *config.BaseTemplateConfigProvider,
	eventFilterEventCounter eventfilter.EventCounter,
	eventFilterFailureService eventfilter.FailureService,
	logger zerolog.Logger,
) libengine.Engine

func NewEventfilterIntervalsWorker

func NewEventfilterIntervalsWorker(
	client mongo.DbClient,
	provider config.TimezoneConfigProvider,
	periodicalInterval time.Duration,
	logger zerolog.Logger,
) engine.PeriodicalWorker

func NewInfosDictionaryPeriodicalWorker

func NewInfosDictionaryPeriodicalWorker(
	client mongo.DbClient,
	periodicalInterval time.Duration,
	logger zerolog.Logger,
) engine.PeriodicalWorker

Types

type DependencyMaker

type DependencyMaker struct {
	depmake.DependencyMaker
}

type Options

type Options struct {
	Version                 bool
	FeatureEventProcessing  bool
	FeatureContextCreation  bool
	Purge                   bool
	PrintEventOnError       bool
	ModeDebug               bool
	ConsumeFromQueue        string
	PublishToQueue          string
	PeriodicalWaitTime      time.Duration
	InfosDictionaryWaitTime time.Duration
	ExternalDataApiTimeout  time.Duration
	SoftDeleteWaitTime      time.Duration
	CleanPerfDataWaitTime   time.Duration
	FifoAckExchange         string
	Workers                 int
}

func ParseOptions

func ParseOptions() Options