mock_temporal

package
v1.0.7 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockTemporalService 

type MockTemporalService struct {
	mock.Mock
}

MockTemporalService is an autogenerated mock type for the TemporalService type

func NewMockTemporalService 

func NewMockTemporalService(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockTemporalService

NewMockTemporalService creates a new instance of MockTemporalService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockTemporalService) CancelWorkflow 

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

CancelWorkflow provides a mock function with given fields: ctx, params

func (*MockTemporalService) Close 

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

Close provides a mock function with given fields: ctx

func (*MockTemporalService) Connect 

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

Connect provides a mock function with given fields: ctx, params

func (*MockTemporalService) EXPECT 

func (_m *MockTemporalService) EXPECT() *MockTemporalService_Expecter

func (*MockTemporalService) ExecuteAsyncWorkflow 

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

ExecuteAsyncWorkflow provides a mock function with given fields: ctx, params

func (*MockTemporalService) ExecuteScheduledWorkflow added in v1.0.7 

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

ExecuteScheduledWorkflow provides a mock function with given fields: ctx, params

func (*MockTemporalService) ExecuteSyncWorkflow 

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

ExecuteSyncWorkflow provides a mock function with given fields: ctx, params

func (*MockTemporalService) GetNewWorker 

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

GetNewWorker provides a mock function with given fields: ctx, params

func (*MockTemporalService) GetWorkflowDetails 

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

GetWorkflowDetails provides a mock function with given fields: ctx, params

func (*MockTemporalService) ListWorkflows 

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

ListWorkflows provides a mock function with given fields: ctx, params

func (*MockTemporalService) QuerySchedule added in v1.0.7 

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

QuerySchedule provides a mock function with given fields: ctx, params

func (*MockTemporalService) QueryWorkflow 

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

QueryWorkflow provides a mock function with given fields: ctx, params

func (*MockTemporalService) SignalWorkflow 

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

SignalWorkflow provides a mock function with given fields: ctx, params

func (*MockTemporalService) TerminateWorkflow 

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

TerminateWorkflow provides a mock function with given fields: ctx, params

type MockTemporalService_CancelWorkflow_Call 

type MockTemporalService_CancelWorkflow_Call struct {
	*mock.Call
}

MockTemporalService_CancelWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelWorkflow'

func (*MockTemporalService_CancelWorkflow_Call) Return 

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

func (*MockTemporalService_CancelWorkflow_Call) Run 

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

func (*MockTemporalService_CancelWorkflow_Call) RunAndReturn 

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

type MockTemporalService_Close_Call 

type MockTemporalService_Close_Call struct {
	*mock.Call
}

MockTemporalService_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*MockTemporalService_Close_Call) Return 

func (_c *MockTemporalService_Close_Call) Return() *MockTemporalService_Close_Call

func (*MockTemporalService_Close_Call) Run 

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

func (*MockTemporalService_Close_Call) RunAndReturn 

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

type MockTemporalService_Connect_Call 

type MockTemporalService_Connect_Call struct {
	*mock.Call
}

MockTemporalService_Connect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connect'

func (*MockTemporalService_Connect_Call) Return 

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

func (*MockTemporalService_Connect_Call) Run 

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

func (*MockTemporalService_Connect_Call) RunAndReturn 

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

type MockTemporalService_ExecuteAsyncWorkflow_Call 

type MockTemporalService_ExecuteAsyncWorkflow_Call struct {
	*mock.Call
}

MockTemporalService_ExecuteAsyncWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteAsyncWorkflow'

func (*MockTemporalService_ExecuteAsyncWorkflow_Call) Return 

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

func (*MockTemporalService_ExecuteAsyncWorkflow_Call) Run 

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

func (*MockTemporalService_ExecuteAsyncWorkflow_Call) RunAndReturn 

func (_c *MockTemporalService_ExecuteAsyncWorkflow_Call) RunAndReturn(run func(context.Context, models.ExecuteWorkflowParams) (models.WorkflowResponse, error)) *MockTemporalService_ExecuteAsyncWorkflow_Call

type MockTemporalService_ExecuteScheduledWorkflow_Call added in v1.0.7 

type MockTemporalService_ExecuteScheduledWorkflow_Call struct {
	*mock.Call
}

MockTemporalService_ExecuteScheduledWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteScheduledWorkflow'

func (*MockTemporalService_ExecuteScheduledWorkflow_Call) Return added in v1.0.7 

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

func (*MockTemporalService_ExecuteScheduledWorkflow_Call) Run added in v1.0.7 

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

func (*MockTemporalService_ExecuteScheduledWorkflow_Call) RunAndReturn added in v1.0.7 

func (_c *MockTemporalService_ExecuteScheduledWorkflow_Call) RunAndReturn(run func(context.Context, models.ExecuteWorkflowWithScheduleParams) (models.ScheduledWorkflowResponse, error)) *MockTemporalService_ExecuteScheduledWorkflow_Call

type MockTemporalService_ExecuteSyncWorkflow_Call 

type MockTemporalService_ExecuteSyncWorkflow_Call struct {
	*mock.Call
}

MockTemporalService_ExecuteSyncWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExecuteSyncWorkflow'

func (*MockTemporalService_ExecuteSyncWorkflow_Call) Return 

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

func (*MockTemporalService_ExecuteSyncWorkflow_Call) Run 

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

func (*MockTemporalService_ExecuteSyncWorkflow_Call) RunAndReturn 

func (_c *MockTemporalService_ExecuteSyncWorkflow_Call) RunAndReturn(run func(context.Context, models.ExecuteWorkflowParams) (models.WorkflowResponse, error)) *MockTemporalService_ExecuteSyncWorkflow_Call

type MockTemporalService_Expecter 

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

func (*MockTemporalService_Expecter) CancelWorkflow 

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

CancelWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • params models.CancelWorkflowParams

func (*MockTemporalService_Expecter) Close 

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

Close is a helper method to define mock.On call

  • ctx context.Context

func (*MockTemporalService_Expecter) Connect 

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

Connect is a helper method to define mock.On call

  • ctx context.Context
  • params models.ConnectClientParams

func (*MockTemporalService_Expecter) ExecuteAsyncWorkflow 

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

ExecuteAsyncWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • params models.ExecuteWorkflowParams

func (*MockTemporalService_Expecter) ExecuteScheduledWorkflow added in v1.0.7 

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

ExecuteScheduledWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • params models.ExecuteWorkflowWithScheduleParams

func (*MockTemporalService_Expecter) ExecuteSyncWorkflow 

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

ExecuteSyncWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • params models.ExecuteWorkflowParams

func (*MockTemporalService_Expecter) GetNewWorker 

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

GetNewWorker is a helper method to define mock.On call

  • ctx context.Context
  • params models.NewWorkerParams

func (*MockTemporalService_Expecter) GetWorkflowDetails 

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

GetWorkflowDetails is a helper method to define mock.On call

  • ctx context.Context
  • params models.GetWorkflowDetailsParams

func (*MockTemporalService_Expecter) ListWorkflows 

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

ListWorkflows is a helper method to define mock.On call

  • ctx context.Context
  • params models.ListWorkflowsParams

func (*MockTemporalService_Expecter) QuerySchedule added in v1.0.7 

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

QuerySchedule is a helper method to define mock.On call

  • ctx context.Context
  • params models.QueryScheduleParams

func (*MockTemporalService_Expecter) QueryWorkflow 

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

QueryWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • params models.QueryWorkflowParams

func (*MockTemporalService_Expecter) SignalWorkflow 

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

SignalWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • params models.SignalWorkflowParams

func (*MockTemporalService_Expecter) TerminateWorkflow 

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

TerminateWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • params models.TerminateWorkflowParams

type MockTemporalService_GetNewWorker_Call 

type MockTemporalService_GetNewWorker_Call struct {
	*mock.Call
}

MockTemporalService_GetNewWorker_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetNewWorker'

func (*MockTemporalService_GetNewWorker_Call) Return 

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

func (*MockTemporalService_GetNewWorker_Call) Run 

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

func (*MockTemporalService_GetNewWorker_Call) RunAndReturn 

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

type MockTemporalService_GetWorkflowDetails_Call 

type MockTemporalService_GetWorkflowDetails_Call struct {
	*mock.Call
}

MockTemporalService_GetWorkflowDetails_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowDetails'

func (*MockTemporalService_GetWorkflowDetails_Call) Return 

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

func (*MockTemporalService_GetWorkflowDetails_Call) Run 

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

func (*MockTemporalService_GetWorkflowDetails_Call) RunAndReturn 

func (_c *MockTemporalService_GetWorkflowDetails_Call) RunAndReturn(run func(context.Context, models.GetWorkflowDetailsParams) (models.WorkflowDetailsResponse, error)) *MockTemporalService_GetWorkflowDetails_Call

type MockTemporalService_ListWorkflows_Call 

type MockTemporalService_ListWorkflows_Call struct {
	*mock.Call
}

MockTemporalService_ListWorkflows_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListWorkflows'

func (*MockTemporalService_ListWorkflows_Call) Return 

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

func (*MockTemporalService_ListWorkflows_Call) Run 

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

func (*MockTemporalService_ListWorkflows_Call) RunAndReturn 

func (_c *MockTemporalService_ListWorkflows_Call) RunAndReturn(run func(context.Context, models.ListWorkflowsParams) (models.ListWorkflowsResponse, error)) *MockTemporalService_ListWorkflows_Call

type MockTemporalService_QuerySchedule_Call added in v1.0.7 

type MockTemporalService_QuerySchedule_Call struct {
	*mock.Call
}

MockTemporalService_QuerySchedule_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QuerySchedule'

func (*MockTemporalService_QuerySchedule_Call) Return added in v1.0.7 

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

func (*MockTemporalService_QuerySchedule_Call) Run added in v1.0.7 

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

func (*MockTemporalService_QuerySchedule_Call) RunAndReturn added in v1.0.7 

func (_c *MockTemporalService_QuerySchedule_Call) RunAndReturn(run func(context.Context, models.QueryScheduleParams) (models.QueryScheduleResponse, error)) *MockTemporalService_QuerySchedule_Call

type MockTemporalService_QueryWorkflow_Call 

type MockTemporalService_QueryWorkflow_Call struct {
	*mock.Call
}

MockTemporalService_QueryWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueryWorkflow'

func (*MockTemporalService_QueryWorkflow_Call) Return 

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

func (*MockTemporalService_QueryWorkflow_Call) Run 

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

func (*MockTemporalService_QueryWorkflow_Call) RunAndReturn 

func (_c *MockTemporalService_QueryWorkflow_Call) RunAndReturn(run func(context.Context, models.QueryWorkflowParams) (models.QueryWorkflowResponse, error)) *MockTemporalService_QueryWorkflow_Call

type MockTemporalService_SignalWorkflow_Call 

type MockTemporalService_SignalWorkflow_Call struct {
	*mock.Call
}

MockTemporalService_SignalWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SignalWorkflow'

func (*MockTemporalService_SignalWorkflow_Call) Return 

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

func (*MockTemporalService_SignalWorkflow_Call) Run 

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

func (*MockTemporalService_SignalWorkflow_Call) RunAndReturn 

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

type MockTemporalService_TerminateWorkflow_Call 

type MockTemporalService_TerminateWorkflow_Call struct {
	*mock.Call
}

MockTemporalService_TerminateWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TerminateWorkflow'

func (*MockTemporalService_TerminateWorkflow_Call) Return 

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

func (*MockTemporalService_TerminateWorkflow_Call) Run 

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

func (*MockTemporalService_TerminateWorkflow_Call) RunAndReturn 

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

Source Files

View all Source files

Directories

Path Synopsis

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.