mocksdk

package
v1.19.1 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2023 License: MIT Imports: 10 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.

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(arg0 context.Context, arg1, arg2 string) error

CancelWorkflow mocks base method.

func (*MockClient) CheckHealth 

func (m *MockClient) CheckHealth(arg0 context.Context, arg1 *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(arg0 context.Context, arg1 []byte, arg2 interface{}, arg3 error) error

CompleteActivity mocks base method.

func (*MockClient) CompleteActivityByID 

func (m *MockClient) CompleteActivityByID(arg0 context.Context, arg1, arg2, arg3, arg4 string, arg5 interface{}, arg6 error) error

CompleteActivityByID mocks base method.

func (*MockClient) CountWorkflow 

func (m *MockClient) CountWorkflow(arg0 context.Context, arg1 *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)

CountWorkflow mocks base method.

func (*MockClient) DescribeTaskQueue 

func (m *MockClient) DescribeTaskQueue(arg0 context.Context, arg1 string, arg2 enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

DescribeTaskQueue mocks base method.

func (*MockClient) DescribeWorkflowExecution 

func (m *MockClient) DescribeWorkflowExecution(arg0 context.Context, arg1, arg2 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(arg0 context.Context, arg1 client.StartWorkflowOptions, arg2 interface{}, arg3 ...interface{}) (client.WorkflowRun, error)

ExecuteWorkflow mocks base method.

func (*MockClient) GetSearchAttributes 

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

GetSearchAttributes mocks base method.

func (*MockClient) GetWorkflow 

func (m *MockClient) GetWorkflow(arg0 context.Context, arg1, arg2 string) client.WorkflowRun

GetWorkflow mocks base method.

func (*MockClient) GetWorkflowHistory 

func (m *MockClient) GetWorkflowHistory(arg0 context.Context, arg1, arg2 string, arg3 bool, arg4 enums.HistoryEventFilterType) client.HistoryEventIterator

GetWorkflowHistory mocks base method.

func (*MockClient) ListArchivedWorkflow 

func (m *MockClient) ListArchivedWorkflow(arg0 context.Context, arg1 *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)

ListArchivedWorkflow mocks base method.

func (*MockClient) ListClosedWorkflow 

func (m *MockClient) ListClosedWorkflow(arg0 context.Context, arg1 *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)

ListClosedWorkflow mocks base method.

func (*MockClient) ListOpenWorkflow 

func (m *MockClient) ListOpenWorkflow(arg0 context.Context, arg1 *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)

ListOpenWorkflow mocks base method.

func (*MockClient) ListWorkflow 

func (m *MockClient) ListWorkflow(arg0 context.Context, arg1 *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)

ListWorkflow 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(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) (converter.EncodedValue, error)

QueryWorkflow mocks base method.

func (*MockClient) QueryWorkflowWithOptions 

func (m *MockClient) QueryWorkflowWithOptions(arg0 context.Context, arg1 *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)

QueryWorkflowWithOptions mocks base method.

func (*MockClient) RecordActivityHeartbeat 

func (m *MockClient) RecordActivityHeartbeat(arg0 context.Context, arg1 []byte, arg2 ...interface{}) error

RecordActivityHeartbeat mocks base method.

func (*MockClient) RecordActivityHeartbeatByID 

func (m *MockClient) RecordActivityHeartbeatByID(arg0 context.Context, arg1, arg2, arg3, arg4 string, arg5 ...interface{}) error

RecordActivityHeartbeatByID mocks base method.

func (*MockClient) ResetWorkflowExecution 

func (m *MockClient) ResetWorkflowExecution(arg0 context.Context, arg1 *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

ResetWorkflowExecution mocks base method.

func (*MockClient) ScanWorkflow 

func (m *MockClient) ScanWorkflow(arg0 context.Context, arg1 *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(arg0 context.Context, arg1, arg2 string, arg3 interface{}, arg4 client.StartWorkflowOptions, arg5 interface{}, arg6 ...interface{}) (client.WorkflowRun, error)

SignalWithStartWorkflow mocks base method.

func (*MockClient) SignalWorkflow 

func (m *MockClient) SignalWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 interface{}) error

SignalWorkflow mocks base method.

func (*MockClient) TerminateWorkflow 

func (m *MockClient) TerminateWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) error

TerminateWorkflow 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(arg0, arg1, arg2 interface{}) *gomock.Call

CancelWorkflow indicates an expected call of CancelWorkflow.

func (*MockClientMockRecorder) CheckHealth 

func (mr *MockClientMockRecorder) CheckHealth(arg0, arg1 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(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

CompleteActivity indicates an expected call of CompleteActivity.

func (*MockClientMockRecorder) CompleteActivityByID 

func (mr *MockClientMockRecorder) CompleteActivityByID(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

CompleteActivityByID indicates an expected call of CompleteActivityByID.

func (*MockClientMockRecorder) CountWorkflow 

func (mr *MockClientMockRecorder) CountWorkflow(arg0, arg1 interface{}) *gomock.Call

CountWorkflow indicates an expected call of CountWorkflow.

func (*MockClientMockRecorder) DescribeTaskQueue 

func (mr *MockClientMockRecorder) DescribeTaskQueue(arg0, arg1, arg2 interface{}) *gomock.Call

DescribeTaskQueue indicates an expected call of DescribeTaskQueue.

func (*MockClientMockRecorder) DescribeWorkflowExecution 

func (mr *MockClientMockRecorder) DescribeWorkflowExecution(arg0, arg1, arg2 interface{}) *gomock.Call

DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.

func (*MockClientMockRecorder) ExecuteWorkflow 

func (mr *MockClientMockRecorder) ExecuteWorkflow(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

ExecuteWorkflow indicates an expected call of ExecuteWorkflow.

func (*MockClientMockRecorder) GetSearchAttributes 

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

GetSearchAttributes indicates an expected call of GetSearchAttributes.

func (*MockClientMockRecorder) GetWorkflow 

func (mr *MockClientMockRecorder) GetWorkflow(arg0, arg1, arg2 interface{}) *gomock.Call

GetWorkflow indicates an expected call of GetWorkflow.

func (*MockClientMockRecorder) GetWorkflowHistory 

func (mr *MockClientMockRecorder) GetWorkflowHistory(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

GetWorkflowHistory indicates an expected call of GetWorkflowHistory.

func (*MockClientMockRecorder) ListArchivedWorkflow 

func (mr *MockClientMockRecorder) ListArchivedWorkflow(arg0, arg1 interface{}) *gomock.Call

ListArchivedWorkflow indicates an expected call of ListArchivedWorkflow.

func (*MockClientMockRecorder) ListClosedWorkflow 

func (mr *MockClientMockRecorder) ListClosedWorkflow(arg0, arg1 interface{}) *gomock.Call

ListClosedWorkflow indicates an expected call of ListClosedWorkflow.

func (*MockClientMockRecorder) ListOpenWorkflow 

func (mr *MockClientMockRecorder) ListOpenWorkflow(arg0, arg1 interface{}) *gomock.Call

ListOpenWorkflow indicates an expected call of ListOpenWorkflow.

func (*MockClientMockRecorder) ListWorkflow 

func (mr *MockClientMockRecorder) ListWorkflow(arg0, arg1 interface{}) *gomock.Call

ListWorkflow indicates an expected call of ListWorkflow.

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(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockClientMockRecorder) QueryWorkflowWithOptions 

func (mr *MockClientMockRecorder) QueryWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call

QueryWorkflowWithOptions indicates an expected call of QueryWorkflowWithOptions.

func (*MockClientMockRecorder) RecordActivityHeartbeat 

func (mr *MockClientMockRecorder) RecordActivityHeartbeat(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RecordActivityHeartbeat indicates an expected call of RecordActivityHeartbeat.

func (*MockClientMockRecorder) RecordActivityHeartbeatByID 

func (mr *MockClientMockRecorder) RecordActivityHeartbeatByID(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call

RecordActivityHeartbeatByID indicates an expected call of RecordActivityHeartbeatByID.

func (*MockClientMockRecorder) ResetWorkflowExecution 

func (mr *MockClientMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call

ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.

func (*MockClientMockRecorder) ScanWorkflow 

func (mr *MockClientMockRecorder) ScanWorkflow(arg0, arg1 interface{}) *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(arg0, arg1, arg2, arg3, arg4, arg5 interface{}, arg6 ...interface{}) *gomock.Call

SignalWithStartWorkflow indicates an expected call of SignalWithStartWorkflow.

func (*MockClientMockRecorder) SignalWorkflow 

func (mr *MockClientMockRecorder) SignalWorkflow(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

SignalWorkflow indicates an expected call of SignalWorkflow.

func (*MockClientMockRecorder) TerminateWorkflow 

func (mr *MockClientMockRecorder) TerminateWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call

TerminateWorkflow indicates an expected call of TerminateWorkflow.

func (*MockClientMockRecorder) WorkflowService 

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

WorkflowService indicates an expected call of WorkflowService.

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(arg0 interface{})

RegisterActivity mocks base method.

func (*MockWorker) RegisterActivityWithOptions 

func (m *MockWorker) RegisterActivityWithOptions(arg0 interface{}, arg1 activity.RegisterOptions)

RegisterActivityWithOptions mocks base method.

func (*MockWorker) RegisterWorkflow 

func (m *MockWorker) RegisterWorkflow(arg0 interface{})

RegisterWorkflow mocks base method.

func (*MockWorker) RegisterWorkflowWithOptions 

func (m *MockWorker) RegisterWorkflowWithOptions(arg0 interface{}, arg1 workflow.RegisterOptions)

RegisterWorkflowWithOptions mocks base method.

func (*MockWorker) Run 

func (m *MockWorker) Run(arg0 <-chan interface{}) 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(arg0 interface{}) *gomock.Call

RegisterActivity indicates an expected call of RegisterActivity.

func (*MockWorkerMockRecorder) RegisterActivityWithOptions 

func (mr *MockWorkerMockRecorder) RegisterActivityWithOptions(arg0, arg1 interface{}) *gomock.Call

RegisterActivityWithOptions indicates an expected call of RegisterActivityWithOptions.

func (*MockWorkerMockRecorder) RegisterWorkflow 

func (mr *MockWorkerMockRecorder) RegisterWorkflow(arg0 interface{}) *gomock.Call

RegisterWorkflow indicates an expected call of RegisterWorkflow.

func (*MockWorkerMockRecorder) RegisterWorkflowWithOptions 

func (mr *MockWorkerMockRecorder) RegisterWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call

RegisterWorkflowWithOptions indicates an expected call of RegisterWorkflowWithOptions.

func (*MockWorkerMockRecorder) Run 

func (mr *MockWorkerMockRecorder) Run(arg0 interface{}) *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(arg0 context.Context, arg1 interface{}) 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(arg0 context.Context, arg1 interface{}, arg2 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(arg0, arg1 interface{}) *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(arg0, arg1, arg2 interface{}) *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.