mocksdk

package
v1.30.1 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Package mocksdk is a generated GoMock package.

Package mocksdk is a generated GoMock package.

Package mocksdk is a generated GoMock package.

Package mocksdk is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 any, err error) error

CompleteActivity mocks base method.

func (*MockClient) CompleteActivityByID 

func (m *MockClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, result any, 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 added in v1.27.0 

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 added in v1.25.0 

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

DescribeTaskQueueEnhanced mocks base method.

func (*MockClient) DescribeWorkflow added in v1.29.0 

func (m *MockClient) DescribeWorkflow(ctx context.Context, workflowID, runID string) (*client.WorkflowExecutionDescription, error)

DescribeWorkflow 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 any, args ...any) (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 added in v1.21.0 

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

GetWorkerBuildIdCompatibility mocks base method.

func (*MockClient) GetWorkerTaskReachability added in v1.22.2 

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

GetWorkerTaskReachability mocks base method.

func (*MockClient) GetWorkerVersioningRules added in v1.25.0 

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 added in v1.21.0 

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 added in v1.26.2 

func (m *MockClient) NewWithStartWorkflowOperation(options client.StartWorkflowOptions, workflow any, args ...any) client.WithStartWorkflowOperation

NewWithStartWorkflowOperation mocks base method.

func (*MockClient) OperatorService added in v1.18.0 

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 ...any) (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 ...any) error

RecordActivityHeartbeat mocks base method.

func (*MockClient) RecordActivityHeartbeatByID 

func (m *MockClient) RecordActivityHeartbeatByID(ctx context.Context, namespace, workflowID, runID, activityID string, details ...any) 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 added in v1.19.0 

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

ScheduleClient mocks base method.

func (*MockClient) SignalWithStartWorkflow 

func (m *MockClient) SignalWithStartWorkflow(ctx context.Context, workflowID, signalName string, signalArg any, options client.StartWorkflowOptions, workflow any, workflowArgs ...any) (client.WorkflowRun, error)

SignalWithStartWorkflow mocks base method.

func (*MockClient) SignalWorkflow 

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

SignalWorkflow mocks base method.

func (*MockClient) TerminateWorkflow 

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

TerminateWorkflow mocks base method.

func (*MockClient) UpdateWithStartWorkflow added in v1.26.2 

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

UpdateWithStartWorkflow mocks base method.

func (*MockClient) UpdateWorkerBuildIdCompatibility added in v1.21.0 

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

UpdateWorkerBuildIdCompatibility mocks base method.

func (*MockClient) UpdateWorkerVersioningRules added in v1.25.0 

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

UpdateWorkerVersioningRules mocks base method.

func (*MockClient) UpdateWorkflow added in v1.20.0 

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

UpdateWorkflow mocks base method.

func (*MockClient) UpdateWorkflowExecutionOptions added in v1.27.0 

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

UpdateWorkflowExecutionOptions mocks base method.

func (*MockClient) WorkerDeploymentClient added in v1.27.2 

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 any) *gomock.Call

CancelWorkflow indicates an expected call of CancelWorkflow.

func (*MockClientMockRecorder) CheckHealth 

func (mr *MockClientMockRecorder) CheckHealth(ctx, request any) *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 any) *gomock.Call

CompleteActivity indicates an expected call of CompleteActivity.

func (*MockClientMockRecorder) CompleteActivityByID 

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

CompleteActivityByID indicates an expected call of CompleteActivityByID.

func (*MockClientMockRecorder) CountWorkflow 

func (mr *MockClientMockRecorder) CountWorkflow(ctx, request any) *gomock.Call

CountWorkflow indicates an expected call of CountWorkflow.

func (*MockClientMockRecorder) DeploymentClient added in v1.27.0 

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

DeploymentClient indicates an expected call of DeploymentClient.

func (*MockClientMockRecorder) DescribeTaskQueue 

func (mr *MockClientMockRecorder) DescribeTaskQueue(ctx, taskqueue, taskqueueType any) *gomock.Call

DescribeTaskQueue indicates an expected call of DescribeTaskQueue.

func (*MockClientMockRecorder) DescribeTaskQueueEnhanced added in v1.25.0 

func (mr *MockClientMockRecorder) DescribeTaskQueueEnhanced(ctx, options any) *gomock.Call

DescribeTaskQueueEnhanced indicates an expected call of DescribeTaskQueueEnhanced.

func (*MockClientMockRecorder) DescribeWorkflow added in v1.29.0 

func (mr *MockClientMockRecorder) DescribeWorkflow(ctx, workflowID, runID any) *gomock.Call

DescribeWorkflow indicates an expected call of DescribeWorkflow.

func (*MockClientMockRecorder) DescribeWorkflowExecution 

