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 WithRepository(r repository.Repository) WorkflowsControllerOpt
  • func WithTaskQueue(tq taskqueue.TaskQueue) 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 WithRepository

func WithRepository(r repository.Repository) WorkflowsControllerOpt

func WithTaskQueue

func WithTaskQueue(tq taskqueue.TaskQueue) WorkflowsControllerOpt

type WorkflowsControllerOpts

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