Documentation ¶
Overview ¶
Package temporal is a generated GoMock package.
Package temporal is a generated GoMock package.
Index ¶
- func NewTemporalClient(tClient client.Client, namespace string, dataConverter converter.DataConverter, ...) uclient.UnifiedClient
- type MockClient
- func (m *MockClient) CancelWorkflow(ctx context.Context, workflowID, runID string) error
- func (m *MockClient) CheckHealth(ctx context.Context, request *client.CheckHealthRequest) (*client.CheckHealthResponse, error)
- func (m *MockClient) Close()
- func (m *MockClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error
- func (m *MockClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, ...) error
- func (m *MockClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
- func (m *MockClient) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)
- func (m *MockClient) DescribeTaskQueueEnhanced(ctx context.Context, options client.DescribeTaskQueueEnhancedOptions) (client.TaskQueueDescription, error)
- func (m *MockClient) DescribeWorkflowExecution(ctx context.Context, workflowID, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error)
- func (m *MockClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)
- func (m *MockClient) GetWorkerBuildIdCompatibility(ctx context.Context, options *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)
- func (m *MockClient) GetWorkerTaskReachability(ctx context.Context, options *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)
- func (m *MockClient) GetWorkerVersioningRules(ctx context.Context, options client.GetWorkerVersioningOptions) (*client.WorkerVersioningRules, error)
- func (m *MockClient) GetWorkflow(ctx context.Context, workflowID, runID string) client.WorkflowRun
- func (m *MockClient) GetWorkflowHistory(ctx context.Context, workflowID, runID string, isLongPoll bool, ...) client.HistoryEventIterator
- func (m *MockClient) GetWorkflowUpdateHandle(ref client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle
- func (m *MockClient) ListArchivedWorkflow(ctx context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
- func (m *MockClient) ListClosedWorkflow(ctx context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
- func (m *MockClient) ListOpenWorkflow(ctx context.Context, ...) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
- func (m *MockClient) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
- func (m *MockClient) OperatorService() operatorservice.OperatorServiceClient
- func (m *MockClient) QueryWorkflow(ctx context.Context, workflowID, runID, queryType string, args ...interface{}) (converter.EncodedValue, error)
- func (m *MockClient) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)
- func (m *MockClient) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error
- func (m *MockClient) RecordActivityHeartbeatByID(ctx context.Context, namespace, workflowID, runID, activityID string, ...) error
- func (m *MockClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
- func (m *MockClient) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
- func (m *MockClient) ScheduleClient() client.ScheduleClient
- func (m *MockClient) SignalWithStartWorkflow(ctx context.Context, workflowID, signalName string, signalArg interface{}, ...) (client.WorkflowRun, error)
- func (m *MockClient) SignalWorkflow(ctx context.Context, workflowID, runID, signalName string, arg interface{}) error
- func (m *MockClient) TerminateWorkflow(ctx context.Context, workflowID, runID, reason string, details ...interface{}) error
- func (m *MockClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error
- func (m *MockClient) UpdateWorkerVersioningRules(ctx context.Context, options client.UpdateWorkerVersioningRulesOptions) (*client.WorkerVersioningRules, error)
- func (m *MockClient) UpdateWorkflow(ctx context.Context, options client.UpdateWorkflowOptions) (client.WorkflowUpdateHandle, error)
- func (m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) CancelWorkflow(ctx, workflowID, runID interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CheckHealth(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Close() *gomock.Call
- func (mr *MockClientMockRecorder) CompleteActivity(ctx, taskToken, result, err interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CompleteActivityByID(ctx, namespace, workflowID, runID, activityID, result, err interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CountWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeTaskQueue(ctx, taskqueue, taskqueueType interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeTaskQueueEnhanced(ctx, options interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeWorkflowExecution(ctx, workflowID, runID interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ExecuteWorkflow(ctx, options, workflow interface{}, args ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetSearchAttributes(ctx interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, options interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkerTaskReachability(ctx, options interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkerVersioningRules(ctx, options interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkflow(ctx, workflowID, runID interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkflowHistory(ctx, workflowID, runID, isLongPoll, filterType interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkflowUpdateHandle(ref interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListArchivedWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListClosedWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListOpenWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) OperatorService() *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkflow(ctx, workflowID, runID, queryType interface{}, args ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkflowWithOptions(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordActivityHeartbeat(ctx, taskToken interface{}, details ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordActivityHeartbeatByID(ctx, namespace, workflowID, runID, activityID interface{}, ...) *gomock.Call
- func (mr *MockClientMockRecorder) ResetWorkflowExecution(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ScanWorkflow(ctx, request interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ScheduleClient() *gomock.Call
- func (mr *MockClientMockRecorder) SignalWithStartWorkflow(ctx, workflowID, signalName, signalArg, options, workflow interface{}, ...) *gomock.Call
- func (mr *MockClientMockRecorder) SignalWorkflow(ctx, workflowID, runID, signalName, arg interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) TerminateWorkflow(ctx, workflowID, runID, reason interface{}, details ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, options interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateWorkerVersioningRules(ctx, options interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateWorkflow(ctx, options interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) WorkflowService() *gomock.Call
- type MockCloudOperationsClient
- type MockCloudOperationsClientMockRecorder
- type MockDataConverter
- func (m *MockDataConverter) EXPECT() *MockDataConverterMockRecorder
- func (m *MockDataConverter) FromPayload(payload *common.Payload, valuePtr interface{}) error
- func (m *MockDataConverter) FromPayloads(payloads *common.Payloads, valuePtrs ...interface{}) error
- func (m *MockDataConverter) ToPayload(value interface{}) (*common.Payload, error)
- func (m *MockDataConverter) ToPayloads(value ...interface{}) (*common.Payloads, error)
- func (m *MockDataConverter) ToString(input *common.Payload) string
- func (m *MockDataConverter) ToStrings(input *common.Payloads) []string
- type MockDataConverterMockRecorder
- func (mr *MockDataConverterMockRecorder) FromPayload(payload, valuePtr interface{}) *gomock.Call
- func (mr *MockDataConverterMockRecorder) FromPayloads(payloads interface{}, valuePtrs ...interface{}) *gomock.Call
- func (mr *MockDataConverterMockRecorder) ToPayload(value interface{}) *gomock.Call
- func (mr *MockDataConverterMockRecorder) ToPayloads(value ...interface{}) *gomock.Call
- func (mr *MockDataConverterMockRecorder) ToString(input interface{}) *gomock.Call
- func (mr *MockDataConverterMockRecorder) ToStrings(input interface{}) *gomock.Call
- type MockNamespaceClient
- func (m *MockNamespaceClient) Close()
- func (m *MockNamespaceClient) Describe(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error)
- func (m *MockNamespaceClient) EXPECT() *MockNamespaceClientMockRecorder
- func (m *MockNamespaceClient) Register(ctx context.Context, request *workflowservice.RegisterNamespaceRequest) error
- func (m *MockNamespaceClient) Update(ctx context.Context, request *workflowservice.UpdateNamespaceRequest) error
- type MockNamespaceClientMockRecorder
- func (mr *MockNamespaceClientMockRecorder) Close() *gomock.Call
- func (mr *MockNamespaceClientMockRecorder) Describe(ctx, name interface{}) *gomock.Call
- func (mr *MockNamespaceClientMockRecorder) Register(ctx, request interface{}) *gomock.Call
- func (mr *MockNamespaceClientMockRecorder) Update(ctx, request interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTemporalClient ¶
func NewTemporalClient( tClient client.Client, namespace string, dataConverter converter.DataConverter, memoEncryption bool, ) uclient.UnifiedClient
Types ¶
type MockClient ¶ added in v1.10.0
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶ added in v1.10.0
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) CancelWorkflow ¶ added in v1.10.0
func (m *MockClient) CancelWorkflow(ctx context.Context, workflowID, runID string) error
CancelWorkflow mocks base method.
func (*MockClient) CheckHealth ¶ added in v1.10.0
func (m *MockClient) CheckHealth(ctx context.Context, request *client.CheckHealthRequest) (*client.CheckHealthResponse, error)
CheckHealth mocks base method.
func (*MockClient) CompleteActivity ¶ added in v1.10.0
func (m *MockClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error
CompleteActivity mocks base method.
func (*MockClient) CompleteActivityByID ¶ added in v1.10.0
func (m *MockClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, result interface{}, err error) error
CompleteActivityByID mocks base method.
func (*MockClient) CountWorkflow ¶ added in v1.10.0
func (m *MockClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
CountWorkflow mocks base method.
func (*MockClient) DescribeTaskQueue ¶ added in v1.10.0
func (m *MockClient) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue mocks base method.
func (*MockClient) DescribeTaskQueueEnhanced ¶ added in v1.11.0
func (m *MockClient) DescribeTaskQueueEnhanced(ctx context.Context, options client.DescribeTaskQueueEnhancedOptions) (client.TaskQueueDescription, error)
DescribeTaskQueueEnhanced mocks base method.
func (*MockClient) DescribeWorkflowExecution ¶ added in v1.10.0
func (m *MockClient) DescribeWorkflowExecution(ctx context.Context, workflowID, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockClient) EXPECT ¶ added in v1.10.0
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) ExecuteWorkflow ¶ added in v1.10.0
func (m *MockClient) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) (client.WorkflowRun, error)
ExecuteWorkflow mocks base method.
func (*MockClient) GetSearchAttributes ¶ added in v1.10.0
func (m *MockClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)
GetSearchAttributes mocks base method.
func (*MockClient) GetWorkerBuildIdCompatibility ¶ added in v1.10.0
func (m *MockClient) GetWorkerBuildIdCompatibility(ctx context.Context, options *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)
GetWorkerBuildIdCompatibility mocks base method.
func (*MockClient) GetWorkerTaskReachability ¶ added in v1.10.0
func (m *MockClient) GetWorkerTaskReachability(ctx context.Context, options *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)
GetWorkerTaskReachability mocks base method.
func (*MockClient) GetWorkerVersioningRules ¶ added in v1.11.0
func (m *MockClient) GetWorkerVersioningRules(ctx context.Context, options client.GetWorkerVersioningOptions) (*client.WorkerVersioningRules, error)
GetWorkerVersioningRules mocks base method.
func (*MockClient) GetWorkflow ¶ added in v1.10.0
func (m *MockClient) GetWorkflow(ctx context.Context, workflowID, runID string) client.WorkflowRun
GetWorkflow mocks base method.
func (*MockClient) GetWorkflowHistory ¶ added in v1.10.0
func (m *MockClient) GetWorkflowHistory(ctx context.Context, workflowID, runID string, isLongPoll bool, filterType enums.HistoryEventFilterType) client.HistoryEventIterator
GetWorkflowHistory mocks base method.
func (*MockClient) GetWorkflowUpdateHandle ¶ added in v1.10.0
func (m *MockClient) GetWorkflowUpdateHandle(ref client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle
GetWorkflowUpdateHandle mocks base method.
func (*MockClient) ListArchivedWorkflow ¶ added in v1.10.0
func (m *MockClient) ListArchivedWorkflow(ctx context.Context, request *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflow mocks base method.
func (*MockClient) ListClosedWorkflow ¶ added in v1.10.0
func (m *MockClient) ListClosedWorkflow(ctx context.Context, request *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflow mocks base method.
func (*MockClient) ListOpenWorkflow ¶ added in v1.10.0
func (m *MockClient) ListOpenWorkflow(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflow mocks base method.
func (*MockClient) ListWorkflow ¶ added in v1.10.0
func (m *MockClient) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
ListWorkflow mocks base method.
func (*MockClient) OperatorService ¶ added in v1.10.0
func (m *MockClient) OperatorService() operatorservice.OperatorServiceClient
OperatorService mocks base method.
func (*MockClient) QueryWorkflow ¶ added in v1.10.0
func (m *MockClient) QueryWorkflow(ctx context.Context, workflowID, runID, queryType string, args ...interface{}) (converter.EncodedValue, error)
QueryWorkflow mocks base method.
func (*MockClient) QueryWorkflowWithOptions ¶ added in v1.10.0
func (m *MockClient) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)
QueryWorkflowWithOptions mocks base method.
func (*MockClient) RecordActivityHeartbeat ¶ added in v1.10.0
func (m *MockClient) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error
RecordActivityHeartbeat mocks base method.
func (*MockClient) RecordActivityHeartbeatByID ¶ added in v1.10.0
func (m *MockClient) RecordActivityHeartbeatByID(ctx context.Context, namespace, workflowID, runID, activityID string, details ...interface{}) error
RecordActivityHeartbeatByID mocks base method.
func (*MockClient) ResetWorkflowExecution ¶ added in v1.10.0
func (m *MockClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method.
func (*MockClient) ScanWorkflow ¶ added in v1.10.0
func (m *MockClient) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
ScanWorkflow mocks base method.
func (*MockClient) ScheduleClient ¶ added in v1.10.0
func (m *MockClient) ScheduleClient() client.ScheduleClient
ScheduleClient mocks base method.
func (*MockClient) SignalWithStartWorkflow ¶ added in v1.10.0
func (m *MockClient) SignalWithStartWorkflow(ctx context.Context, workflowID, signalName string, signalArg interface{}, options client.StartWorkflowOptions, workflow interface{}, workflowArgs ...interface{}) (client.WorkflowRun, error)
SignalWithStartWorkflow mocks base method.
func (*MockClient) SignalWorkflow ¶ added in v1.10.0
func (m *MockClient) SignalWorkflow(ctx context.Context, workflowID, runID, signalName string, arg interface{}) error
SignalWorkflow mocks base method.
func (*MockClient) TerminateWorkflow ¶ added in v1.10.0
func (m *MockClient) TerminateWorkflow(ctx context.Context, workflowID, runID, reason string, details ...interface{}) error
TerminateWorkflow mocks base method.
func (*MockClient) UpdateWorkerBuildIdCompatibility ¶ added in v1.10.0
func (m *MockClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error
UpdateWorkerBuildIdCompatibility mocks base method.
func (*MockClient) UpdateWorkerVersioningRules ¶ added in v1.11.0
func (m *MockClient) UpdateWorkerVersioningRules(ctx context.Context, options client.UpdateWorkerVersioningRulesOptions) (*client.WorkerVersioningRules, error)
UpdateWorkerVersioningRules mocks base method.
func (*MockClient) UpdateWorkflow ¶ added in v1.10.0
func (m *MockClient) UpdateWorkflow(ctx context.Context, options client.UpdateWorkflowOptions) (client.WorkflowUpdateHandle, error)
UpdateWorkflow mocks base method.
func (*MockClient) WorkflowService ¶ added in v1.10.0
func (m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient
WorkflowService mocks base method.
type MockClientMockRecorder ¶ added in v1.10.0
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) CancelWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) CancelWorkflow(ctx, workflowID, runID interface{}) *gomock.Call
CancelWorkflow indicates an expected call of CancelWorkflow.
func (*MockClientMockRecorder) CheckHealth ¶ added in v1.10.0
func (mr *MockClientMockRecorder) CheckHealth(ctx, request interface{}) *gomock.Call
CheckHealth indicates an expected call of CheckHealth.
func (*MockClientMockRecorder) Close ¶ added in v1.10.0
func (mr *MockClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockClientMockRecorder) CompleteActivity ¶ added in v1.10.0
func (mr *MockClientMockRecorder) CompleteActivity(ctx, taskToken, result, err interface{}) *gomock.Call
CompleteActivity indicates an expected call of CompleteActivity.
func (*MockClientMockRecorder) CompleteActivityByID ¶ added in v1.10.0
func (mr *MockClientMockRecorder) CompleteActivityByID(ctx, namespace, workflowID, runID, activityID, result, err interface{}) *gomock.Call
CompleteActivityByID indicates an expected call of CompleteActivityByID.
func (*MockClientMockRecorder) CountWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) CountWorkflow(ctx, request interface{}) *gomock.Call
CountWorkflow indicates an expected call of CountWorkflow.
func (*MockClientMockRecorder) DescribeTaskQueue ¶ added in v1.10.0
func (mr *MockClientMockRecorder) DescribeTaskQueue(ctx, taskqueue, taskqueueType interface{}) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockClientMockRecorder) DescribeTaskQueueEnhanced ¶ added in v1.11.0
func (mr *MockClientMockRecorder) DescribeTaskQueueEnhanced(ctx, options interface{}) *gomock.Call
DescribeTaskQueueEnhanced indicates an expected call of DescribeTaskQueueEnhanced.
func (*MockClientMockRecorder) DescribeWorkflowExecution ¶ added in v1.10.0
func (mr *MockClientMockRecorder) DescribeWorkflowExecution(ctx, workflowID, runID interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockClientMockRecorder) ExecuteWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ExecuteWorkflow(ctx, options, workflow interface{}, args ...interface{}) *gomock.Call
ExecuteWorkflow indicates an expected call of ExecuteWorkflow.
func (*MockClientMockRecorder) GetSearchAttributes ¶ added in v1.10.0
func (mr *MockClientMockRecorder) GetSearchAttributes(ctx interface{}) *gomock.Call
GetSearchAttributes indicates an expected call of GetSearchAttributes.
func (*MockClientMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.10.0
func (mr *MockClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, options interface{}) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockClientMockRecorder) GetWorkerTaskReachability ¶ added in v1.10.0
func (mr *MockClientMockRecorder) GetWorkerTaskReachability(ctx, options interface{}) *gomock.Call
GetWorkerTaskReachability indicates an expected call of GetWorkerTaskReachability.
func (*MockClientMockRecorder) GetWorkerVersioningRules ¶ added in v1.11.0
func (mr *MockClientMockRecorder) GetWorkerVersioningRules(ctx, options interface{}) *gomock.Call
GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.
func (*MockClientMockRecorder) GetWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) GetWorkflow(ctx, workflowID, runID interface{}) *gomock.Call
GetWorkflow indicates an expected call of GetWorkflow.
func (*MockClientMockRecorder) GetWorkflowHistory ¶ added in v1.10.0
func (mr *MockClientMockRecorder) GetWorkflowHistory(ctx, workflowID, runID, isLongPoll, filterType interface{}) *gomock.Call
GetWorkflowHistory indicates an expected call of GetWorkflowHistory.
func (*MockClientMockRecorder) GetWorkflowUpdateHandle ¶ added in v1.10.0
func (mr *MockClientMockRecorder) GetWorkflowUpdateHandle(ref interface{}) *gomock.Call
GetWorkflowUpdateHandle indicates an expected call of GetWorkflowUpdateHandle.
func (*MockClientMockRecorder) ListArchivedWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ListArchivedWorkflow(ctx, request interface{}) *gomock.Call
ListArchivedWorkflow indicates an expected call of ListArchivedWorkflow.
func (*MockClientMockRecorder) ListClosedWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ListClosedWorkflow(ctx, request interface{}) *gomock.Call
ListClosedWorkflow indicates an expected call of ListClosedWorkflow.
func (*MockClientMockRecorder) ListOpenWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ListOpenWorkflow(ctx, request interface{}) *gomock.Call
ListOpenWorkflow indicates an expected call of ListOpenWorkflow.
func (*MockClientMockRecorder) ListWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ListWorkflow(ctx, request interface{}) *gomock.Call
ListWorkflow indicates an expected call of ListWorkflow.
func (*MockClientMockRecorder) OperatorService ¶ added in v1.10.0
func (mr *MockClientMockRecorder) OperatorService() *gomock.Call
OperatorService indicates an expected call of OperatorService.
func (*MockClientMockRecorder) QueryWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) QueryWorkflow(ctx, workflowID, runID, queryType interface{}, args ...interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockClientMockRecorder) QueryWorkflowWithOptions ¶ added in v1.10.0
func (mr *MockClientMockRecorder) QueryWorkflowWithOptions(ctx, request interface{}) *gomock.Call
QueryWorkflowWithOptions indicates an expected call of QueryWorkflowWithOptions.
func (*MockClientMockRecorder) RecordActivityHeartbeat ¶ added in v1.10.0
func (mr *MockClientMockRecorder) RecordActivityHeartbeat(ctx, taskToken interface{}, details ...interface{}) *gomock.Call
RecordActivityHeartbeat indicates an expected call of RecordActivityHeartbeat.
func (*MockClientMockRecorder) RecordActivityHeartbeatByID ¶ added in v1.10.0
func (mr *MockClientMockRecorder) RecordActivityHeartbeatByID(ctx, namespace, workflowID, runID, activityID interface{}, details ...interface{}) *gomock.Call
RecordActivityHeartbeatByID indicates an expected call of RecordActivityHeartbeatByID.
func (*MockClientMockRecorder) ResetWorkflowExecution ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ResetWorkflowExecution(ctx, request interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (*MockClientMockRecorder) ScanWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ScanWorkflow(ctx, request interface{}) *gomock.Call
ScanWorkflow indicates an expected call of ScanWorkflow.
func (*MockClientMockRecorder) ScheduleClient ¶ added in v1.10.0
func (mr *MockClientMockRecorder) ScheduleClient() *gomock.Call
ScheduleClient indicates an expected call of ScheduleClient.
func (*MockClientMockRecorder) SignalWithStartWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) SignalWithStartWorkflow(ctx, workflowID, signalName, signalArg, options, workflow interface{}, workflowArgs ...interface{}) *gomock.Call
SignalWithStartWorkflow indicates an expected call of SignalWithStartWorkflow.
func (*MockClientMockRecorder) SignalWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) SignalWorkflow(ctx, workflowID, runID, signalName, arg interface{}) *gomock.Call
SignalWorkflow indicates an expected call of SignalWorkflow.
func (*MockClientMockRecorder) TerminateWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) TerminateWorkflow(ctx, workflowID, runID, reason interface{}, details ...interface{}) *gomock.Call
TerminateWorkflow indicates an expected call of TerminateWorkflow.
func (*MockClientMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.10.0
func (mr *MockClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, options interface{}) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
func (*MockClientMockRecorder) UpdateWorkerVersioningRules ¶ added in v1.11.0
func (mr *MockClientMockRecorder) UpdateWorkerVersioningRules(ctx, options interface{}) *gomock.Call
UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.
func (*MockClientMockRecorder) UpdateWorkflow ¶ added in v1.10.0
func (mr *MockClientMockRecorder) UpdateWorkflow(ctx, options interface{}) *gomock.Call
UpdateWorkflow indicates an expected call of UpdateWorkflow.
func (*MockClientMockRecorder) WorkflowService ¶ added in v1.10.0
func (mr *MockClientMockRecorder) WorkflowService() *gomock.Call
WorkflowService indicates an expected call of WorkflowService.
type MockCloudOperationsClient ¶ added in v1.11.0
type MockCloudOperationsClient struct {
// contains filtered or unexported fields
}
MockCloudOperationsClient is a mock of CloudOperationsClient interface.
func NewMockCloudOperationsClient ¶ added in v1.11.0
func NewMockCloudOperationsClient(ctrl *gomock.Controller) *MockCloudOperationsClient
NewMockCloudOperationsClient creates a new mock instance.
func (*MockCloudOperationsClient) Close ¶ added in v1.11.0
func (m *MockCloudOperationsClient) Close()
Close mocks base method.
func (*MockCloudOperationsClient) CloudService ¶ added in v1.11.0
func (m *MockCloudOperationsClient) CloudService() cloudservice.CloudServiceClient
CloudService mocks base method.
func (*MockCloudOperationsClient) EXPECT ¶ added in v1.11.0
func (m *MockCloudOperationsClient) EXPECT() *MockCloudOperationsClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockCloudOperationsClientMockRecorder ¶ added in v1.11.0
type MockCloudOperationsClientMockRecorder struct {
// contains filtered or unexported fields
}
MockCloudOperationsClientMockRecorder is the mock recorder for MockCloudOperationsClient.
func (*MockCloudOperationsClientMockRecorder) Close ¶ added in v1.11.0
func (mr *MockCloudOperationsClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockCloudOperationsClientMockRecorder) CloudService ¶ added in v1.11.0
func (mr *MockCloudOperationsClientMockRecorder) CloudService() *gomock.Call
CloudService indicates an expected call of CloudService.
type MockDataConverter ¶ added in v1.10.0
type MockDataConverter struct {
// contains filtered or unexported fields
}
MockDataConverter is a mock of DataConverter interface.
func NewMockDataConverter ¶ added in v1.10.0
func NewMockDataConverter(ctrl *gomock.Controller) *MockDataConverter
NewMockDataConverter creates a new mock instance.
func (*MockDataConverter) EXPECT ¶ added in v1.10.0
func (m *MockDataConverter) EXPECT() *MockDataConverterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDataConverter) FromPayload ¶ added in v1.10.0
func (m *MockDataConverter) FromPayload(payload *common.Payload, valuePtr interface{}) error
FromPayload mocks base method.
func (*MockDataConverter) FromPayloads ¶ added in v1.10.0
func (m *MockDataConverter) FromPayloads(payloads *common.Payloads, valuePtrs ...interface{}) error
FromPayloads mocks base method.
func (*MockDataConverter) ToPayload ¶ added in v1.10.0
func (m *MockDataConverter) ToPayload(value interface{}) (*common.Payload, error)
ToPayload mocks base method.
func (*MockDataConverter) ToPayloads ¶ added in v1.10.0
func (m *MockDataConverter) ToPayloads(value ...interface{}) (*common.Payloads, error)
ToPayloads mocks base method.
type MockDataConverterMockRecorder ¶ added in v1.10.0
type MockDataConverterMockRecorder struct {
// contains filtered or unexported fields
}
MockDataConverterMockRecorder is the mock recorder for MockDataConverter.
func (*MockDataConverterMockRecorder) FromPayload ¶ added in v1.10.0
func (mr *MockDataConverterMockRecorder) FromPayload(payload, valuePtr interface{}) *gomock.Call
FromPayload indicates an expected call of FromPayload.
func (*MockDataConverterMockRecorder) FromPayloads ¶ added in v1.10.0
func (mr *MockDataConverterMockRecorder) FromPayloads(payloads interface{}, valuePtrs ...interface{}) *gomock.Call
FromPayloads indicates an expected call of FromPayloads.
func (*MockDataConverterMockRecorder) ToPayload ¶ added in v1.10.0
func (mr *MockDataConverterMockRecorder) ToPayload(value interface{}) *gomock.Call
ToPayload indicates an expected call of ToPayload.
func (*MockDataConverterMockRecorder) ToPayloads ¶ added in v1.10.0
func (mr *MockDataConverterMockRecorder) ToPayloads(value ...interface{}) *gomock.Call
ToPayloads indicates an expected call of ToPayloads.
func (*MockDataConverterMockRecorder) ToString ¶ added in v1.10.0
func (mr *MockDataConverterMockRecorder) ToString(input interface{}) *gomock.Call
ToString indicates an expected call of ToString.
func (*MockDataConverterMockRecorder) ToStrings ¶ added in v1.10.0
func (mr *MockDataConverterMockRecorder) ToStrings(input interface{}) *gomock.Call
ToStrings indicates an expected call of ToStrings.
type MockNamespaceClient ¶ added in v1.10.0
type MockNamespaceClient struct {
// contains filtered or unexported fields
}
MockNamespaceClient is a mock of NamespaceClient interface.
func NewMockNamespaceClient ¶ added in v1.10.0
func NewMockNamespaceClient(ctrl *gomock.Controller) *MockNamespaceClient
NewMockNamespaceClient creates a new mock instance.
func (*MockNamespaceClient) Close ¶ added in v1.10.0
func (m *MockNamespaceClient) Close()
Close mocks base method.
func (*MockNamespaceClient) Describe ¶ added in v1.10.0
func (m *MockNamespaceClient) Describe(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error)
Describe mocks base method.
func (*MockNamespaceClient) EXPECT ¶ added in v1.10.0
func (m *MockNamespaceClient) EXPECT() *MockNamespaceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockNamespaceClient) Register ¶ added in v1.10.0
func (m *MockNamespaceClient) Register(ctx context.Context, request *workflowservice.RegisterNamespaceRequest) error
Register mocks base method.
func (*MockNamespaceClient) Update ¶ added in v1.10.0
func (m *MockNamespaceClient) Update(ctx context.Context, request *workflowservice.UpdateNamespaceRequest) error
Update mocks base method.
type MockNamespaceClientMockRecorder ¶ added in v1.10.0
type MockNamespaceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockNamespaceClientMockRecorder is the mock recorder for MockNamespaceClient.
func (*MockNamespaceClientMockRecorder) Close ¶ added in v1.10.0
func (mr *MockNamespaceClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockNamespaceClientMockRecorder) Describe ¶ added in v1.10.0
func (mr *MockNamespaceClientMockRecorder) Describe(ctx, name interface{}) *gomock.Call
Describe indicates an expected call of Describe.
func (*MockNamespaceClientMockRecorder) Register ¶ added in v1.10.0
func (mr *MockNamespaceClientMockRecorder) Register(ctx, request interface{}) *gomock.Call
Register indicates an expected call of Register.
func (*MockNamespaceClientMockRecorder) Update ¶ added in v1.10.0
func (mr *MockNamespaceClientMockRecorder) Update(ctx, request interface{}) *gomock.Call
Update indicates an expected call of Update.