func (mr *MockClientMockRecorder) DescribeWorkflowExecution(ctx, workflowID, runID any) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockClientMockRecorder) ExecuteWorkflow 

func (mr *MockClientMockRecorder) ExecuteWorkflow(ctx, options, workflow any, args ...any) *gomock.Call

ExecuteWorkflow indicates an expected call of ExecuteWorkflow.

func (*MockClientMockRecorder) GetSearchAttributes 

func (mr *MockClientMockRecorder) GetSearchAttributes(ctx any) *gomock.Call

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockClientMockRecorder) GetWorkerBuildIdCompatibility added in v1.21.0 

func (mr *MockClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, options any) *gomock.Call

GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.

func (*MockClientMockRecorder) GetWorkerTaskReachability added in v1.22.2 

func (mr *MockClientMockRecorder) GetWorkerTaskReachability(ctx, options any) *gomock.Call

GetWorkerTaskReachability indicates an expected call of GetWorkerTaskReachability.

func (*MockClientMockRecorder) GetWorkerVersioningRules added in v1.25.0 

func (mr *MockClientMockRecorder) GetWorkerVersioningRules(ctx, options any) *gomock.Call

GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.

func (*MockClientMockRecorder) GetWorkflow 

func (mr *MockClientMockRecorder) GetWorkflow(ctx, workflowID, runID any) *gomock.Call

GetWorkflow indicates an expected call of GetWorkflow.

func (*MockClientMockRecorder) GetWorkflowHistory 

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

GetWorkflowHistory indicates an expected call of GetWorkflowHistory.

func (*MockClientMockRecorder) GetWorkflowUpdateHandle added in v1.21.0 

func (mr *MockClientMockRecorder) GetWorkflowUpdateHandle(ref any) *gomock.Call

GetWorkflowUpdateHandle indicates an expected call of GetWorkflowUpdateHandle.

func (*MockClientMockRecorder) ListArchivedWorkflow 

func (mr *MockClientMockRecorder) ListArchivedWorkflow(ctx, request any) *gomock.Call

ListArchivedWorkflow indicates an expected call of ListArchivedWorkflow.

func (*MockClientMockRecorder) ListClosedWorkflow 

func (mr *MockClientMockRecorder) ListClosedWorkflow(ctx, request any) *gomock.Call

ListClosedWorkflow indicates an expected call of ListClosedWorkflow.

func (*MockClientMockRecorder) ListOpenWorkflow 

func (mr *MockClientMockRecorder) ListOpenWorkflow(ctx, request any) *gomock.Call

ListOpenWorkflow indicates an expected call of ListOpenWorkflow.

func (*MockClientMockRecorder) ListWorkflow 

func (mr *MockClientMockRecorder) ListWorkflow(ctx, request any) *gomock.Call

ListWorkflow indicates an expected call of ListWorkflow.

func (*MockClientMockRecorder) NewWithStartWorkflowOperation added in v1.26.2 

func (mr *MockClientMockRecorder) NewWithStartWorkflowOperation(options, workflow any, args ...any) *gomock.Call

NewWithStartWorkflowOperation indicates an expected call of NewWithStartWorkflowOperation.

func (*MockClientMockRecorder) OperatorService added in v1.18.0 

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

OperatorService indicates an expected call of OperatorService.

func (*MockClientMockRecorder) QueryWorkflow 

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

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockClientMockRecorder) QueryWorkflowWithOptions 

func (mr *MockClientMockRecorder) QueryWorkflowWithOptions(ctx, request any) *gomock.Call

QueryWorkflowWithOptions indicates an expected call of QueryWorkflowWithOptions.

func (*MockClientMockRecorder) RecordActivityHeartbeat 

func (mr *MockClientMockRecorder) RecordActivityHeartbeat(ctx, taskToken any, details ...any) *gomock.Call

RecordActivityHeartbeat indicates an expected call of RecordActivityHeartbeat.

func (*MockClientMockRecorder) RecordActivityHeartbeatByID 

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

RecordActivityHeartbeatByID indicates an expected call of RecordActivityHeartbeatByID.

func (*MockClientMockRecorder) ResetWorkflowExecution 

func (mr *MockClientMockRecorder) ResetWorkflowExecution(ctx, request any) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockClientMockRecorder) ScanWorkflow 

func (mr *MockClientMockRecorder) ScanWorkflow(ctx, request any) *gomock.Call

ScanWorkflow indicates an expected call of ScanWorkflow.

func (*MockClientMockRecorder) ScheduleClient added in v1.19.0 

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 any, workflowArgs ...any) *gomock.Call

SignalWithStartWorkflow indicates an expected call of SignalWithStartWorkflow.

func (*MockClientMockRecorder) SignalWorkflow 

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

