temporal

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2025 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Overview

Package temporal is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AsyncActivityHeartbeat 

func AsyncActivityHeartbeat(ctx context.Context, timeout time.Duration)

AsyncActivityHeartbeat will start a goroutine that will send a heartbeat every timeout until the context is done.

Types

type Client 

type Client interface {
	temporalclient.Client
}

Client is the client interface from temporal library.

type MockClient 

type MockClient struct {
	// contains filtered or unexported fields
}

MockClient is a mock of Client interface.

func NewMockClient 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) CancelWorkflow 

func (m *MockClient) CancelWorkflow(ctx context.Context, workflowID, runID string) error

CancelWorkflow mocks base method.

func (*MockClient) CheckHealth 

func (m *MockClient) CheckHealth(ctx context.Context, request *client.CheckHealthRequest) (*client.CheckHealthResponse, error)

CheckHealth mocks base method.

func (*MockClient) Close 

func (m *MockClient) Close()

Close mocks base method.

func (*MockClient) CompleteActivity 

func (m *MockClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error

CompleteActivity mocks base method.

func (*MockClient) CompleteActivityByID 

func (m *MockClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, result interface{}, err error) error

CompleteActivityByID mocks base method.

func (*MockClient) CountWorkflow 

func (m *MockClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)

CountWorkflow mocks base method.

func (*MockClient) DeploymentClient 

func (m *MockClient) DeploymentClient() client.DeploymentClient

DeploymentClient mocks base method.

func (*MockClient) DescribeTaskQueue 

func (m *MockClient) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

DescribeTaskQueue mocks base method.

func (*MockClient) DescribeTaskQueueEnhanced 

func (m *MockClient) DescribeTaskQueueEnhanced(ctx context.Context, options client.DescribeTaskQueueEnhancedOptions) (client.TaskQueueDescription, error)

DescribeTaskQueueEnhanced mocks base method.

func (*MockClient) DescribeWorkflowExecution 

func (m *MockClient) DescribeWorkflowExecution(ctx context.Context, workflowID, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution mocks base method.

func (*MockClient) EXPECT 

func (m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) ExecuteWorkflow 

func (m *MockClient) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) (client.WorkflowRun, error)

ExecuteWorkflow mocks base method.

func (*MockClient) GetSearchAttributes 

func (m *MockClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)

GetSearchAttributes mocks base method.

func (*MockClient) GetWorkerBuildIdCompatibility 

func (m *MockClient) GetWorkerBuildIdCompatibility(ctx context.Context, options *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)

GetWorkerBuildIdCompatibility mocks base method.

func (*MockClient) GetWorkerTaskReachability 

func (m *MockClient) GetWorkerTaskReachability(ctx context.Context, options *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)

GetWorkerTaskReachability mocks base method.

func (*MockClient) GetWorkerVersioningRules 

func (m *MockClient) GetWorkerVersioningRules(ctx context.Context, options client.GetWorkerVersioningOptions) (*client.WorkerVersioningRules, error)

GetWorkerVersioningRules mocks base method.

func (*MockClient) GetWorkflow 

func (m *MockClient) GetWorkflow(ctx context.Context, workflowID, runID string) client.WorkflowRun

GetWorkflow mocks base method.

func (*MockClient) GetWorkflowHistory 

func (m *MockClient) GetWorkflowHistory(ctx context.Context, workflowID, runID string, isLongPoll bool, filterType enums.HistoryEventFilterType) client.HistoryEventIterator

GetWorkflowHistory mocks base method.

func (*MockClient) GetWorkflowUpdateHandle 

func (m *MockClient) GetWorkflowUpdateHandle(ref client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle

GetWorkflowUpdateHandle mocks base method.

func (*MockClient) ListArchivedWorkflow 

func (m *MockClient) ListArchivedWorkflow(ctx context.Context, request *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)

ListArchivedWorkflow mocks base method.

func (*MockClient) ListClosedWorkflow 

func (m *MockClient) ListClosedWorkflow(ctx context.Context, request *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)

ListClosedWorkflow mocks base method.

func (*MockClient) ListOpenWorkflow 

func (m *MockClient) ListOpenWorkflow(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)

ListOpenWorkflow mocks base method.

func (*MockClient) ListWorkflow 

func (m *MockClient) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)

ListWorkflow mocks base method.

func (*MockClient) NewWithStartWorkflowOperation 

func (m *MockClient) NewWithStartWorkflowOperation(options client.StartWorkflowOptions, workflow interface{}, args ...interface{}) client.WithStartWorkflowOperation

NewWithStartWorkflowOperation mocks base method.

func (*MockClient) OperatorService 

func (m *MockClient) OperatorService() operatorservice.OperatorServiceClient

OperatorService mocks base method.

func (*MockClient) QueryWorkflow 

func (m *MockClient) QueryWorkflow(ctx context.Context, workflowID, runID, queryType string, args ...interface{}) (converter.EncodedValue, error)

QueryWorkflow mocks base method.

func (*MockClient) QueryWorkflowWithOptions 

func (m *MockClient) QueryWorkflowWithOptions(ctx context.Context, request *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)

QueryWorkflowWithOptions mocks base method.

func (*MockClient) RecordActivityHeartbeat 

func (m *MockClient) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error

RecordActivityHeartbeat mocks base method.

func (*MockClient) RecordActivityHeartbeatByID 

func (m *MockClient) RecordActivityHeartbeatByID(ctx context.Context, namespace, workflowID, runID, activityID string, details ...interface{}) error

RecordActivityHeartbeatByID mocks base method.

func (*MockClient) ResetWorkflowExecution 

func (m *MockClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method.

func (*MockClient) ScanWorkflow 

func (m *MockClient) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)

ScanWorkflow mocks base method.

func (*MockClient) ScheduleClient 

func (m *MockClient) ScheduleClient() client.ScheduleClient

ScheduleClient mocks base method.

func (*MockClient) SignalWithStartWorkflow 

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 

func (m *MockClient) SignalWorkflow(ctx context.Context, workflowID, runID, signalName string, arg interface{}) error

SignalWorkflow mocks base method.

func (*MockClient) TerminateWorkflow 

func (m *MockClient) TerminateWorkflow(ctx context.Context, workflowID, runID, reason string, details ...interface{}) error

TerminateWorkflow mocks base method.

func (*MockClient) UpdateWithStartWorkflow 

func (m *MockClient) UpdateWithStartWorkflow(ctx context.Context, options client.UpdateWithStartWorkflowOptions) (client.WorkflowUpdateHandle, error)

UpdateWithStartWorkflow mocks base method.

func (*MockClient) UpdateWorkerBuildIdCompatibility 

func (m *MockClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *client.UpdateWorkerBuildIdCompatibilityOptions) error

UpdateWorkerBuildIdCompatibility mocks base method.

func (*MockClient) UpdateWorkerVersioningRules 

func (m *MockClient) UpdateWorkerVersioningRules(ctx context.Context, options client.UpdateWorkerVersioningRulesOptions) (*client.WorkerVersioningRules, error)

UpdateWorkerVersioningRules mocks base method.

func (*MockClient) UpdateWorkflow 

func (m *MockClient) UpdateWorkflow(ctx context.Context, options client.UpdateWorkflowOptions) (client.WorkflowUpdateHandle, error)

UpdateWorkflow mocks base method.

func (*MockClient) UpdateWorkflowExecutionOptions 

func (m *MockClient) UpdateWorkflowExecutionOptions(ctx context.Context, options client.UpdateWorkflowExecutionOptionsRequest) (client.WorkflowExecutionOptions, error)

UpdateWorkflowExecutionOptions mocks base method.

func (*MockClient) WorkerDeploymentClient 

func (m *MockClient) WorkerDeploymentClient() client.WorkerDeploymentClient

WorkerDeploymentClient mocks base method.

func (*MockClient) WorkflowService 

func (m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient

WorkflowService mocks base method.

type MockClientMockRecorder 

type MockClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) CancelWorkflow 

func (mr *MockClientMockRecorder) CancelWorkflow(ctx, workflowID, runID interface{}) *gomock.Call

CancelWorkflow indicates an expected call of CancelWorkflow.

func (*MockClientMockRecorder) CheckHealth 

func (mr *MockClientMockRecorder) CheckHealth(ctx, request interface{}) *gomock.Call

CheckHealth indicates an expected call of CheckHealth.

func (*MockClientMockRecorder) Close 

func (mr *MockClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockClientMockRecorder) CompleteActivity 

func (mr *MockClientMockRecorder) CompleteActivity(ctx, taskToken, result, err interface{}) *gomock.Call

CompleteActivity indicates an expected call of CompleteActivity.

func (*MockClientMockRecorder) CompleteActivityByID 

func (mr *MockClientMockRecorder) CompleteActivityByID(ctx, namespace, workflowID, runID, activityID, result, err interface{}) *gomock.Call

CompleteActivityByID indicates an expected call of CompleteActivityByID.

func (*MockClientMockRecorder) CountWorkflow 

func (mr *MockClientMockRecorder) CountWorkflow(ctx, request interface{}) *gomock.Call

CountWorkflow indicates an expected call of CountWorkflow.

func (*MockClientMockRecorder) DeploymentClient 

func (mr *MockClientMockRecorder) DeploymentClient() *gomock.Call

DeploymentClient indicates an expected call of DeploymentClient.

func (*MockClientMockRecorder) DescribeTaskQueue 

func (mr *MockClientMockRecorder) DescribeTaskQueue(ctx, taskqueue, taskqueueType interface{}) *gomock.Call

DescribeTaskQueue indicates an expected call of DescribeTaskQueue.

func (*MockClientMockRecorder) DescribeTaskQueueEnhanced 

func (mr *MockClientMockRecorder) DescribeTaskQueueEnhanced(ctx, options interface{}) *gomock.Call

DescribeTaskQueueEnhanced indicates an expected call of DescribeTaskQueueEnhanced.

func (*MockClientMockRecorder) DescribeWorkflowExecution 

func (mr *MockClientMockRecorder) DescribeWorkflowExecution(ctx, workflowID, runID interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockClientMockRecorder) ExecuteWorkflow 

func (mr *MockClientMockRecorder) ExecuteWorkflow(ctx, options, workflow interface{}, args ...interface{}) *gomock.Call

ExecuteWorkflow indicates an expected call of ExecuteWorkflow.

func (*MockClientMockRecorder) GetSearchAttributes 

func (mr *MockClientMockRecorder) GetSearchAttributes(ctx interface{}) *gomock.Call

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockClientMockRecorder) GetWorkerBuildIdCompatibility 

