workflows

Documentation

Index

• type WorkflowsController
• type WorkflowsControllerImpl
  • func New(fs ...WorkflowsControllerOpt) (*WorkflowsControllerImpl, error)
  • func (wc *WorkflowsControllerImpl) Start() (func() error, error)
• type WorkflowsControllerOpt
  • func WithDataDecoderValidator(dv datautils.DataDecoderValidator) WorkflowsControllerOpt
  • func WithLogger(l *zerolog.Logger) WorkflowsControllerOpt
  • func WithMessageQueue(mq msgqueue.MessageQueue) WorkflowsControllerOpt
  • func WithRepository(r repository.EngineRepository) WorkflowsControllerOpt
  • func WithTenantAlerter(ta *alerting.TenantAlertManager) WorkflowsControllerOpt
• type WorkflowsControllerOpts

Types

type WorkflowsController

type WorkflowsController interface {
	Start(ctx context.Context) error
}

type WorkflowsControllerImpl

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

func New

func New(fs ...WorkflowsControllerOpt) (*WorkflowsControllerImpl, error)

func (*WorkflowsControllerImpl) Start

func (wc *WorkflowsControllerImpl) Start() (func() error, error)

type WorkflowsControllerOpt

type WorkflowsControllerOpt func(*WorkflowsControllerOpts)

func WithDataDecoderValidator

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) WorkflowsControllerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) WorkflowsControllerOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) WorkflowsControllerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) WorkflowsControllerOpt

func WithTenantAlerter

func WithTenantAlerter(ta *alerting.TenantAlertManager) WorkflowsControllerOpt

type WorkflowsControllerOpts

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