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) DeploymentClient() client.DeploymentClient
- func (_m *Client) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)
- func (_m *Client) DescribeTaskQueueEnhanced(ctx context.Context, options client.DescribeTaskQueueEnhancedOptions) (client.TaskQueueDescription, 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) GetWorkerVersioningRules(ctx context.Context, options client.GetWorkerVersioningOptions) (*client.WorkerVersioningRules, 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) NewWithStartWorkflowOperation(options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) client.WithStartWorkflowOperation
- 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) UpdateWithStartWorkflow(ctx context.Context, options client.UpdateWithStartWorkflowOptions) (client.WorkflowUpdateHandle, error)
- func (_m *Client) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error
- func (_m *Client) UpdateWorkerVersioningRules(ctx context.Context, options client.UpdateWorkerVersioningRulesOptions) (*client.WorkerVersioningRules, error)
- func (_m *Client) UpdateWorkflow(ctx context.Context, options client.UpdateWorkflowOptions) (client.WorkflowUpdateHandle, error)
- func (_m *Client) UpdateWorkflowExecutionOptions(ctx context.Context, options client.UpdateWorkflowExecutionOptionsRequest) (client.WorkflowExecutionOptions, error)
- func (_m *Client) WorkerDeploymentClient() client.WorkerDeploymentClient
- func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient
- type DeploymentClient
- func (_m *DeploymentClient) Describe(ctx context.Context, options client.DeploymentDescribeOptions) (client.DeploymentDescription, error)
- func (_m *DeploymentClient) GetCurrent(ctx context.Context, options client.DeploymentGetCurrentOptions) (client.DeploymentGetCurrentResponse, error)
- func (_m *DeploymentClient) GetReachability(ctx context.Context, options client.DeploymentGetReachabilityOptions) (client.DeploymentReachabilityInfo, error)
- func (_m *DeploymentClient) List(ctx context.Context, options client.DeploymentListOptions) (client.DeploymentListIterator, error)
- func (_m *DeploymentClient) SetCurrent(ctx context.Context, options client.DeploymentSetCurrentOptions) (client.DeploymentSetCurrentResponse, error)
- type DeploymentListIterator
- 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 WorkerDeploymentClient
- func (_m *WorkerDeploymentClient) Delete(ctx context.Context, options client.WorkerDeploymentDeleteOptions) (client.WorkerDeploymentDeleteResponse, error)
- func (_m *WorkerDeploymentClient) GetHandle(name string) client.WorkerDeploymentHandle
- func (_m *WorkerDeploymentClient) List(ctx context.Context, options client.WorkerDeploymentListOptions) (client.WorkerDeploymentListIterator, error)
- type WorkerDeploymentHandle
- func (_m *WorkerDeploymentHandle) DeleteVersion(ctx context.Context, options client.WorkerDeploymentDeleteVersionOptions) (client.WorkerDeploymentDeleteVersionResponse, error)
- func (_m *WorkerDeploymentHandle) Describe(ctx context.Context, options client.WorkerDeploymentDescribeOptions) (client.WorkerDeploymentDescribeResponse, error)
- func (_m *WorkerDeploymentHandle) DescribeVersion(ctx context.Context, options client.WorkerDeploymentDescribeVersionOptions) (client.WorkerDeploymentVersionDescription, error)
- func (_m *WorkerDeploymentHandle) SetCurrentVersion(ctx context.Context, options client.WorkerDeploymentSetCurrentVersionOptions) (client.WorkerDeploymentSetCurrentVersionResponse, error)
- func (_m *WorkerDeploymentHandle) SetRampingVersion(ctx context.Context, options client.WorkerDeploymentSetRampingVersionOptions) (client.WorkerDeploymentSetRampingVersionResponse, error)
- func (_m *WorkerDeploymentHandle) UpdateVersionMetadata(ctx context.Context, ...) (client.WorkerDeploymentUpdateVersionMetadataResponse, error)
- type WorkerDeploymentListIterator
- 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 NewClient ¶ added in v1.26.0
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. The first argument is typically a *testing.T value.
func (*Client) CancelWorkflow ¶
CancelWorkflow provides a mock function with given fields: ctx, workflowID, runID
func (*Client) CheckHealth ¶ added in v1.15.0
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) DeploymentClient ¶ added in v1.32.0
func (_m *Client) DeploymentClient() client.DeploymentClient
DeploymentClient provides a mock function with given fields:
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) DescribeTaskQueueEnhanced ¶ added in v1.27.0
func (_m *Client) DescribeTaskQueueEnhanced(ctx context.Context, options client.DescribeTaskQueueEnhancedOptions) (client.TaskQueueDescription, error)
DescribeTaskQueueEnhanced provides a mock function with given fields: ctx, options
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 ¶ added in v1.22.0
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 ¶ added in v1.25.0
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) GetWorkerVersioningRules ¶ added in v1.27.0
func (_m *Client) GetWorkerVersioningRules(ctx context.Context, options client.GetWorkerVersioningOptions) (*client.WorkerVersioningRules, error)
GetWorkerVersioningRules 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 ¶ added in v1.22.2
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) NewWithStartWorkflowOperation ¶ added in v1.31.0
func (_m *Client) NewWithStartWorkflowOperation(options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) client.WithStartWorkflowOperation
NewWithStartWorkflowOperation provides a mock function with given fields: options, workflow, args
func (*Client) OperatorService ¶ added in v1.17.0
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 ¶ added in v1.6.0
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 ¶ added in v1.18.0
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) UpdateWithStartWorkflow ¶ added in v1.31.0
func (_m *Client) UpdateWithStartWorkflow(ctx context.Context, options client.UpdateWithStartWorkflowOptions) (client.WorkflowUpdateHandle, error)
UpdateWithStartWorkflow provides a mock function with given fields: ctx, options
func (*Client) UpdateWorkerBuildIdCompatibility ¶ added in v1.22.0
func (_m *Client) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error
UpdateWorkerBuildIdCompatibility provides a mock function with given fields: ctx, options
func (*Client) UpdateWorkerVersioningRules ¶ added in v1.27.0
func (_m *Client) UpdateWorkerVersioningRules(ctx context.Context, options client.UpdateWorkerVersioningRulesOptions) (*client.WorkerVersioningRules, error)
UpdateWorkerVersioningRules provides a mock function with given fields: ctx, options
func (*Client) UpdateWorkflow ¶ added in v1.20.0
func (_m *Client) UpdateWorkflow(ctx context.Context, options client.UpdateWorkflowOptions) (client.WorkflowUpdateHandle, error)
UpdateWorkflow provides a mock function with given fields: ctx, options
func (*Client) UpdateWorkflowExecutionOptions ¶ added in v1.32.0
func (_m *Client) UpdateWorkflowExecutionOptions(ctx context.Context, options client.UpdateWorkflowExecutionOptionsRequest) (client.WorkflowExecutionOptions, error)
UpdateWorkflowExecutionOptions provides a mock function with given fields: ctx, options
func (*Client) WorkerDeploymentClient ¶ added in v1.33.0
func (_m *Client) WorkerDeploymentClient() client.WorkerDeploymentClient
WorkerDeploymentClient provides a mock function with given fields:
func (*Client) WorkflowService ¶ added in v1.12.0
func (_m *Client) WorkflowService() workflowservice.WorkflowServiceClient
WorkflowService provides a mock function with given fields:
type DeploymentClient ¶ added in v1.32.0
DeploymentClient is an autogenerated mock type for the DeploymentClient type
func NewDeploymentClient ¶ added in v1.32.0
func NewDeploymentClient(t interface { mock.TestingT Cleanup(func()) }) *DeploymentClient
NewDeploymentClient creates a new instance of DeploymentClient. 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 (*DeploymentClient) Describe ¶ added in v1.32.0
func (_m *DeploymentClient) Describe(ctx context.Context, options client.DeploymentDescribeOptions) (client.DeploymentDescription, error)
Describe provides a mock function with given fields: ctx, options
func (*DeploymentClient) GetCurrent ¶ added in v1.32.0
func (_m *DeploymentClient) GetCurrent(ctx context.Context, options client.DeploymentGetCurrentOptions) (client.DeploymentGetCurrentResponse, error)
GetCurrent provides a mock function with given fields: ctx, options
func (*DeploymentClient) GetReachability ¶ added in v1.32.0
func (_m *DeploymentClient) GetReachability(ctx context.Context, options client.DeploymentGetReachabilityOptions) (client.DeploymentReachabilityInfo, error)
GetReachability provides a mock function with given fields: ctx, options
func (*DeploymentClient) List ¶ added in v1.32.0
func (_m *DeploymentClient) List(ctx context.Context, options client.DeploymentListOptions) (client.DeploymentListIterator, error)
List provides a mock function with given fields: ctx, options
func (*DeploymentClient) SetCurrent ¶ added in v1.32.0
func (_m *DeploymentClient) SetCurrent(ctx context.Context, options client.DeploymentSetCurrentOptions) (client.DeploymentSetCurrentResponse, error)
SetCurrent provides a mock function with given fields: ctx, options
type DeploymentListIterator ¶ added in v1.32.0
DeploymentListIterator is an autogenerated mock type for the DeploymentListIterator type
func NewDeploymentListIterator ¶ added in v1.32.0
func NewDeploymentListIterator(t interface { mock.TestingT Cleanup(func()) }) *DeploymentListIterator
NewDeploymentListIterator creates a new instance of DeploymentListIterator. 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 (*DeploymentListIterator) HasNext ¶ added in v1.32.0
func (_m *DeploymentListIterator) HasNext() bool
HasNext provides a mock function with given fields:
func (*DeploymentListIterator) Next ¶ added in v1.32.0
func (_m *DeploymentListIterator) Next() (*client.DeploymentListEntry, error)
Next provides a mock function with given fields:
type HistoryEventIterator ¶
HistoryEventIterator is an autogenerated mock type for the HistoryEventIterator type
func NewHistoryEventIterator ¶ added in v1.26.0
func NewHistoryEventIterator(t interface { mock.TestingT Cleanup(func()) }) *HistoryEventIterator
NewHistoryEventIterator creates a new instance of HistoryEventIterator. 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 (*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 NewNamespaceClient ¶ added in v1.26.0
func NewNamespaceClient(t interface { mock.TestingT Cleanup(func()) }) *NamespaceClient
NewNamespaceClient creates a new instance of NamespaceClient. 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 (*NamespaceClient) Close ¶
func (_m *NamespaceClient) Close()
Close provides a mock function with 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 ¶ added in v1.24.0
ScheduleClient is an autogenerated mock type for the ScheduleClient type
func NewScheduleClient ¶ added in v1.24.0
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 ¶ added in v1.24.0
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 ¶ added in v1.24.0
func (_m *ScheduleClient) GetHandle(ctx context.Context, scheduleID string) client.ScheduleHandle
GetHandle provides a mock function with given fields: ctx, scheduleID
func (*ScheduleClient) List ¶ added in v1.24.0
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 ¶ added in v1.24.0
ScheduleHandle is an autogenerated mock type for the ScheduleHandle type
func NewScheduleHandle ¶ added in v1.24.0
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 ¶ added in v1.24.0
func (_m *ScheduleHandle) Backfill(ctx context.Context, options client.ScheduleBackfillOptions) error
Backfill provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Delete ¶ added in v1.24.0
func (_m *ScheduleHandle) Delete(ctx context.Context) error
Delete provides a mock function with given fields: ctx
func (*ScheduleHandle) Describe ¶ added in v1.24.0
func (_m *ScheduleHandle) Describe(ctx context.Context) (*client.ScheduleDescription, error)
Describe provides a mock function with given fields: ctx
func (*ScheduleHandle) GetID ¶ added in v1.24.0
func (_m *ScheduleHandle) GetID() string
GetID provides a mock function with given fields:
func (*ScheduleHandle) Pause ¶ added in v1.24.0
func (_m *ScheduleHandle) Pause(ctx context.Context, options client.SchedulePauseOptions) error
Pause provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Trigger ¶ added in v1.24.0
func (_m *ScheduleHandle) Trigger(ctx context.Context, options client.ScheduleTriggerOptions) error
Trigger provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Unpause ¶ added in v1.24.0
func (_m *ScheduleHandle) Unpause(ctx context.Context, options client.ScheduleUnpauseOptions) error
Unpause provides a mock function with given fields: ctx, options
func (*ScheduleHandle) Update ¶ added in v1.24.0
func (_m *ScheduleHandle) Update(ctx context.Context, options client.ScheduleUpdateOptions) error
Update provides a mock function with given fields: ctx, options
type ScheduleListIterator ¶ added in v1.24.0
ScheduleListIterator is an autogenerated mock type for the ScheduleListIterator type
func NewScheduleListIterator ¶ added in v1.24.0
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 ¶ added in v1.24.0
func (_m *ScheduleListIterator) HasNext() bool
HasNext provides a mock function with given fields:
func (*ScheduleListIterator) Next ¶ added in v1.24.0
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
func NewEncodedValue ¶ added in v1.26.0
NewEncodedValue creates a new instance of Value. 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.
type WorkerDeploymentClient ¶ added in v1.33.0
WorkerDeploymentClient is an autogenerated mock type for the WorkerDeploymentClient type
func NewWorkerDeploymentClient ¶ added in v1.33.0
func NewWorkerDeploymentClient(t interface { mock.TestingT Cleanup(func()) }) *WorkerDeploymentClient
NewWorkerDeploymentClient creates a new instance of WorkerDeploymentClient. 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 (*WorkerDeploymentClient) Delete ¶ added in v1.33.0
func (_m *WorkerDeploymentClient) Delete(ctx context.Context, options client.WorkerDeploymentDeleteOptions) (client.WorkerDeploymentDeleteResponse, error)
Delete provides a mock function with given fields: ctx, options
func (*WorkerDeploymentClient) GetHandle ¶ added in v1.33.0
func (_m *WorkerDeploymentClient) GetHandle(name string) client.WorkerDeploymentHandle
GetHandle provides a mock function with given fields: name
func (*WorkerDeploymentClient) List ¶ added in v1.33.0
func (_m *WorkerDeploymentClient) List(ctx context.Context, options client.WorkerDeploymentListOptions) (client.WorkerDeploymentListIterator, error)
List provides a mock function with given fields: ctx, options
type WorkerDeploymentHandle ¶ added in v1.33.0
WorkerDeploymentHandle is an autogenerated mock type for the WorkerDeploymentHandle type
func NewWorkerDeploymentHandle ¶ added in v1.33.0
func NewWorkerDeploymentHandle(t interface { mock.TestingT Cleanup(func()) }) *WorkerDeploymentHandle
NewWorkerDeploymentHandle creates a new instance of WorkerDeploymentHandle. 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 (*WorkerDeploymentHandle) DeleteVersion ¶ added in v1.33.0
func (_m *WorkerDeploymentHandle) DeleteVersion(ctx context.Context, options client.WorkerDeploymentDeleteVersionOptions) (client.WorkerDeploymentDeleteVersionResponse, error)
DeleteVersion provides a mock function with given fields: ctx, options
func (*WorkerDeploymentHandle) Describe ¶ added in v1.33.0
func (_m *WorkerDeploymentHandle) Describe(ctx context.Context, options client.WorkerDeploymentDescribeOptions) (client.WorkerDeploymentDescribeResponse, error)
Describe provides a mock function with given fields: ctx, options
func (*WorkerDeploymentHandle) DescribeVersion ¶ added in v1.33.0
func (_m *WorkerDeploymentHandle) DescribeVersion(ctx context.Context, options client.WorkerDeploymentDescribeVersionOptions) (client.WorkerDeploymentVersionDescription, error)
DescribeVersion provides a mock function with given fields: ctx, options
func (*WorkerDeploymentHandle) SetCurrentVersion ¶ added in v1.33.0
func (_m *WorkerDeploymentHandle) SetCurrentVersion(ctx context.Context, options client.WorkerDeploymentSetCurrentVersionOptions) (client.WorkerDeploymentSetCurrentVersionResponse, error)
SetCurrentVersion provides a mock function with given fields: ctx, options
func (*WorkerDeploymentHandle) SetRampingVersion ¶ added in v1.33.0
func (_m *WorkerDeploymentHandle) SetRampingVersion(ctx context.Context, options client.WorkerDeploymentSetRampingVersionOptions) (client.WorkerDeploymentSetRampingVersionResponse, error)
SetRampingVersion provides a mock function with given fields: ctx, options
func (*WorkerDeploymentHandle) UpdateVersionMetadata ¶ added in v1.33.0
func (_m *WorkerDeploymentHandle) UpdateVersionMetadata(ctx context.Context, options client.WorkerDeploymentUpdateVersionMetadataOptions) (client.WorkerDeploymentUpdateVersionMetadataResponse, error)
UpdateVersionMetadata provides a mock function with given fields: ctx, options
type WorkerDeploymentListIterator ¶ added in v1.33.0
WorkerDeploymentListIterator is an autogenerated mock type for the WorkerDeploymentListIterator type
func NewWorkerDeploymentListIterator ¶ added in v1.33.0
func NewWorkerDeploymentListIterator(t interface { mock.TestingT Cleanup(func()) }) *WorkerDeploymentListIterator
NewWorkerDeploymentListIterator creates a new instance of WorkerDeploymentListIterator. 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 (*WorkerDeploymentListIterator) HasNext ¶ added in v1.33.0
func (_m *WorkerDeploymentListIterator) HasNext() bool
HasNext provides a mock function with given fields:
func (*WorkerDeploymentListIterator) Next ¶ added in v1.33.0
func (_m *WorkerDeploymentListIterator) Next() (*client.WorkerDeploymentListEntry, error)
Next provides a mock function with given fields:
type WorkflowRun ¶
WorkflowRun is an autogenerated mock type for the WorkflowRun type
func NewWorkflowRun ¶ added in v1.26.0
func NewWorkflowRun(t interface { mock.TestingT Cleanup(func()) }) *WorkflowRun
NewWorkflowRun creates a new instance of WorkflowRun. 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 (*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 ¶ added in v1.15.0
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 ¶ added in v1.24.0
WorkflowUpdateHandle is an autogenerated mock type for the WorkflowUpdateHandle type
func NewWorkflowUpdateHandle ¶ added in v1.24.0
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 ¶ added in v1.24.0
func (_m *WorkflowUpdateHandle) Get(ctx context.Context, valuePtr interface{}) error
Get provides a mock function with given fields: ctx, valuePtr
func (*WorkflowUpdateHandle) RunID ¶ added in v1.24.0
func (_m *WorkflowUpdateHandle) RunID() string
RunID provides a mock function with given fields:
func (*WorkflowUpdateHandle) UpdateID ¶ added in v1.24.0
func (_m *WorkflowUpdateHandle) UpdateID() string
UpdateID provides a mock function with given fields:
func (*WorkflowUpdateHandle) WorkflowID ¶ added in v1.24.0
func (_m *WorkflowUpdateHandle) WorkflowID() string
WorkflowID provides a mock function with given fields:
Source Files
¶
- Client.go
- DeploymentClient.go
- DeploymentListIterator.go
- HistoryEventIterator.go
- NamespaceClient.go
- ScheduleClient.go
- ScheduleHandle.go
- ScheduleListIterator.go
- Value.go
- WorkerDeploymentClient.go
- WorkerDeploymentHandle.go
- WorkerDeploymentListIterator.go
- WorkflowRun.go
- WorkflowUpdateHandle.go
- verify.go