func (mr *MockClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, options interface{}) *gomock.Call

GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.

func (*MockClientMockRecorder) GetWorkerTaskReachability 

func (mr *MockClientMockRecorder) GetWorkerTaskReachability(ctx, options interface{}) *gomock.Call

GetWorkerTaskReachability indicates an expected call of GetWorkerTaskReachability.

func (*MockClientMockRecorder) GetWorkerVersioningRules 

func (mr *MockClientMockRecorder) GetWorkerVersioningRules(ctx, options interface{}) *gomock.Call

GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.

func (*MockClientMockRecorder) GetWorkflow 

func (mr *MockClientMockRecorder) GetWorkflow(ctx, workflowID, runID interface{}) *gomock.Call

GetWorkflow indicates an expected call of GetWorkflow.

func (*MockClientMockRecorder) GetWorkflowHistory 

func (mr *MockClientMockRecorder) GetWorkflowHistory(ctx, workflowID, runID, isLongPoll, filterType interface{}) *gomock.Call

GetWorkflowHistory indicates an expected call of GetWorkflowHistory.

func (*MockClientMockRecorder) GetWorkflowUpdateHandle 

func (mr *MockClientMockRecorder) GetWorkflowUpdateHandle(ref interface{}) *gomock.Call

GetWorkflowUpdateHandle indicates an expected call of GetWorkflowUpdateHandle.

