temporal

package
v1.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 4, 2024 License: MIT Imports: 24 Imported by: 0

Documentation

Overview

Package temporal is a generated GoMock package.

Package temporal is a generated GoMock package.

Index

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

CheckHealth mocks base method.

func (*MockClient) Close added in v1.10.0

func (m *MockClient) Close()

Close 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

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

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

GetWorkflowUpdateHandle mocks base method.

func (*MockClient) ListArchivedWorkflow added in v1.10.0

ListArchivedWorkflow mocks base method.

func (*MockClient) ListClosedWorkflow added in v1.10.0

ListClosedWorkflow mocks base method.

func (*MockClient) ListOpenWorkflow added in v1.10.0

ListOpenWorkflow mocks base method.

func (*MockClient) ListWorkflow added in v1.10.0

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

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

ResetWorkflowExecution mocks base method.

func (*MockClient) ScanWorkflow added in v1.10.0

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

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

CloudService mocks base method.

func (*MockCloudOperationsClient) EXPECT added in v1.11.0

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

Close indicates an expected call of Close.

func (*MockCloudOperationsClientMockRecorder) CloudService added in v1.11.0

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

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.

func (*MockDataConverter) ToString added in v1.10.0

func (m *MockDataConverter) ToString(input *common.Payload) string

ToString mocks base method.

func (*MockDataConverter) ToStrings added in v1.10.0

func (m *MockDataConverter) ToStrings(input *common.Payloads) []string

ToStrings 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

Describe mocks base method.

func (*MockNamespaceClient) EXPECT added in v1.10.0

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNamespaceClient) Register added in v1.10.0

Register mocks base method.

func (*MockNamespaceClient) Update added in v1.10.0

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL