mocks

Documentation

Overview

Mock implementation of a WorkflowExecutor for use in tests.

Index

• func NewMockEventScheduler() interfaces.EventScheduler
• type AddScheduleFunc
• type MockEventScheduler
  • func (s *MockEventScheduler) AddSchedule(ctx context.Context, input interfaces.AddScheduleInput) error
  • func (s *MockEventScheduler) CreateScheduleInput(ctx context.Context, appConfig *runtimeInterfaces.SchedulerConfig, ...) (interfaces.AddScheduleInput, error)
  • func (s *MockEventScheduler) RemoveSchedule(ctx context.Context, input interfaces.RemoveScheduleInput) error
  • func (s *MockEventScheduler) SetAddScheduleFunc(addScheduleFunc AddScheduleFunc)
  • func (s *MockEventScheduler) SetRemoveScheduleFunc(removeScheduleFunc RemoveScheduleFunc)
• type MockWorkflowExecutor
  • func (e *MockWorkflowExecutor) Run()
  • func (e *MockWorkflowExecutor) SetRunFunc(runFunc func())
  • func (e *MockWorkflowExecutor) SetStopFunc(stopFunc func() error)
  • func (e *MockWorkflowExecutor) Stop() error
• type RemoveScheduleFunc

Functions

func NewMockEventScheduler

func NewMockEventScheduler() interfaces.EventScheduler

Types

type AddScheduleFunc

type AddScheduleFunc func(ctx context.Context, input interfaces.AddScheduleInput) error

type MockEventScheduler

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

func (*MockEventScheduler) AddSchedule

func (s *MockEventScheduler) AddSchedule(ctx context.Context, input interfaces.AddScheduleInput) error

func (*MockEventScheduler) CreateScheduleInput

func (s *MockEventScheduler) CreateScheduleInput(ctx context.Context, appConfig *runtimeInterfaces.SchedulerConfig,
	identifier core.Identifier, schedule *admin.Schedule) (interfaces.AddScheduleInput, error)

func (*MockEventScheduler) RemoveSchedule

func (s *MockEventScheduler) RemoveSchedule(ctx context.Context, input interfaces.RemoveScheduleInput) error

func (*MockEventScheduler) SetAddScheduleFunc

func (s *MockEventScheduler) SetAddScheduleFunc(addScheduleFunc AddScheduleFunc)

func (*MockEventScheduler) SetRemoveScheduleFunc

func (s *MockEventScheduler) SetRemoveScheduleFunc(removeScheduleFunc RemoveScheduleFunc)

type MockWorkflowExecutor

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

func (*MockWorkflowExecutor) Run

func (e *MockWorkflowExecutor) Run()

func (*MockWorkflowExecutor) SetRunFunc

func (e *MockWorkflowExecutor) SetRunFunc(runFunc func())

func (*MockWorkflowExecutor) SetStopFunc

func (e *MockWorkflowExecutor) SetStopFunc(stopFunc func() error)

func (*MockWorkflowExecutor) Stop

func (e *MockWorkflowExecutor) Stop() error

type RemoveScheduleFunc

type RemoveScheduleFunc func(ctx context.Context, input interfaces.RemoveScheduleInput) error