SignalWorkflow indicates an expected call of SignalWorkflow.

func (*MockClientMockRecorder) TerminateWorkflow 

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

TerminateWorkflow indicates an expected call of TerminateWorkflow.

func (*MockClientMockRecorder) UpdateWithStartWorkflow added in v1.26.2 

func (mr *MockClientMockRecorder) UpdateWithStartWorkflow(ctx, options any) *gomock.Call

UpdateWithStartWorkflow indicates an expected call of UpdateWithStartWorkflow.

func (*MockClientMockRecorder) UpdateWorkerBuildIdCompatibility added in v1.21.0 

func (mr *MockClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, options any) *gomock.Call

UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.

func (*MockClientMockRecorder) UpdateWorkerVersioningRules added in v1.25.0 

func (mr *MockClientMockRecorder) UpdateWorkerVersioningRules(ctx, options any) *gomock.Call

UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.

func (*MockClientMockRecorder) UpdateWorkflow added in v1.20.0 

func (mr *MockClientMockRecorder) UpdateWorkflow(ctx, options any) *gomock.Call

UpdateWorkflow indicates an expected call of UpdateWorkflow.

func (*MockClientMockRecorder) UpdateWorkflowExecutionOptions added in v1.27.0 

func (mr *MockClientMockRecorder) UpdateWorkflowExecutionOptions(ctx, options any) *gomock.Call

UpdateWorkflowExecutionOptions indicates an expected call of UpdateWorkflowExecutionOptions.

func (*MockClientMockRecorder) WorkerDeploymentClient added in v1.27.2 

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.

type MockEncodedValue added in v1.23.0 

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

MockEncodedValue is a mock of EncodedValue interface.

func NewMockEncodedValue added in v1.23.0 

func NewMockEncodedValue(ctrl *gomock.Controller) *MockEncodedValue

NewMockEncodedValue creates a new mock instance.

func (*MockEncodedValue) EXPECT added in v1.23.0 

func (m *MockEncodedValue) EXPECT() *MockEncodedValueMockRecorder

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

func (*MockEncodedValue) Get added in v1.23.0 

func (m *MockEncodedValue) Get(arg0 interface{}) error

Get mocks base method.

func (*MockEncodedValue) HasValue added in v1.23.0 

func (m *MockEncodedValue) HasValue() bool

HasValue mocks base method.

type MockEncodedValueMockRecorder added in v1.23.0 

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

MockEncodedValueMockRecorder is the mock recorder for MockEncodedValue.

func (*MockEncodedValueMockRecorder) Get added in v1.23.0 

func (mr *MockEncodedValueMockRecorder) Get(arg0 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockEncodedValueMockRecorder) HasValue added in v1.23.0 

func (mr *MockEncodedValueMockRecorder) HasValue() *gomock.Call

HasValue indicates an expected call of HasValue.

type MockWorker 

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

MockWorker is a mock of Worker interface.

func NewMockWorker 

func NewMockWorker(ctrl *gomock.Controller) *MockWorker

NewMockWorker creates a new mock instance.

func (*MockWorker) EXPECT 

func (m *MockWorker) EXPECT() *MockWorkerMockRecorder

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

func (*MockWorker) RegisterActivity 

func (m *MockWorker) RegisterActivity(a any)

RegisterActivity mocks base method.

func (*MockWorker) RegisterActivityWithOptions 

func (m *MockWorker) RegisterActivityWithOptions(a any, options activity.RegisterOptions)

RegisterActivityWithOptions mocks base method.

func (*MockWorker) RegisterDynamicActivity added in v1.29.0 

func (m *MockWorker) RegisterDynamicActivity(a any, options activity.DynamicRegisterOptions)

RegisterDynamicActivity mocks base method.

func (*MockWorker) RegisterDynamicWorkflow added in v1.29.0 

func (m *MockWorker) RegisterDynamicWorkflow(w any, options workflow.DynamicRegisterOptions)

RegisterDynamicWorkflow mocks base method.

func (*MockWorker) RegisterNexusService added in v1.26.2 

func (m *MockWorker) RegisterNexusService(arg0 *nexus.Service)

RegisterNexusService mocks base method.

func (*MockWorker) RegisterWorkflow 

func (m *MockWorker) RegisterWorkflow(w any)

RegisterWorkflow mocks base method.

func (*MockWorker) RegisterWorkflowWithOptions 

func (m *MockWorker) RegisterWorkflowWithOptions(w any, options workflow.RegisterOptions)

RegisterWorkflowWithOptions mocks base method.

func (*MockWorker) Run 

func (m *MockWorker) Run(interruptCh <-chan any) error

Run mocks base method.

func (*MockWorker) Start 

func (m *MockWorker) Start() error

