mem_workflow

Documentation

Index

• type Worker
  • func NewWorker(actSvc service.Activity, notSvc service.Notification, ...) *Worker
  • func (m *Worker) Close(ctx context.Context) error
  • func (w *Worker) RunningTasks() uint32
  • func (m *Worker) Start(ctx context.Context) error
• type WorkerOpt
  • func WithLogLevel(lvl zerolog.Level) WorkerOpt

Types

type Worker

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

func NewWorker

func NewWorker(actSvc service.Activity, notSvc service.Notification, c chan workflow.ExecutionInput, opts ...WorkerOpt) *Worker

func (*Worker) Close

func (m *Worker) Close(ctx context.Context) error

func (*Worker) RunningTasks

func (w *Worker) RunningTasks() uint32

func (*Worker) Start

func (m *Worker) Start(ctx context.Context) error

type WorkerOpt

type WorkerOpt func(*Worker)

func WithLogLevel

func WithLogLevel(lvl zerolog.Level) WorkerOpt