func (*MockClientMockRecorder) ListArchivedWorkflow 

func (mr *MockClientMockRecorder) ListArchivedWorkflow(ctx, request interface{}) *gomock.Call

ListArchivedWorkflow indicates an expected call of ListArchivedWorkflow.

func (*MockClientMockRecorder) ListClosedWorkflow 

func (mr *MockClientMockRecorder) ListClosedWorkflow(ctx, request interface{}) *gomock.Call

ListClosedWorkflow indicates an expected call of ListClosedWorkflow.

func (*MockClientMockRecorder) ListOpenWorkflow 

func (mr *MockClientMockRecorder) ListOpenWorkflow(ctx, request interface{}) *gomock.Call

ListOpenWorkflow indicates an expected call of ListOpenWorkflow.

func (*MockClientMockRecorder) ListWorkflow 

func (mr *MockClientMockRecorder) ListWorkflow(ctx, request interface{}) *gomock.Call

ListWorkflow indicates an expected call of ListWorkflow.

func (*MockClientMockRecorder) NewWithStartWorkflowOperation 

func (mr *MockClientMockRecorder) NewWithStartWorkflowOperation(options, workflow interface{}, args ...interface{}) *gomock.Call

NewWithStartWorkflowOperation indicates an expected call of NewWithStartWorkflowOperation.

