Documentation
¶
Index ¶
Constants ¶
View Source
const ( // TM_TimeTravel is the default time mode. Time is advanced by directly jumping to the next timer ready to be fired. TM_TimeTravel timeMode = iota // TM_WallClock prevents time traveling. Timers are only fired when the time has actually passed. TM_WallClock )
Variables ¶
This section is empty.
Functions ¶
func NewWorkflowTester ¶
func NewWorkflowTester[TResult any](wf interface{}, opts ...WorkflowTesterOption) *workflowTester[TResult]
Types ¶
type WorkflowTester ¶
type WorkflowTester[TResult any] interface { // Now returns the current time of the simulated clock in the tester Now() time.Time Execute(args ...interface{}) Registry() *workflow.Registry OnActivity(activity interface{}, args ...interface{}) *mock.Call OnSubWorkflow(workflow interface{}, args ...interface{}) *mock.Call SignalWorkflow(signalName string, value interface{}) SignalWorkflowInstance(wfi *core.WorkflowInstance, signalName string, value interface{}) error WorkflowFinished() bool WorkflowResult() (TResult, string) // AssertExpectations asserts any assertions set up for mock activities and sub-workflow AssertExpectations(t *testing.T) // ScheduleCallback schedules the given callback after the given delay in workflow time (not wall clock). ScheduleCallback(delay time.Duration, callback func()) // ListenSubWorkflow registers a handler to be called when a sub-workflow is started. ListenSubWorkflow(listener func(instance *core.WorkflowInstance, name string)) }
type WorkflowTesterOption ¶ added in v0.4.0
type WorkflowTesterOption func(*options)
func WithConverter ¶ added in v0.9.0
func WithConverter(converter converter.Converter) WorkflowTesterOption
func WithLogger ¶ added in v0.4.0
func WithLogger(logger log.Logger) WorkflowTesterOption
func WithTestTimeout ¶ added in v0.4.0
func WithTestTimeout(timeout time.Duration) WorkflowTesterOption
Source Files
Click to show internal directories.
Click to hide internal directories.