Documentation
¶
Index ¶
- type Client
- func (_m *Client) CancelWorkflow(ctx context.Context, workflowID string, runID string) error
- func (_m *Client) CheckHealth(ctx context.Context, request *client.CheckHealthRequest) (*client.CheckHealthResponse, error)
- func (_m *Client) Close()
- func (_m *Client) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error
- func (_m *Client) CompleteActivityByID(ctx context.Context, namespace string, workflowID string, runID string, ...) error
- func (_m *Client) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
- func (_m *Client) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)
- func (_m *Client) DescribeWorkflowExecution(ctx context.Context, workflowID string, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)
- func (_m *Client) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error)
- func (_m *Client) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)
- func (_m *Client) GetWorkerBuildIdCompatibility(ctx context.Context, options *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)
- func (_m *Client) GetWorkflow(ctx context.Context, workflowID string, runID string) client.WorkflowRun
- func (_m *Client) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, ...) client.HistoryEventIterator
- func (_m *Client) GetWorkflowUpdateHandle(ref client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle
- func (_m *Client) ListArchivedWorkflow(ctx context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
- func (_m *Client) ListClosedWorkflow(ctx context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
- func (_m *Client) ListOpenWorkflow(ctx context.Context, ...) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
- func (_m *Client) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
- func (_m *Client) OperatorService() operatorservice.OperatorServiceClient
- func (_m *Client) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, ...) (converter.EncodedValue, error)
- func (_m *Client) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)
- func (_m *Client) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error
- func (_m *Client) RecordActivityHeartbeatByID(ctx context.Context, namespace string, workflowID string, runID string, ...) error
- func (_m *Client) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
- func (_m *Client) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
- func (_m *Client) ScheduleClient() client.ScheduleClient
- func (_m *Client) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, ...) (client.WorkflowRun, error)
- func (_m *Client) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, ...) error
- func (_m *Client) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, ...) error
- func (_m *Client) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error
- func (_m *Client) UpdateWorkflow(ctx context.Context, workflowID string, workflowRunID string, ...) (client.WorkflowUpdateHandle, error)
- func (_m *Client) UpdateWorkflowWithOptions(ctx context.Context, request *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error)
- func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewClient ¶
func NewClient(t mockConstructorTestingTNewClient) *Client
NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Client) CancelWorkflow ¶
CancelWorkflow provides a mock function with given fields: ctx, workflowID, runID
func (*Client) CheckHealth ¶
func (_m *Client) CheckHealth(ctx context.Context, request *client.CheckHealthRequest) (*client.CheckHealthResponse, error)
CheckHealth provides a mock function with given fields: ctx, request
func (*Client) CompleteActivity ¶
func (_m *Client) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error
CompleteActivity provides a mock function with given fields: ctx, taskToken, result, err
func (*Client) CompleteActivityByID ¶
func (_m *Client) CompleteActivityByID(ctx context.Context, namespace string, workflowID string, runID string, activityID string, result interface{}, err error) error
CompleteActivityByID provides a mock function with given fields: ctx, namespace, workflowID, runID, activityID, result, err
func (*Client) CountWorkflow ¶
func (_m *Client) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
CountWorkflow provides a mock function with given fields: ctx, request
func (*Client) DescribeTaskQueue ¶
func (_m *Client) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue provides a mock function with given fields: ctx, taskqueue, taskqueueType
func (*Client) DescribeWorkflowExecution ¶
func (_m *Client) DescribeWorkflowExecution(ctx context.Context, workflowID string, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution provides a mock function with given fields: ctx, workflowID, runID
func (*Client) ExecuteWorkflow ¶
func (_m *Client) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) (client.WorkflowRun, error)
ExecuteWorkflow provides a mock function with given fields: ctx, options, workflow, args
func (*Client) GetSearchAttributes ¶
func (_m *Client) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)
GetSearchAttributes provides a mock function with given fields: ctx
func (*Client) GetWorkerBuildIdCompatibility ¶
func (_m *Client) GetWorkerBuildIdCompatibility(ctx context.Context, options *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)
GetWorkerBuildIdCompatibility provides a mock function with given fields: ctx, options
func (*Client) GetWorkflow ¶
func (_m *Client) GetWorkflow(ctx context.Context, workflowID string, runID string) client.WorkflowRun
GetWorkflow provides a mock function with given fields: ctx, workflowID, runID
func (*Client) GetWorkflowHistory ¶
func (_m *Client) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, filterType enums.HistoryEventFilterType) client.HistoryEventIterator
GetWorkflowHistory provides a mock function with given fields: ctx, workflowID, runID, isLongPoll, filterType
func (*Client) GetWorkflowUpdateHandle ¶
func (_m *Client) GetWorkflowUpdateHandle(ref client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle
GetWorkflowUpdateHandle provides a mock function with given fields: ref
func (*Client) ListArchivedWorkflow ¶
func (_m *Client) ListArchivedWorkflow(ctx context.Context, request *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflow provides a mock function with given fields: ctx, request
func (*Client) ListClosedWorkflow ¶
func (_m *Client) ListClosedWorkflow(ctx context.Context, request *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflow provides a mock function with given fields: ctx, request
func (*Client) ListOpenWorkflow ¶
func (_m *Client) ListOpenWorkflow(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflow provides a mock function with given fields: ctx, request
func (*Client) ListWorkflow ¶
func (_m *Client) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
ListWorkflow provides a mock function with given fields: ctx, request
func (*Client) OperatorService ¶
func (_m *Client) OperatorService() operatorservice.OperatorServiceClient
OperatorService provides a mock function with given fields:
func (*Client) QueryWorkflow ¶
func (_m *Client) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, args ...interface{}) (converter.EncodedValue, error)
QueryWorkflow provides a mock function with given fields: ctx, workflowID, runID, queryType, args
func (*Client) QueryWorkflowWithOptions ¶
func (_m *Client) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)
QueryWorkflowWithOptions provides a mock function with given fields: ctx, request
func (*Client) RecordActivityHeartbeat ¶
func (_m *Client) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error
RecordActivityHeartbeat provides a mock function with given fields: ctx, taskToken, details
func (*Client) RecordActivityHeartbeatByID ¶
func (_m *Client) RecordActivityHeartbeatByID(ctx context.Context, namespace string, workflowID string, runID string, activityID string, details ...interface{}) error
RecordActivityHeartbeatByID provides a mock function with given fields: ctx, namespace, workflowID, runID, activityID, details
func (*Client) ResetWorkflowExecution ¶
func (_m *Client) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution provides a mock function with given fields: ctx, request
func (*Client) ScanWorkflow ¶
func (_m *Client) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
ScanWorkflow provides a mock function with given fields: ctx, request
func (*Client) ScheduleClient ¶
func (_m *Client) ScheduleClient() client.ScheduleClient
ScheduleClient provides a mock function with given fields:
func (*Client) SignalWithStartWorkflow ¶
func (_m *Client) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, signalArg interface{}, options client.StartWorkflowOptions, workflow interface{}, workflowArgs ...interface{}) (client.WorkflowRun, error)
SignalWithStartWorkflow provides a mock function with given fields: ctx, workflowID, signalName, signalArg, options, workflow, workflowArgs
func (*Client) SignalWorkflow ¶
func (_m *Client) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, arg interface{}) error
SignalWorkflow provides a mock function with given fields: ctx, workflowID, runID, signalName, arg
func (*Client) TerminateWorkflow ¶
func (_m *Client) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, details ...interface{}) error
TerminateWorkflow provides a mock function with given fields: ctx, workflowID, runID, reason, details
func (*Client) UpdateWorkerBuildIdCompatibility ¶
func (_m *Client) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error
UpdateWorkerBuildIdCompatibility provides a mock function with given fields: ctx, options
func (*Client) UpdateWorkflow ¶
func (_m *Client) UpdateWorkflow(ctx context.Context, workflowID string, workflowRunID string, updateName string, args ...interface{}) (client.WorkflowUpdateHandle, error)
UpdateWorkflow provides a mock function with given fields: ctx, workflowID, workflowRunID, updateName, args
func (*Client) UpdateWorkflowWithOptions ¶
func (_m *Client) UpdateWorkflowWithOptions(ctx context.Context, request *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error)
UpdateWorkflowWithOptions provides a mock function with given fields: ctx, request
func (*Client) WorkflowService ¶
func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient
WorkflowService provides a mock function with given fields:
Source Files