Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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{}) 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)) }
func NewWorkflowTester ¶
func NewWorkflowTester[TResult any](wf interface{}, opts ...WorkflowTesterOption) WorkflowTester[TResult]
type WorkflowTesterOption ¶ added in v0.4.0
type WorkflowTesterOption func(*options)
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
Click to show internal directories.
Click to hide internal directories.