action

Documentation

Index

• func NewEngineAction(ctx context.Context, options Options, cfg config.CanopsisConf, ...) engine.Engine
• type DependencyMaker
• type Options
  • func ParseOptions() Options

Functions

func NewEngineAction

func NewEngineAction(
	ctx context.Context,
	options Options,
	cfg config.CanopsisConf,
	mongoClient mongo.DbClient,
	amqpConnection amqp.Connection,
	webhookRpcClient engine.RPCClient,
	rpcPublishQueues []string,
	logger zerolog.Logger,
) engine.Engine

NewEngineAction returns the default Action engine with default connections.

Types

type DependencyMaker

type DependencyMaker struct {
	depmake.DependencyMaker
}

DependencyMaker can be created with DependencyMaker{}

type Options

type Options struct {
	Version                  bool
	ModeDebug                bool
	FifoAckQueue             string
	FifoAckExchange          string
	FeaturePrintEventOnError bool
	PeriodicalWaitTime       time.Duration
	WorkerPoolSize           int
	LastRetryInterval        time.Duration
}

func ParseOptions

func ParseOptions() Options