Start mocks base method.

func (*MockWorker) Stop 

func (m *MockWorker) Stop()

Stop mocks base method.

type MockWorkerMockRecorder 

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

MockWorkerMockRecorder is the mock recorder for MockWorker.

func (*MockWorkerMockRecorder) RegisterActivity 

func (mr *MockWorkerMockRecorder) RegisterActivity(a any) *gomock.Call

RegisterActivity indicates an expected call of RegisterActivity.

func (*MockWorkerMockRecorder) RegisterActivityWithOptions 

func (mr *MockWorkerMockRecorder) RegisterActivityWithOptions(a, options any) *gomock.Call

RegisterActivityWithOptions indicates an expected call of RegisterActivityWithOptions.

func (*MockWorkerMockRecorder) RegisterDynamicActivity added in v1.29.0 

func (mr *MockWorkerMockRecorder) RegisterDynamicActivity(a, options any) *gomock.Call

RegisterDynamicActivity indicates an expected call of RegisterDynamicActivity.

func (*MockWorkerMockRecorder) RegisterDynamicWorkflow added in v1.29.0 

func (mr *MockWorkerMockRecorder) RegisterDynamicWorkflow(w, options any) *gomock.Call

RegisterDynamicWorkflow indicates an expected call of RegisterDynamicWorkflow.

func (*MockWorkerMockRecorder) RegisterNexusService added in v1.26.2 

func (mr *MockWorkerMockRecorder) RegisterNexusService(arg0 any) *gomock.Call

RegisterNexusService indicates an expected call of RegisterNexusService.

func (*MockWorkerMockRecorder) RegisterWorkflow 

func (mr *MockWorkerMockRecorder) RegisterWorkflow(w any) *gomock.Call

RegisterWorkflow indicates an expected call of RegisterWorkflow.

func (*MockWorkerMockRecorder) RegisterWorkflowWithOptions 

func (mr *MockWorkerMockRecorder) RegisterWorkflowWithOptions(w, options any) *gomock.Call

RegisterWorkflowWithOptions indicates an expected call of RegisterWorkflowWithOptions.

func (*MockWorkerMockRecorder) Run 

func (mr *MockWorkerMockRecorder) Run(interruptCh any) *gomock.Call

Run indicates an expected call of Run.

func (*MockWorkerMockRecorder) Start 

func (mr *MockWorkerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockWorkerMockRecorder) Stop 

func (mr *MockWorkerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type MockWorkflowRun added in v1.17.3 

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

MockWorkflowRun is a mock of WorkflowRun interface.

func NewMockWorkflowRun added in v1.17.3 

func NewMockWorkflowRun(ctrl *gomock.Controller) *MockWorkflowRun

NewMockWorkflowRun creates a new mock instance.

func (*MockWorkflowRun) EXPECT added in v1.17.3 

func (m *MockWorkflowRun) EXPECT() *MockWorkflowRunMockRecorder

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

func (*MockWorkflowRun) Get added in v1.17.3 

func (m *MockWorkflowRun) Get(ctx context.Context, valuePtr any) error

Get mocks base method.

func (*MockWorkflowRun) GetID added in v1.17.3 

func (m *MockWorkflowRun) GetID() string

GetID mocks base method.

func (*MockWorkflowRun) GetRunID added in v1.17.3 

func (m *MockWorkflowRun) GetRunID() string

GetRunID mocks base method.

func (*MockWorkflowRun) GetWithOptions added in v1.17.3 

func (m *MockWorkflowRun) GetWithOptions(ctx context.Context, valuePtr any, options client.WorkflowRunGetOptions) error

GetWithOptions mocks base method.

type MockWorkflowRunMockRecorder added in v1.17.3 

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

MockWorkflowRunMockRecorder is the mock recorder for MockWorkflowRun.

func (*MockWorkflowRunMockRecorder) Get added in v1.17.3 

func (mr *MockWorkflowRunMockRecorder) Get(ctx, valuePtr any) *gomock.Call

Get indicates an expected call of Get.

func (*MockWorkflowRunMockRecorder) GetID added in v1.17.3 

func (mr *MockWorkflowRunMockRecorder) GetID() *gomock.Call

GetID indicates an expected call of GetID.

func (*MockWorkflowRunMockRecorder) GetRunID added in v1.17.3 

func (mr *MockWorkflowRunMockRecorder) GetRunID() *gomock.Call

GetRunID indicates an expected call of GetRunID.

func (*MockWorkflowRunMockRecorder) GetWithOptions added in v1.17.3 

func (mr *MockWorkflowRunMockRecorder) GetWithOptions(ctx, valuePtr, options any) *gomock.Call

GetWithOptions indicates an expected call of GetWithOptions.

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.