mock_temporal

package

Go to main page

Versions in this module

v1

v1.0.7

Jan 16, 2025

Changes in this version

type MockTemporalService

+ func (_m *MockTemporalService) ExecuteScheduledWorkflow(ctx context.Context, params models.ExecuteWorkflowWithScheduleParams) (models.ScheduledWorkflowResponse, error)

+ func (_m *MockTemporalService) QuerySchedule(ctx context.Context, params models.QueryScheduleParams) (models.QueryScheduleResponse, error)

+ type MockTemporalService_ExecuteScheduledWorkflow_Call struct

+ func (_c *MockTemporalService_ExecuteScheduledWorkflow_Call) Return(_a0 models.ScheduledWorkflowResponse, _a1 error) *MockTemporalService_ExecuteScheduledWorkflow_Call

+ func (_c *MockTemporalService_ExecuteScheduledWorkflow_Call) Run(run func(ctx context.Context, params models.ExecuteWorkflowWithScheduleParams)) *MockTemporalService_ExecuteScheduledWorkflow_Call

+ func (_c *MockTemporalService_ExecuteScheduledWorkflow_Call) RunAndReturn(...) *MockTemporalService_ExecuteScheduledWorkflow_Call

type MockTemporalService_Expecter

+ func (_e *MockTemporalService_Expecter) ExecuteScheduledWorkflow(ctx interface{}, params interface{}) *MockTemporalService_ExecuteScheduledWorkflow_Call

+ func (_e *MockTemporalService_Expecter) QuerySchedule(ctx interface{}, params interface{}) *MockTemporalService_QuerySchedule_Call

+ type MockTemporalService_QuerySchedule_Call struct

+ func (_c *MockTemporalService_QuerySchedule_Call) Return(_a0 models.QueryScheduleResponse, _a1 error) *MockTemporalService_QuerySchedule_Call

+ func (_c *MockTemporalService_QuerySchedule_Call) Run(run func(ctx context.Context, params models.QueryScheduleParams)) *MockTemporalService_QuerySchedule_Call

+ func (_c *MockTemporalService_QuerySchedule_Call) RunAndReturn(...) *MockTemporalService_QuerySchedule_Call

v1.0.5

Jan 16, 2025

v1.0.4

Jan 16, 2025

v1.0.3

Jan 16, 2025

v1.0.2

Jan 16, 2025

Changes in this version

+ type MockTemporalService struct

+ func NewMockTemporalService(t interface{ ... }) *MockTemporalService

+ func (_m *MockTemporalService) CancelWorkflow(ctx context.Context, params models.CancelWorkflowParams) error

+ func (_m *MockTemporalService) Close(ctx context.Context)

+ func (_m *MockTemporalService) Connect(ctx context.Context, params models.ConnectClientParams) error

+ func (_m *MockTemporalService) EXPECT() *MockTemporalService_Expecter

+ func (_m *MockTemporalService) ExecuteAsyncWorkflow(ctx context.Context, params models.ExecuteWorkflowParams) (models.WorkflowResponse, error)

+ func (_m *MockTemporalService) ExecuteSyncWorkflow(ctx context.Context, params models.ExecuteWorkflowParams) (models.WorkflowResponse, error)

+ func (_m *MockTemporalService) GetNewWorker(ctx context.Context, params models.NewWorkerParams) (worker.Worker, error)

+ func (_m *MockTemporalService) GetWorkflowDetails(ctx context.Context, params models.GetWorkflowDetailsParams) (models.WorkflowDetailsResponse, error)

+ func (_m *MockTemporalService) ListWorkflows(ctx context.Context, params models.ListWorkflowsParams) (models.ListWorkflowsResponse, error)

+ func (_m *MockTemporalService) QueryWorkflow(ctx context.Context, params models.QueryWorkflowParams) (models.QueryWorkflowResponse, error)

+ func (_m *MockTemporalService) SignalWorkflow(ctx context.Context, params models.SignalWorkflowParams) error

+ func (_m *MockTemporalService) TerminateWorkflow(ctx context.Context, params models.TerminateWorkflowParams) error

+ type MockTemporalService_CancelWorkflow_Call struct

+ func (_c *MockTemporalService_CancelWorkflow_Call) Return(_a0 error) *MockTemporalService_CancelWorkflow_Call

+ func (_c *MockTemporalService_CancelWorkflow_Call) Run(run func(ctx context.Context, params models.CancelWorkflowParams)) *MockTemporalService_CancelWorkflow_Call

+ func (_c *MockTemporalService_CancelWorkflow_Call) RunAndReturn(run func(context.Context, models.CancelWorkflowParams) error) *MockTemporalService_CancelWorkflow_Call

+ type MockTemporalService_Close_Call struct

+ func (_c *MockTemporalService_Close_Call) Return() *MockTemporalService_Close_Call

+ func (_c *MockTemporalService_Close_Call) Run(run func(ctx context.Context)) *MockTemporalService_Close_Call

+ func (_c *MockTemporalService_Close_Call) RunAndReturn(run func(context.Context)) *MockTemporalService_Close_Call

+ type MockTemporalService_Connect_Call struct

+ func (_c *MockTemporalService_Connect_Call) Return(_a0 error) *MockTemporalService_Connect_Call

+ func (_c *MockTemporalService_Connect_Call) Run(run func(ctx context.Context, params models.ConnectClientParams)) *MockTemporalService_Connect_Call

+ func (_c *MockTemporalService_Connect_Call) RunAndReturn(run func(context.Context, models.ConnectClientParams) error) *MockTemporalService_Connect_Call

+ type MockTemporalService_ExecuteAsyncWorkflow_Call struct

+ func (_c *MockTemporalService_ExecuteAsyncWorkflow_Call) Return(_a0 models.WorkflowResponse, _a1 error) *MockTemporalService_ExecuteAsyncWorkflow_Call

+ func (_c *MockTemporalService_ExecuteAsyncWorkflow_Call) Run(run func(ctx context.Context, params models.ExecuteWorkflowParams)) *MockTemporalService_ExecuteAsyncWorkflow_Call

+ func (_c *MockTemporalService_ExecuteAsyncWorkflow_Call) RunAndReturn(...) *MockTemporalService_ExecuteAsyncWorkflow_Call

+ type MockTemporalService_ExecuteSyncWorkflow_Call struct

+ func (_c *MockTemporalService_ExecuteSyncWorkflow_Call) Return(_a0 models.WorkflowResponse, _a1 error) *MockTemporalService_ExecuteSyncWorkflow_Call

+ func (_c *MockTemporalService_ExecuteSyncWorkflow_Call) Run(run func(ctx context.Context, params models.ExecuteWorkflowParams)) *MockTemporalService_ExecuteSyncWorkflow_Call

+ func (_c *MockTemporalService_ExecuteSyncWorkflow_Call) RunAndReturn(...) *MockTemporalService_ExecuteSyncWorkflow_Call

+ type MockTemporalService_Expecter struct

+ func (_e *MockTemporalService_Expecter) CancelWorkflow(ctx interface{}, params interface{}) *MockTemporalService_CancelWorkflow_Call

+ func (_e *MockTemporalService_Expecter) Close(ctx interface{}) *MockTemporalService_Close_Call

+ func (_e *MockTemporalService_Expecter) Connect(ctx interface{}, params interface{}) *MockTemporalService_Connect_Call

+ func (_e *MockTemporalService_Expecter) ExecuteAsyncWorkflow(ctx interface{}, params interface{}) *MockTemporalService_ExecuteAsyncWorkflow_Call

+ func (_e *MockTemporalService_Expecter) ExecuteSyncWorkflow(ctx interface{}, params interface{}) *MockTemporalService_ExecuteSyncWorkflow_Call

+ func (_e *MockTemporalService_Expecter) GetNewWorker(ctx interface{}, params interface{}) *MockTemporalService_GetNewWorker_Call

+ func (_e *MockTemporalService_Expecter) GetWorkflowDetails(ctx interface{}, params interface{}) *MockTemporalService_GetWorkflowDetails_Call

+ func (_e *MockTemporalService_Expecter) ListWorkflows(ctx interface{}, params interface{}) *MockTemporalService_ListWorkflows_Call

+ func (_e *MockTemporalService_Expecter) QueryWorkflow(ctx interface{}, params interface{}) *MockTemporalService_QueryWorkflow_Call

+ func (_e *MockTemporalService_Expecter) SignalWorkflow(ctx interface{}, params interface{}) *MockTemporalService_SignalWorkflow_Call

+ func (_e *MockTemporalService_Expecter) TerminateWorkflow(ctx interface{}, params interface{}) *MockTemporalService_TerminateWorkflow_Call

+ type MockTemporalService_GetNewWorker_Call struct

+ func (_c *MockTemporalService_GetNewWorker_Call) Return(_a0 worker.Worker, _a1 error) *MockTemporalService_GetNewWorker_Call

+ func (_c *MockTemporalService_GetNewWorker_Call) Run(run func(ctx context.Context, params models.NewWorkerParams)) *MockTemporalService_GetNewWorker_Call

+ func (_c *MockTemporalService_GetNewWorker_Call) RunAndReturn(run func(context.Context, models.NewWorkerParams) (worker.Worker, error)) *MockTemporalService_GetNewWorker_Call

+ type MockTemporalService_GetWorkflowDetails_Call struct

+ func (_c *MockTemporalService_GetWorkflowDetails_Call) Return(_a0 models.WorkflowDetailsResponse, _a1 error) *MockTemporalService_GetWorkflowDetails_Call

+ func (_c *MockTemporalService_GetWorkflowDetails_Call) Run(run func(ctx context.Context, params models.GetWorkflowDetailsParams)) *MockTemporalService_GetWorkflowDetails_Call

+ func (_c *MockTemporalService_GetWorkflowDetails_Call) RunAndReturn(...) *MockTemporalService_GetWorkflowDetails_Call

+ type MockTemporalService_ListWorkflows_Call struct

+ func (_c *MockTemporalService_ListWorkflows_Call) Return(_a0 models.ListWorkflowsResponse, _a1 error) *MockTemporalService_ListWorkflows_Call

+ func (_c *MockTemporalService_ListWorkflows_Call) Run(run func(ctx context.Context, params models.ListWorkflowsParams)) *MockTemporalService_ListWorkflows_Call

+ func (_c *MockTemporalService_ListWorkflows_Call) RunAndReturn(...) *MockTemporalService_ListWorkflows_Call

+ type MockTemporalService_QueryWorkflow_Call struct

+ func (_c *MockTemporalService_QueryWorkflow_Call) Return(_a0 models.QueryWorkflowResponse, _a1 error) *MockTemporalService_QueryWorkflow_Call

+ func (_c *MockTemporalService_QueryWorkflow_Call) Run(run func(ctx context.Context, params models.QueryWorkflowParams)) *MockTemporalService_QueryWorkflow_Call

+ func (_c *MockTemporalService_QueryWorkflow_Call) RunAndReturn(...) *MockTemporalService_QueryWorkflow_Call

+ type MockTemporalService_SignalWorkflow_Call struct

+ func (_c *MockTemporalService_SignalWorkflow_Call) Return(_a0 error) *MockTemporalService_SignalWorkflow_Call

+ func (_c *MockTemporalService_SignalWorkflow_Call) Run(run func(ctx context.Context, params models.SignalWorkflowParams)) *MockTemporalService_SignalWorkflow_Call

+ func (_c *MockTemporalService_SignalWorkflow_Call) RunAndReturn(run func(context.Context, models.SignalWorkflowParams) error) *MockTemporalService_SignalWorkflow_Call

+ type MockTemporalService_TerminateWorkflow_Call struct

+ func (_c *MockTemporalService_TerminateWorkflow_Call) Return(_a0 error) *MockTemporalService_TerminateWorkflow_Call

+ func (_c *MockTemporalService_TerminateWorkflow_Call) Run(run func(ctx context.Context, params models.TerminateWorkflowParams)) *MockTemporalService_TerminateWorkflow_Call

+ func (_c *MockTemporalService_TerminateWorkflow_Call) RunAndReturn(run func(context.Context, models.TerminateWorkflowParams) error) *MockTemporalService_TerminateWorkflow_Call

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