func (*MockClientMockRecorder) OperatorService 

func (mr *MockClientMockRecorder) OperatorService() *gomock.Call

OperatorService indicates an expected call of OperatorService.

func (*MockClientMockRecorder) QueryWorkflow 

func (mr *MockClientMockRecorder) QueryWorkflow(ctx, workflowID, runID, queryType interface{}, args ...interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockClientMockRecorder) QueryWorkflowWithOptions 

func (mr *MockClientMockRecorder) QueryWorkflowWithOptions(ctx, request interface{}) *gomock.Call

QueryWorkflowWithOptions indicates an expected call of QueryWorkflowWithOptions.

func (*MockClientMockRecorder) RecordActivityHeartbeat 

func (mr *MockClientMockRecorder) RecordActivityHeartbeat(ctx, taskToken interface{}, details ...interface{}) *gomock.Call

RecordActivityHeartbeat indicates an expected call of RecordActivityHeartbeat.

func (*MockClientMockRecorder) RecordActivityHeartbeatByID 

func (mr *MockClientMockRecorder) RecordActivityHeartbeatByID(ctx, namespace, workflowID, runID, activityID interface{}, details ...interface{}) *gomock.Call

RecordActivityHeartbeatByID indicates an expected call of RecordActivityHeartbeatByID.

func (*MockClientMockRecorder) ResetWorkflowExecution 

func (mr *MockClientMockRecorder) ResetWorkflowExecution(ctx, request interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockClientMockRecorder) ScanWorkflow 

func (mr *MockClientMockRecorder) ScanWorkflow(ctx, request interface{}) *gomock.Call

ScanWorkflow indicates an expected call of ScanWorkflow.

func (*MockClientMockRecorder) ScheduleClient 

func (mr *MockClientMockRecorder) ScheduleClient() *gomock.Call

ScheduleClient indicates an expected call of ScheduleClient.

func (*MockClientMockRecorder) SignalWithStartWorkflow 

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 

func (mr *MockClientMockRecorder) SignalWorkflow(ctx, workflowID, runID, signalName, arg interface{}) *gomock.Call

SignalWorkflow indicates an expected call of SignalWorkflow.

func (*MockClientMockRecorder) TerminateWorkflow 

func (mr *MockClientMockRecorder) TerminateWorkflow(ctx, workflowID, runID, reason interface{}, details ...interface{}) *gomock.Call

TerminateWorkflow indicates an expected call of TerminateWorkflow.

func (*MockClientMockRecorder) UpdateWithStartWorkflow 

func (mr *MockClientMockRecorder) UpdateWithStartWorkflow(ctx, options interface{}) *gomock.Call

UpdateWithStartWorkflow indicates an expected call of UpdateWithStartWorkflow.

func (*MockClientMockRecorder) UpdateWorkerBuildIdCompatibility 

func (mr *MockClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, options interface{}) *gomock.Call

UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.

func (*MockClientMockRecorder) UpdateWorkerVersioningRules 

func (mr *MockClientMockRecorder) UpdateWorkerVersioningRules(ctx, options interface{}) *gomock.Call

UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.

func (*MockClientMockRecorder) UpdateWorkflow 

func (mr *MockClientMockRecorder) UpdateWorkflow(ctx, options interface{}) *gomock.Call

UpdateWorkflow indicates an expected call of UpdateWorkflow.

func (*MockClientMockRecorder) UpdateWorkflowExecutionOptions 

func (mr *MockClientMockRecorder) UpdateWorkflowExecutionOptions(ctx, options interface{}) *gomock.Call

UpdateWorkflowExecutionOptions indicates an expected call of UpdateWorkflowExecutionOptions.

func (*MockClientMockRecorder) WorkerDeploymentClient 

func (mr *MockClientMockRecorder) WorkerDeploymentClient() *gomock.Call

WorkerDeploymentClient indicates an expected call of WorkerDeploymentClient.

func (*MockClientMockRecorder) WorkflowService 

func (mr *MockClientMockRecorder) WorkflowService() *gomock.Call

WorkflowService indicates an expected call of WorkflowService.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.