Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkflowTester ¶
type WorkflowTester 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(vtpr interface{}, err *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(wf interface{}, opts ...WorkflowTesterOption) WorkflowTester
type WorkflowTesterOption ¶ added in v0.0.9
type WorkflowTesterOption func(*options)
func WithLogger ¶ added in v0.0.9
func WithLogger(logger log.Logger) WorkflowTesterOption
Click to show internal directories.
Click to hide internal directories.