Documentation ¶
Overview ¶
Code generated by mockery v1.0.0. DO NOT EDIT.
Code generated by mockery v1.0.0 ¶
Code generated by mockery v2.30.16. DO NOT EDIT. Modified manually to add new method.
Code generated by mockery v2.30.16. DO NOT EDIT. Modified manually to add new method.
Code generated by mockery v2.30.16. DO NOT EDIT. Modified manually to add new method.
Code generated by mockery v1.0.0. DO NOT EDIT. Modified manually to add new method.
Code generated by mockery v2.30.16. DO NOT EDIT. Modified manually to add new method.
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 enumspb.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) GetWorkerTaskReachability(ctx context.Context, options *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, 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, updateName string, ...) (client.WorkflowUpdateHandle, error)
- func (_m *Client) UpdateWorkflowWithOptions(ctx context.Context, req *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error)
- func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient
- type HistoryEventIterator
- type NamespaceClient
- func (_m *NamespaceClient) Close()
- func (_m *NamespaceClient) Describe(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error)
- func (_m *NamespaceClient) Register(ctx context.Context, request *workflowservice.RegisterNamespaceRequest) error
- func (_m *NamespaceClient) Update(ctx context.Context, request *workflowservice.UpdateNamespaceRequest) error
- type ScheduleClient
- func (_m *ScheduleClient) Create(ctx context.Context, options client.ScheduleOptions) (client.ScheduleHandle, error)
- func (_m *ScheduleClient) GetHandle(ctx context.Context, scheduleID string) client.ScheduleHandle
- func (_m *ScheduleClient) List(ctx context.Context, options client.ScheduleListOptions) (client.ScheduleListIterator, error)
- type ScheduleHandle
- func (_m *ScheduleHandle) Backfill(ctx context.Context, options client.ScheduleBackfillOptions) error
- func (_m *ScheduleHandle) Delete(ctx context.Context) error
- func (_m *ScheduleHandle) Describe(ctx context.Context) (*client.ScheduleDescription, error)
- func (_m *ScheduleHandle) GetID() string
- func (_m *ScheduleHandle) Pause(ctx context.Context, options client.SchedulePauseOptions) error
- func (_m *ScheduleHandle) Trigger(ctx context.Context, options client.ScheduleTriggerOptions) error
- func (_m *ScheduleHandle) Unpause(ctx context.Context, options client.ScheduleUnpauseOptions) error
- func (_m *ScheduleHandle) Update(ctx context.Context, options client.ScheduleUpdateOptions) error
- type ScheduleListIterator
- type Value
- type WorkflowRun
- type WorkflowUpdateHandle
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 (*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 enumspb.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) GetWorkerTaskReachability ¶
func (_m *Client) GetWorkerTaskReachability(ctx context.Context, options *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)
GetWorkerTaskReachability 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 enumspb.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
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
Schedule 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 (*Client) UpdateWorkflowWithOptions ¶
func (_m *Client) UpdateWorkflowWithOptions(ctx context.Context, req *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error)
func (*Client) WorkflowService ¶
func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient
WorkflowService provides a mock function with given fields:
type HistoryEventIterator ¶
HistoryEventIterator is an autogenerated mock type for the HistoryEventIterator type
func (*HistoryEventIterator) HasNext ¶
func (_m *HistoryEventIterator) HasNext() bool
HasNext provides a mock function with given fields:
func (*HistoryEventIterator) Next ¶
func (_m *HistoryEventIterator) Next() (*historypb.HistoryEvent, error)
Next provides a mock function with given fields:
type NamespaceClient ¶
NamespaceClient is an autogenerated mock type for the NamespaceClient type
func (*NamespaceClient) Close ¶
func (_m *NamespaceClient) Close()
Close provides a mock function without given fields
func (*NamespaceClient) Describe ¶
func (_m *NamespaceClient) Describe(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error)
Describe provides a mock function with given fields: ctx, name
type ScheduleClient ¶
ScheduleClient is an autogenerated mock type for the ScheduleClient type
func NewScheduleClient ¶
func NewScheduleClient(t interface { mock.TestingT Cleanup(func()) }) *ScheduleClient
NewScheduleClient creates a new instance of ScheduleClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ScheduleClient) Create ¶
func (_m *ScheduleClient) Create(ctx context.Context, options client.ScheduleOptions) (client.ScheduleHandle, error)
Create provides a mock function with given fields: ctx, options
func (*ScheduleClient) GetHandle ¶
func (_m *ScheduleClient) GetHandle(ctx context.Context, scheduleID string) client.ScheduleHandle
GetHandle provides a mock function with given fields: ctx, scheduleID
func (*ScheduleClient) List ¶
func (_m *ScheduleClient) List(ctx context.Context, options client.ScheduleListOptions) (client.ScheduleListIterator, error)
List provides a mock function with given fields: ctx, options
type ScheduleHandle ¶
ScheduleHandle is an autogenerated mock type for the ScheduleHandle type
func NewScheduleHandle ¶
func NewScheduleHandle(t interface { mock.TestingT Cleanup(func()) }) *ScheduleHandle
NewScheduleHandle creates a new instance of ScheduleHandle. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ScheduleHandle) Backfill ¶
func (_m *ScheduleHandle) Backfill(ctx context.Context, options client.ScheduleBackfillOptions) error
Backfill provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Delete ¶
func (_m *ScheduleHandle) Delete(ctx context.Context) error
Delete provides a mock function with given fields: ctx
func (*ScheduleHandle) Describe ¶
func (_m *ScheduleHandle) Describe(ctx context.Context) (*client.ScheduleDescription, error)
Describe provides a mock function with given fields: ctx
func (*ScheduleHandle) GetID ¶
func (_m *ScheduleHandle) GetID() string
GetID provides a mock function with given fields:
func (*ScheduleHandle) Pause ¶
func (_m *ScheduleHandle) Pause(ctx context.Context, options client.SchedulePauseOptions) error
Pause provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Trigger ¶
func (_m *ScheduleHandle) Trigger(ctx context.Context, options client.ScheduleTriggerOptions) error
Trigger provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Unpause ¶
func (_m *ScheduleHandle) Unpause(ctx context.Context, options client.ScheduleUnpauseOptions) error
Unpause provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Update ¶
func (_m *ScheduleHandle) Update(ctx context.Context, options client.ScheduleUpdateOptions) error
Update provides a mock function with given fields: ctx, options
type ScheduleListIterator ¶
ScheduleListIterator is an autogenerated mock type for the ScheduleListIterator type
func NewScheduleListIterator ¶
func NewScheduleListIterator(t interface { mock.TestingT Cleanup(func()) }) *ScheduleListIterator
NewScheduleListIterator creates a new instance of ScheduleListIterator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ScheduleListIterator) HasNext ¶
func (_m *ScheduleListIterator) HasNext() bool
HasNext provides a mock function with given fields:
func (*ScheduleListIterator) Next ¶
func (_m *ScheduleListIterator) Next() (*client.ScheduleListEntry, error)
Next provides a mock function with given fields:
type Value ¶
Value is an autogenerated mock type for the Value type
type WorkflowRun ¶
WorkflowRun is an autogenerated mock type for the WorkflowRun type
func (*WorkflowRun) Get ¶
func (_m *WorkflowRun) Get(ctx context.Context, valuePtr interface{}) error
Get provides a mock function with given fields: ctx, valuePtr
func (*WorkflowRun) GetID ¶
func (_m *WorkflowRun) GetID() string
GetID provides a mock function with given fields:
func (*WorkflowRun) GetRunID ¶
func (_m *WorkflowRun) GetRunID() string
GetRunID provides a mock function with given fields:
func (*WorkflowRun) GetWithOptions ¶
func (_m *WorkflowRun) GetWithOptions(ctx context.Context, valuePtr interface{}, options client.WorkflowRunGetOptions) error
GetWithOptions provides a mock function with given fields: ctx, valuePtr, options
type WorkflowUpdateHandle ¶
WorkflowUpdateHandle is an autogenerated mock type for the WorkflowUpdateHandle type
func NewWorkflowUpdateHandle ¶
func NewWorkflowUpdateHandle(t interface { mock.TestingT Cleanup(func()) }) *WorkflowUpdateHandle
NewWorkflowUpdateHandle creates a new instance of WorkflowUpdateHandle. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*WorkflowUpdateHandle) Get ¶
func (_m *WorkflowUpdateHandle) Get(ctx context.Context, valuePtr interface{}) error
Get provides a mock function with given fields: ctx, valuePtr
func (*WorkflowUpdateHandle) RunID ¶
func (_m *WorkflowUpdateHandle) RunID() string
RunID provides a mock function with given fields:
func (*WorkflowUpdateHandle) UpdateID ¶
func (_m *WorkflowUpdateHandle) UpdateID() string
UpdateID provides a mock function with given fields:
func (*WorkflowUpdateHandle) WorkflowID ¶
func (_m *WorkflowUpdateHandle) WorkflowID() string
WorkflowID provides a mock function with given fields: