taskpoller

Dec 23, 2024

Changes in this version

+ var CompleteActivityTask = func(tv *testvars.TestVars) ...

+ var DrainWorkflowTask = func(task *workflowservice.PollWorkflowTaskQueueResponse) (*workflowservice.RespondWorkflowTaskCompletedRequest, error)

+ var NoActivityTaskAvailable = errors.New(...)

+ var NoWorkflowTaskAvailable = errors.New(...)

+ var WithTimeout = func(timeout time.Duration) optionFunc

+ type TaskPoller struct

+ func New(t *testing.T, client workflowservice.WorkflowServiceClient, namespace string) *TaskPoller

+ func (p *TaskPoller) HandleActivityTask(tv *testvars.TestVars, task *workflowservice.PollActivityTaskQueueResponse, ...) (*workflowservice.RespondActivityTaskCompletedResponse, error)

+ func (p *TaskPoller) HandleWorkflowTask(tv *testvars.TestVars, task *workflowservice.PollWorkflowTaskQueueResponse, ...) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)

+ func (p *TaskPoller) PollActivityTask(req *workflowservice.PollActivityTaskQueueRequest) *activityTaskPoller

+ func (p *TaskPoller) PollAndHandleActivityTask(tv *testvars.TestVars, ...) (*workflowservice.RespondActivityTaskCompletedResponse, error)

+ func (p *TaskPoller) PollAndHandleWorkflowTask(tv *testvars.TestVars, ...) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)

+ func (p *TaskPoller) PollWorkflowTask(req *workflowservice.PollWorkflowTaskQueueRequest) *workflowTaskPoller