mocks

package
v1.16.8 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Mock implementation of a workflow repo to be used for tests.

Mock implementation of a task repo to be used for tests.

Mock implementation of a workflow repo to be used for tests.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMockExecutionRepo 

func NewMockExecutionRepo() interfaces.ExecutionRepoInterface

func NewMockLaunchPlanRepo 

func NewMockLaunchPlanRepo() interfaces.LaunchPlanRepoInterface

func NewMockNodeExecutionRepo 

func NewMockNodeExecutionRepo() interfaces.NodeExecutionRepoInterface

func NewMockProjectRepo 

func NewMockProjectRepo() interfaces.ProjectRepoInterface

func NewMockRepository 

func NewMockRepository() interfaces.Repository

func NewMockResourceRepo 

func NewMockResourceRepo() interfaces.ResourceRepoInterface

func NewMockTaskExecutionRepo 

func NewMockTaskExecutionRepo() interfaces.TaskExecutionRepoInterface

func NewMockTaskRepo 

func NewMockTaskRepo() interfaces.TaskRepoInterface

func NewMockWorkflowRepo 

func NewMockWorkflowRepo() interfaces.WorkflowRepoInterface

Types

type CountExecutionFunc 

type CountExecutionFunc func(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

type CountNodeExecutionFunc 

type CountNodeExecutionFunc func(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

type CountTaskExecutionFunc 

type CountTaskExecutionFunc func(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

type CreateExecutionFunc 

type CreateExecutionFunc func(ctx context.Context, input models.Execution) error

type CreateLaunchPlanFunc 

type CreateLaunchPlanFunc func(input models.LaunchPlan) error

type CreateNodeExecutionFunc 

type CreateNodeExecutionFunc func(ctx context.Context, input *models.NodeExecution) error

type CreateOrUpdateResourceFunction 

type CreateOrUpdateResourceFunction func(ctx context.Context, input models.Resource) error

type CreateProjectFunction 

type CreateProjectFunction func(ctx context.Context, project models.Project) error

type CreateTaskExecutionFunc 

type CreateTaskExecutionFunc func(ctx context.Context, input models.TaskExecution) error

type CreateTaskFunc 

type CreateTaskFunc func(input models.Task, descriptionEntity *models.DescriptionEntity) error

type CreateWorkflowFunc 

type CreateWorkflowFunc func(input models.Workflow, descriptionEntity *models.DescriptionEntity) error

type DeleteResourceFunction 

type DeleteResourceFunction func(ctx context.Context, ID interfaces.ResourceID) error

type DescriptionEntityRepoInterface added in v1.16.0 

type DescriptionEntityRepoInterface struct {
	mock.Mock
}

DescriptionEntityRepoInterface is an autogenerated mock type for the DescriptionEntityRepoInterface type

func NewDescriptionEntityRepoInterface added in v1.16.0 

func NewDescriptionEntityRepoInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *DescriptionEntityRepoInterface

NewDescriptionEntityRepoInterface creates a new instance of DescriptionEntityRepoInterface. 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 (*DescriptionEntityRepoInterface) EXPECT added in v1.16.0 

func (_m *DescriptionEntityRepoInterface) EXPECT() *DescriptionEntityRepoInterface_Expecter

func (*DescriptionEntityRepoInterface) Get added in v1.16.0 

func (_m *DescriptionEntityRepoInterface) Get(ctx context.Context, input interfaces.GetDescriptionEntityInput) (models.DescriptionEntity, error)

Get provides a mock function with given fields: ctx, input

func (*DescriptionEntityRepoInterface) List added in v1.16.0 

func (_m *DescriptionEntityRepoInterface) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.DescriptionEntityCollectionOutput, error)

List provides a mock function with given fields: ctx, input

type DescriptionEntityRepoInterface_Expecter added in v1.16.0 

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

func (*DescriptionEntityRepoInterface_Expecter) Get added in v1.16.0 

func (_e *DescriptionEntityRepoInterface_Expecter) Get(ctx interface{}, input interface{}) *DescriptionEntityRepoInterface_Get_Call

Get is a helper method to define mock.On call

  • ctx context.Context
  • input interfaces.GetDescriptionEntityInput

func (*DescriptionEntityRepoInterface_Expecter) List added in v1.16.0 

func (_e *DescriptionEntityRepoInterface_Expecter) List(ctx interface{}, input interface{}) *DescriptionEntityRepoInterface_List_Call

List is a helper method to define mock.On call

  • ctx context.Context
  • input interfaces.ListResourceInput

type DescriptionEntityRepoInterface_Get_Call added in v1.16.0 

type DescriptionEntityRepoInterface_Get_Call struct {
	*mock.Call
}

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

func (*DescriptionEntityRepoInterface_Get_Call) Return added in v1.16.0 

func (_c *DescriptionEntityRepoInterface_Get_Call) Return(_a0 models.DescriptionEntity, _a1 error) *DescriptionEntityRepoInterface_Get_Call

func (*DescriptionEntityRepoInterface_Get_Call) Run added in v1.16.0 

func (_c *DescriptionEntityRepoInterface_Get_Call) Run(run func(ctx context.Context, input interfaces.GetDescriptionEntityInput)) *DescriptionEntityRepoInterface_Get_Call

func (*DescriptionEntityRepoInterface_Get_Call) RunAndReturn added in v1.16.0 

func (_c *DescriptionEntityRepoInterface_Get_Call) RunAndReturn(run func(context.Context, interfaces.GetDescriptionEntityInput) (models.DescriptionEntity, error)) *DescriptionEntityRepoInterface_Get_Call

type DescriptionEntityRepoInterface_List_Call added in v1.16.0 

type DescriptionEntityRepoInterface_List_Call struct {
	*mock.Call
}

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

func (*DescriptionEntityRepoInterface_List_Call) Return added in v1.16.0 

func (_c *DescriptionEntityRepoInterface_List_Call) Return(_a0 interfaces.DescriptionEntityCollectionOutput, _a1 error) *DescriptionEntityRepoInterface_List_Call

func (*DescriptionEntityRepoInterface_List_Call) Run added in v1.16.0 

func (_c *DescriptionEntityRepoInterface_List_Call) Run(run func(ctx context.Context, input interfaces.ListResourceInput)) *DescriptionEntityRepoInterface_List_Call

func (*DescriptionEntityRepoInterface_List_Call) RunAndReturn added in v1.16.0 

func (_c *DescriptionEntityRepoInterface_List_Call) RunAndReturn(run func(context.Context, interfaces.ListResourceInput) (interfaces.DescriptionEntityCollectionOutput, error)) *DescriptionEntityRepoInterface_List_Call

type ExecutionEventRepoInterface 

type ExecutionEventRepoInterface struct {
	mock.Mock
}

ExecutionEventRepoInterface is an autogenerated mock type for the ExecutionEventRepoInterface type

func NewExecutionEventRepoInterface added in v1.15.1 

func NewExecutionEventRepoInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *ExecutionEventRepoInterface

NewExecutionEventRepoInterface creates a new instance of ExecutionEventRepoInterface. 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 (*ExecutionEventRepoInterface) Create 

func (_m *ExecutionEventRepoInterface) Create(ctx context.Context, input models.ExecutionEvent) error

Create provides a mock function with given fields: ctx, input

func (*ExecutionEventRepoInterface) EXPECT added in v1.15.1 

func (_m *ExecutionEventRepoInterface) EXPECT() *ExecutionEventRepoInterface_Expecter

type ExecutionEventRepoInterface_Create_Call added in v1.15.1 

type ExecutionEventRepoInterface_Create_Call struct {
	*mock.Call
}

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

func (*ExecutionEventRepoInterface_Create_Call) Return added in v1.15.1 

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

func (*ExecutionEventRepoInterface_Create_Call) Run added in v1.15.1 

func (_c *ExecutionEventRepoInterface_Create_Call) Run(run func(ctx context.Context, input models.ExecutionEvent)) *ExecutionEventRepoInterface_Create_Call

func (*ExecutionEventRepoInterface_Create_Call) RunAndReturn added in v1.15.1 

func (_c *ExecutionEventRepoInterface_Create_Call) RunAndReturn(run func(context.Context, models.ExecutionEvent) error) *ExecutionEventRepoInterface_Create_Call

type ExecutionEventRepoInterface_Expecter added in v1.15.1 

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

func (*ExecutionEventRepoInterface_Expecter) Create added in v1.15.1 

func (_e *ExecutionEventRepoInterface_Expecter) Create(ctx interface{}, input interface{}) *ExecutionEventRepoInterface_Create_Call

Create is a helper method to define mock.On call

  • ctx context.Context
  • input models.ExecutionEvent

type ExistsNodeExecutionFunc 

type ExistsNodeExecutionFunc func(ctx context.Context, input interfaces.NodeExecutionResource) (bool, error)

type GetExecutionFunc 

type GetExecutionFunc func(ctx context.Context, input interfaces.Identifier) (models.Execution, error)

type GetLaunchPlanFunc 

type GetLaunchPlanFunc func(input interfaces.Identifier) (models.LaunchPlan, error)

type GetNodeExecutionFunc 

type GetNodeExecutionFunc func(ctx context.Context, input interfaces.NodeExecutionResource) (models.NodeExecution, error)

type GetProjectFunction 

type GetProjectFunction func(ctx context.Context, projectID string) (models.Project, error)

type GetResourceFunction 

type GetResourceFunction func(ctx context.Context, ID interfaces.ResourceID) (
	models.Resource, error)

type GetTaskExecutionFunc 

type GetTaskExecutionFunc func(ctx context.Context, input interfaces.GetTaskExecutionInput) (models.TaskExecution, error)

type GetTaskFunc 

type GetTaskFunc func(input interfaces.Identifier) (models.Task, error)

type GetWorkflowFunc 

type GetWorkflowFunc func(input interfaces.Identifier) (models.Workflow, error)

type ListAllResourcesFunction 

type ListAllResourcesFunction func(ctx context.Context, resourceType string) ([]models.Resource, error)

type ListExecutionFunc 

type ListExecutionFunc func(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.ExecutionCollectionOutput, error)

type ListIdentifiersFunc 

type ListIdentifiersFunc func(input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error)

type ListLaunchPlanFunc 

type ListLaunchPlanFunc func(input interfaces.ListResourceInput) (interfaces.LaunchPlanCollectionOutput, error)

type ListLaunchPlanIdentifiersFunc 

type ListLaunchPlanIdentifiersFunc func(input interfaces.ListResourceInput) (
	interfaces.LaunchPlanCollectionOutput, error)

type ListNodeExecutionFunc 

type ListNodeExecutionFunc func(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.NodeExecutionCollectionOutput, error)

type ListProjectsFunction 

type ListProjectsFunction func(ctx context.Context, input interfaces.ListResourceInput) ([]models.Project, error)

type ListTaskExecutionFunc 

type ListTaskExecutionFunc func(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskExecutionCollectionOutput, error)

type ListTaskFunc 

type ListTaskFunc func(input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error)

type ListTaskIdentifiersFunc 

type ListTaskIdentifiersFunc func(input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error)

type ListWorkflowFunc 

type ListWorkflowFunc func(input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error)

type MockExecutionRepo 

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

func (*MockExecutionRepo) Count 

func (r *MockExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

func (*MockExecutionRepo) Create 

func (r *MockExecutionRepo) Create(ctx context.Context, input models.Execution, executionTagModel []*models.ExecutionTag) error

func (*MockExecutionRepo) Get 

func (r *MockExecutionRepo) Get(ctx context.Context, input interfaces.Identifier) (models.Execution, error)

func (*MockExecutionRepo) List 

func (r *MockExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.ExecutionCollectionOutput, error)

func (*MockExecutionRepo) SetCountCallback 

func (r *MockExecutionRepo) SetCountCallback(countFunction CountExecutionFunc)

func (*MockExecutionRepo) SetCreateCallback 

func (r *MockExecutionRepo) SetCreateCallback(createFunction CreateExecutionFunc)

func (*MockExecutionRepo) SetGetCallback 

func (r *MockExecutionRepo) SetGetCallback(getFunction GetExecutionFunc)

func (*MockExecutionRepo) SetListCallback 

func (r *MockExecutionRepo) SetListCallback(listFunction ListExecutionFunc)

func (*MockExecutionRepo) SetUpdateCallback 

func (r *MockExecutionRepo) SetUpdateCallback(updateFunction UpdateExecutionFunc)

func (*MockExecutionRepo) Update 

func (r *MockExecutionRepo) Update(ctx context.Context, execution models.Execution) error

type MockLaunchPlanRepo 

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

func (*MockLaunchPlanRepo) Create 

func (r *MockLaunchPlanRepo) Create(ctx context.Context, input models.LaunchPlan) error

func (*MockLaunchPlanRepo) Get 

func (r *MockLaunchPlanRepo) Get(
	ctx context.Context, input interfaces.Identifier) (models.LaunchPlan, error)

func (*MockLaunchPlanRepo) List 

func (r *MockLaunchPlanRepo) List(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.LaunchPlanCollectionOutput, error)

func (*MockLaunchPlanRepo) ListLaunchPlanIdentifiers 

func (r *MockLaunchPlanRepo) ListLaunchPlanIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.LaunchPlanCollectionOutput, error)

func (*MockLaunchPlanRepo) SetActive 

func (r *MockLaunchPlanRepo) SetActive(
	ctx context.Context, toEnable models.LaunchPlan, toDisable *models.LaunchPlan) error

func (*MockLaunchPlanRepo) SetCreateCallback 

func (r *MockLaunchPlanRepo) SetCreateCallback(createFunction CreateLaunchPlanFunc)

func (*MockLaunchPlanRepo) SetGetCallback 

func (r *MockLaunchPlanRepo) SetGetCallback(getFunction GetLaunchPlanFunc)

func (*MockLaunchPlanRepo) SetListCallback 

func (r *MockLaunchPlanRepo) SetListCallback(listFunction ListLaunchPlanFunc)

func (*MockLaunchPlanRepo) SetListLaunchPlanIdentifiersCallback 

func (r *MockLaunchPlanRepo) SetListLaunchPlanIdentifiersCallback(fn ListLaunchPlanIdentifiersFunc)

func (*MockLaunchPlanRepo) SetSetActiveCallback 

func (r *MockLaunchPlanRepo) SetSetActiveCallback(setActiveFunction SetActiveLaunchPlanFunc)

func (*MockLaunchPlanRepo) SetUpdateCallback 

func (r *MockLaunchPlanRepo) SetUpdateCallback(updateFunction UpdateLaunchPlanFunc)

func (*MockLaunchPlanRepo) Update 

func (r *MockLaunchPlanRepo) Update(ctx context.Context, launchPlan models.LaunchPlan) error

type MockNodeExecutionRepo 

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

func (*MockNodeExecutionRepo) Count 

func (r *MockNodeExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

func (*MockNodeExecutionRepo) Create 

func (r *MockNodeExecutionRepo) Create(ctx context.Context, input *models.NodeExecution) error

func (*MockNodeExecutionRepo) Exists 

func (r *MockNodeExecutionRepo) Exists(ctx context.Context, input interfaces.NodeExecutionResource) (bool, error)

func (*MockNodeExecutionRepo) Get 

func (r *MockNodeExecutionRepo) Get(ctx context.Context, input interfaces.NodeExecutionResource) (models.NodeExecution, error)

func (*MockNodeExecutionRepo) GetWithChildren 

func (r *MockNodeExecutionRepo) GetWithChildren(ctx context.Context, input interfaces.NodeExecutionResource) (models.NodeExecution, error)

func (*MockNodeExecutionRepo) List 

func (r *MockNodeExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.NodeExecutionCollectionOutput, error)

func (*MockNodeExecutionRepo) SetCountCallback 

func (r *MockNodeExecutionRepo) SetCountCallback(countFunction CountNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetCreateCallback 

func (r *MockNodeExecutionRepo) SetCreateCallback(createFunction CreateNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetExistsCallback 

func (r *MockNodeExecutionRepo) SetExistsCallback(existsFunction ExistsNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetGetCallback 

func (r *MockNodeExecutionRepo) SetGetCallback(getFunction GetNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetGetWithChildrenCallback 

func (r *MockNodeExecutionRepo) SetGetWithChildrenCallback(getWithChildrenFunction GetNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetListCallback 

func (r *MockNodeExecutionRepo) SetListCallback(listFunction ListNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetUpdateCallback 

func (r *MockNodeExecutionRepo) SetUpdateCallback(updateFunction UpdateNodeExecutionFunc)

func (*MockNodeExecutionRepo) Update 

func (r *MockNodeExecutionRepo) Update(ctx context.Context, nodeExecution *models.NodeExecution) error

type MockProjectRepo 

type MockProjectRepo struct {
	CreateFunction        CreateProjectFunction
	GetFunction           GetProjectFunction
	ListProjectsFunction  ListProjectsFunction
	UpdateProjectFunction UpdateProjectFunction
}

func (*MockProjectRepo) Create 

func (r *MockProjectRepo) Create(ctx context.Context, project models.Project) error

func (*MockProjectRepo) Get 

func (r *MockProjectRepo) Get(ctx context.Context, projectID string) (models.Project, error)

func (*MockProjectRepo) List 

func (r *MockProjectRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Project, error)

func (*MockProjectRepo) UpdateProject 

func (r *MockProjectRepo) UpdateProject(ctx context.Context, projectUpdate models.Project) error

type MockRepository 

type MockRepository struct {
	ExecutionEventRepoIface interfaces.ExecutionEventRepoInterface

	NodeExecutionEventRepoIface interfaces.NodeExecutionEventRepoInterface
	ProjectRepoIface            interfaces.ProjectRepoInterface
	// contains filtered or unexported fields
}

func (*MockRepository) DescriptionEntityRepo 

func (r *MockRepository) DescriptionEntityRepo() interfaces.DescriptionEntityRepoInterface

func (*MockRepository) ExecutionEventRepo 

func (r *MockRepository) ExecutionEventRepo() interfaces.ExecutionEventRepoInterface

func (*MockRepository) ExecutionRepo 

func (r *MockRepository) ExecutionRepo() interfaces.ExecutionRepoInterface

func (*MockRepository) GetGormDB 

func (r *MockRepository) GetGormDB() *gorm.DB

func (*MockRepository) LaunchPlanRepo 

func (r *MockRepository) LaunchPlanRepo() interfaces.LaunchPlanRepoInterface

func (*MockRepository) NamedEntityRepo 

func (r *MockRepository) NamedEntityRepo() interfaces.NamedEntityRepoInterface

func (*MockRepository) NodeExecutionEventRepo 

func (r *MockRepository) NodeExecutionEventRepo() interfaces.NodeExecutionEventRepoInterface

func (*MockRepository) NodeExecutionRepo 

func (r *MockRepository) NodeExecutionRepo() interfaces.NodeExecutionRepoInterface

func (*MockRepository) ProjectRepo 

func (r *MockRepository) ProjectRepo() interfaces.ProjectRepoInterface

func (*MockRepository) ResourceRepo 

func (r *MockRepository) ResourceRepo() interfaces.ResourceRepoInterface

func (*MockRepository) SchedulableEntityRepo 

func (r *MockRepository) SchedulableEntityRepo() sIface.SchedulableEntityRepoInterface

func (*MockRepository) ScheduleEntitiesSnapshotRepo 

func (r *MockRepository) ScheduleEntitiesSnapshotRepo() sIface.ScheduleEntitiesSnapShotRepoInterface

func (*MockRepository) SignalRepo 

func (r *MockRepository) SignalRepo() interfaces.SignalRepoInterface

func (*MockRepository) TaskExecutionRepo 

func (r *MockRepository) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface

func (*MockRepository) TaskRepo 

func (r *MockRepository) TaskRepo() interfaces.TaskRepoInterface

func (*MockRepository) WorkflowRepo 

func (r *MockRepository) WorkflowRepo() interfaces.WorkflowRepoInterface

type MockResourceRepo 

type MockResourceRepo struct {
	CreateOrUpdateFunction CreateOrUpdateResourceFunction
	GetFunction            GetResourceFunction
	DeleteFunction         DeleteResourceFunction
	ListAllFunction        ListAllResourcesFunction
}

func (*MockResourceRepo) CreateOrUpdate 

func (r *MockResourceRepo) CreateOrUpdate(ctx context.Context, input models.Resource) error

func (*MockResourceRepo) Delete 

func (r *MockResourceRepo) Delete(ctx context.Context, ID interfaces.ResourceID) error

func (*MockResourceRepo) Get 

func (r *MockResourceRepo) Get(ctx context.Context, ID interfaces.ResourceID) (
	models.Resource, error)

func (*MockResourceRepo) GetProjectLevel 

func (r *MockResourceRepo) GetProjectLevel(ctx context.Context, ID interfaces.ResourceID) (
	models.Resource, error)

func (*MockResourceRepo) GetRaw 

func (r *MockResourceRepo) GetRaw(ctx context.Context, ID interfaces.ResourceID) (
	models.Resource, error)

func (*MockResourceRepo) ListAll 

func (r *MockResourceRepo) ListAll(ctx context.Context, resourceType string) ([]models.Resource, error)

type MockTaskExecutionRepo 

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

func (*MockTaskExecutionRepo) Count 

func (r *MockTaskExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

func (*MockTaskExecutionRepo) Create 

func (r *MockTaskExecutionRepo) Create(ctx context.Context, input models.TaskExecution) error

func (*MockTaskExecutionRepo) Get 

func (r *MockTaskExecutionRepo) Get(ctx context.Context, input interfaces.GetTaskExecutionInput) (models.TaskExecution, error)

func (*MockTaskExecutionRepo) List 

func (r *MockTaskExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskExecutionCollectionOutput, error)

func (*MockTaskExecutionRepo) SetCountCallback 

func (r *MockTaskExecutionRepo) SetCountCallback(countFunction CountTaskExecutionFunc)

func (*MockTaskExecutionRepo) SetCreateCallback 

func (r *MockTaskExecutionRepo) SetCreateCallback(createFunction CreateTaskExecutionFunc)

func (*MockTaskExecutionRepo) SetGetCallback 

func (r *MockTaskExecutionRepo) SetGetCallback(getFunction GetTaskExecutionFunc)

func (*MockTaskExecutionRepo) SetListCallback 

func (r *MockTaskExecutionRepo) SetListCallback(listFunction ListTaskExecutionFunc)

func (*MockTaskExecutionRepo) SetUpdateCallback 

func (r *MockTaskExecutionRepo) SetUpdateCallback(updateFunction UpdateTaskExecutionFunc)

func (*MockTaskExecutionRepo) Update 

func (r *MockTaskExecutionRepo) Update(ctx context.Context, execution models.TaskExecution) error

type MockTaskRepo 

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

func (*MockTaskRepo) Create 

func (r *MockTaskRepo) Create(ctx context.Context, input models.Task, descriptionEntity *models.DescriptionEntity) error

func (*MockTaskRepo) Get 

func (r *MockTaskRepo) Get(ctx context.Context, input interfaces.Identifier) (models.Task, error)

func (*MockTaskRepo) List 

func (r *MockTaskRepo) List(
	ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error)

func (*MockTaskRepo) ListTaskIdentifiers 

func (r *MockTaskRepo) ListTaskIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.TaskCollectionOutput, error)

func (*MockTaskRepo) SetCreateCallback 

func (r *MockTaskRepo) SetCreateCallback(createFunction CreateTaskFunc)

func (*MockTaskRepo) SetGetCallback 

func (r *MockTaskRepo) SetGetCallback(getFunction GetTaskFunc)

func (*MockTaskRepo) SetListCallback 

func (r *MockTaskRepo) SetListCallback(listFunction ListTaskFunc)

func (*MockTaskRepo) SetListTaskIdentifiersCallback 

func (r *MockTaskRepo) SetListTaskIdentifiersCallback(listFunction ListTaskIdentifiersFunc)

type MockWorkflowRepo 

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

func (*MockWorkflowRepo) Create 

func (r *MockWorkflowRepo) Create(ctx context.Context, input models.Workflow, descriptionEntity *models.DescriptionEntity) error

func (*MockWorkflowRepo) Get 

func (r *MockWorkflowRepo) Get(ctx context.Context, input interfaces.Identifier) (models.Workflow, error)

func (*MockWorkflowRepo) List 

func (r *MockWorkflowRepo) List(
	ctx context.Context, input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error)

func (*MockWorkflowRepo) ListIdentifiers 

func (r *MockWorkflowRepo) ListIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.WorkflowCollectionOutput, error)

func (*MockWorkflowRepo) SetCreateCallback 

func (r *MockWorkflowRepo) SetCreateCallback(createFunction CreateWorkflowFunc)

func (*MockWorkflowRepo) SetGetCallback 

func (r *MockWorkflowRepo) SetGetCallback(getFunction GetWorkflowFunc)

func (*MockWorkflowRepo) SetListCallback 

func (r *MockWorkflowRepo) SetListCallback(listFunction ListWorkflowFunc)

func (*MockWorkflowRepo) SetListIdentifiersFunc 

func (r *MockWorkflowRepo) SetListIdentifiersFunc(fn ListIdentifiersFunc)

type NamedEntityRepoInterface added in v1.16.0 

type NamedEntityRepoInterface struct {
	mock.Mock
}

NamedEntityRepoInterface is an autogenerated mock type for the NamedEntityRepoInterface type

func NewNamedEntityRepoInterface added in v1.16.0 

func NewNamedEntityRepoInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *NamedEntityRepoInterface

NewNamedEntityRepoInterface creates a new instance of NamedEntityRepoInterface. 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 (*NamedEntityRepoInterface) EXPECT added in v1.16.0 

func (_m *NamedEntityRepoInterface) EXPECT() *NamedEntityRepoInterface_Expecter

func (*NamedEntityRepoInterface) Get added in v1.16.0 

func (_m *NamedEntityRepoInterface) Get(ctx context.Context, input interfaces.GetNamedEntityInput) (models.NamedEntity, error)

Get provides a mock function with given fields: ctx, input

func (*NamedEntityRepoInterface) List added in v1.16.0 

func (_m *NamedEntityRepoInterface) List(ctx context.Context, input interfaces.ListNamedEntityInput) (interfaces.NamedEntityCollectionOutput, error)

List provides a mock function with given fields: ctx, input

func (*NamedEntityRepoInterface) Update added in v1.16.0 

func (_m *NamedEntityRepoInterface) Update(ctx context.Context, input models.NamedEntity) error

Update provides a mock function with given fields: ctx, input

type NamedEntityRepoInterface_Expecter added in v1.16.0 

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

func (*NamedEntityRepoInterface_Expecter) Get added in v1.16.0 

func (_e *NamedEntityRepoInterface_Expecter) Get(ctx interface{}, input interface{}) *NamedEntityRepoInterface_Get_Call

Get is a helper method to define mock.On call

  • ctx context.Context
  • input interfaces.GetNamedEntityInput

func (*NamedEntityRepoInterface_Expecter) List added in v1.16.0 

func (_e *NamedEntityRepoInterface_Expecter) List(ctx interface{}, input interface{}) *NamedEntityRepoInterface_List_Call

List is a helper method to define mock.On call

  • ctx context.Context
  • input interfaces.ListNamedEntityInput

func (*NamedEntityRepoInterface_Expecter) Update added in v1.16.0 

func (_e *NamedEntityRepoInterface_Expecter) Update(ctx interface{}, input interface{}) *NamedEntityRepoInterface_Update_Call

Update is a helper method to define mock.On call

  • ctx context.Context
  • input models.NamedEntity

type NamedEntityRepoInterface_Get_Call added in v1.16.0 

type NamedEntityRepoInterface_Get_Call struct {
	*mock.Call
}

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

func (*NamedEntityRepoInterface_Get_Call) Return added in v1.16.0 

func (_c *NamedEntityRepoInterface_Get_Call) Return(_a0 models.NamedEntity, _a1 error) *NamedEntityRepoInterface_Get_Call

func (*NamedEntityRepoInterface_Get_Call) Run added in v1.16.0 

func (_c *NamedEntityRepoInterface_Get_Call) Run(run func(ctx context.Context, input interfaces.GetNamedEntityInput)) *NamedEntityRepoInterface_Get_Call

func (*NamedEntityRepoInterface_Get_Call) RunAndReturn added in v1.16.0 

func (_c *NamedEntityRepoInterface_Get_Call) RunAndReturn(run func(context.Context, interfaces.GetNamedEntityInput) (models.NamedEntity, error)) *NamedEntityRepoInterface_Get_Call

type NamedEntityRepoInterface_List_Call added in v1.16.0 

type NamedEntityRepoInterface_List_Call struct {
	*mock.Call
}

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

func (*NamedEntityRepoInterface_List_Call) Return added in v1.16.0 

func (_c *NamedEntityRepoInterface_List_Call) Return(_a0 interfaces.NamedEntityCollectionOutput, _a1 error) *NamedEntityRepoInterface_List_Call

func (*NamedEntityRepoInterface_List_Call) Run added in v1.16.0 

func (_c *NamedEntityRepoInterface_List_Call) Run(run func(ctx context.Context, input interfaces.ListNamedEntityInput)) *NamedEntityRepoInterface_List_Call

func (*NamedEntityRepoInterface_List_Call) RunAndReturn added in v1.16.0 

func (_c *NamedEntityRepoInterface_List_Call) RunAndReturn(run func(context.Context, interfaces.ListNamedEntityInput) (interfaces.NamedEntityCollectionOutput, error)) *NamedEntityRepoInterface_List_Call

type NamedEntityRepoInterface_Update_Call added in v1.16.0 

type NamedEntityRepoInterface_Update_Call struct {
	*mock.Call
}

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

func (*NamedEntityRepoInterface_Update_Call) Return added in v1.16.0 

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

func (*NamedEntityRepoInterface_Update_Call) Run added in v1.16.0 

func (_c *NamedEntityRepoInterface_Update_Call) Run(run func(ctx context.Context, input models.NamedEntity)) *NamedEntityRepoInterface_Update_Call

func (*NamedEntityRepoInterface_Update_Call) RunAndReturn added in v1.16.0 

func (_c *NamedEntityRepoInterface_Update_Call) RunAndReturn(run func(context.Context, models.NamedEntity) error) *NamedEntityRepoInterface_Update_Call

type NodeExecutionEventRepoInterface 

type NodeExecutionEventRepoInterface struct {
	mock.Mock
}

NodeExecutionEventRepoInterface is an autogenerated mock type for the NodeExecutionEventRepoInterface type

func NewNodeExecutionEventRepoInterface added in v1.15.1 

func NewNodeExecutionEventRepoInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeExecutionEventRepoInterface

NewNodeExecutionEventRepoInterface creates a new instance of NodeExecutionEventRepoInterface. 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 (*NodeExecutionEventRepoInterface) Create 

func (_m *NodeExecutionEventRepoInterface) Create(ctx context.Context, input models.NodeExecutionEvent) error

Create provides a mock function with given fields: ctx, input

func (*NodeExecutionEventRepoInterface) EXPECT added in v1.15.1 

func (_m *NodeExecutionEventRepoInterface) EXPECT() *NodeExecutionEventRepoInterface_Expecter

type NodeExecutionEventRepoInterface_Create_Call added in v1.15.1 

type NodeExecutionEventRepoInterface_Create_Call struct {
	*mock.Call
}

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

func (*NodeExecutionEventRepoInterface_Create_Call) Return added in v1.15.1 

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

func (*NodeExecutionEventRepoInterface_Create_Call) Run added in v1.15.1 

func (_c *NodeExecutionEventRepoInterface_Create_Call) Run(run func(ctx context.Context, input models.NodeExecutionEvent)) *NodeExecutionEventRepoInterface_Create_Call

func (*NodeExecutionEventRepoInterface_Create_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionEventRepoInterface_Create_Call) RunAndReturn(run func(context.Context, models.NodeExecutionEvent) error) *NodeExecutionEventRepoInterface_Create_Call

type NodeExecutionEventRepoInterface_Expecter added in v1.15.1 

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

func (*NodeExecutionEventRepoInterface_Expecter) Create added in v1.15.1 

func (_e *NodeExecutionEventRepoInterface_Expecter) Create(ctx interface{}, input interface{}) *NodeExecutionEventRepoInterface_Create_Call

Create is a helper method to define mock.On call

  • ctx context.Context
  • input models.NodeExecutionEvent

type SetActiveLaunchPlanFunc 

type SetActiveLaunchPlanFunc func(toEnable models.LaunchPlan, toDisable *models.LaunchPlan) error

type SignalRepoInterface 

type SignalRepoInterface struct {
	mock.Mock
}

SignalRepoInterface is an autogenerated mock type for the SignalRepoInterface type

func NewSignalRepoInterface added in v1.15.1 

func NewSignalRepoInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *SignalRepoInterface

NewSignalRepoInterface creates a new instance of SignalRepoInterface. 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 (*SignalRepoInterface) EXPECT added in v1.15.1 

func (_m *SignalRepoInterface) EXPECT() *SignalRepoInterface_Expecter

func (*SignalRepoInterface) Get 

func (_m *SignalRepoInterface) Get(ctx context.Context, input models.SignalKey) (models.Signal, error)

Get provides a mock function with given fields: ctx, input

func (*SignalRepoInterface) GetOrCreate 

func (_m *SignalRepoInterface) GetOrCreate(ctx context.Context, input *models.Signal) error

GetOrCreate provides a mock function with given fields: ctx, input

func (*SignalRepoInterface) List 

func (_m *SignalRepoInterface) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Signal, error)

List provides a mock function with given fields: ctx, input

func (*SignalRepoInterface) Update 

func (_m *SignalRepoInterface) Update(ctx context.Context, input models.SignalKey, value []byte) error

Update provides a mock function with given fields: ctx, input, value

type SignalRepoInterface_Expecter added in v1.15.1 

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

func (*SignalRepoInterface_Expecter) Get added in v1.15.1 

func (_e *SignalRepoInterface_Expecter) Get(ctx interface{}, input interface{}) *SignalRepoInterface_Get_Call

Get is a helper method to define mock.On call

  • ctx context.Context
  • input models.SignalKey

func (*SignalRepoInterface_Expecter) GetOrCreate added in v1.15.1 

func (_e *SignalRepoInterface_Expecter) GetOrCreate(ctx interface{}, input interface{}) *SignalRepoInterface_GetOrCreate_Call

GetOrCreate is a helper method to define mock.On call

  • ctx context.Context
  • input *models.Signal

func (*SignalRepoInterface_Expecter) List added in v1.15.1 

func (_e *SignalRepoInterface_Expecter) List(ctx interface{}, input interface{}) *SignalRepoInterface_List_Call

List is a helper method to define mock.On call

  • ctx context.Context
  • input interfaces.ListResourceInput

func (*SignalRepoInterface_Expecter) Update added in v1.15.1 

func (_e *SignalRepoInterface_Expecter) Update(ctx interface{}, input interface{}, value interface{}) *SignalRepoInterface_Update_Call

Update is a helper method to define mock.On call

  • ctx context.Context
  • input models.SignalKey
  • value []byte

type SignalRepoInterface_GetOrCreate_Call added in v1.15.1 

type SignalRepoInterface_GetOrCreate_Call struct {
	*mock.Call
}

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

func (*SignalRepoInterface_GetOrCreate_Call) Return added in v1.15.1 

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

func (*SignalRepoInterface_GetOrCreate_Call) Run added in v1.15.1 

func (_c *SignalRepoInterface_GetOrCreate_Call) Run(run func(ctx context.Context, input *models.Signal)) *SignalRepoInterface_GetOrCreate_Call

func (*SignalRepoInterface_GetOrCreate_Call) RunAndReturn added in v1.15.1 

func (_c *SignalRepoInterface_GetOrCreate_Call) RunAndReturn(run func(context.Context, *models.Signal) error) *SignalRepoInterface_GetOrCreate_Call

type SignalRepoInterface_Get_Call added in v1.15.1 

type SignalRepoInterface_Get_Call struct {
	*mock.Call
}

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

func (*SignalRepoInterface_Get_Call) Return added in v1.15.1 

func (_c *SignalRepoInterface_Get_Call) Return(_a0 models.Signal, _a1 error) *SignalRepoInterface_Get_Call

func (*SignalRepoInterface_Get_Call) Run added in v1.15.1 

func (_c *SignalRepoInterface_Get_Call) Run(run func(ctx context.Context, input models.SignalKey)) *SignalRepoInterface_Get_Call

func (*SignalRepoInterface_Get_Call) RunAndReturn added in v1.15.1 

func (_c *SignalRepoInterface_Get_Call) RunAndReturn(run func(context.Context, models.SignalKey) (models.Signal, error)) *SignalRepoInterface_Get_Call

type SignalRepoInterface_List_Call added in v1.15.1 

type SignalRepoInterface_List_Call struct {
	*mock.Call
}

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

func (*SignalRepoInterface_List_Call) Return added in v1.15.1 

func (_c *SignalRepoInterface_List_Call) Return(_a0 []models.Signal, _a1 error) *SignalRepoInterface_List_Call

func (*SignalRepoInterface_List_Call) Run added in v1.15.1 

func (_c *SignalRepoInterface_List_Call) Run(run func(ctx context.Context, input interfaces.ListResourceInput)) *SignalRepoInterface_List_Call

func (*SignalRepoInterface_List_Call) RunAndReturn added in v1.15.1 

func (_c *SignalRepoInterface_List_Call) RunAndReturn(run func(context.Context, interfaces.ListResourceInput) ([]models.Signal, error)) *SignalRepoInterface_List_Call

type SignalRepoInterface_Update_Call added in v1.15.1 

type SignalRepoInterface_Update_Call struct {
	*mock.Call
}

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

func (*SignalRepoInterface_Update_Call) Return added in v1.15.1 

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

func (*SignalRepoInterface_Update_Call) Run added in v1.15.1 

func (_c *SignalRepoInterface_Update_Call) Run(run func(ctx context.Context, input models.SignalKey, value []byte)) *SignalRepoInterface_Update_Call

func (*SignalRepoInterface_Update_Call) RunAndReturn added in v1.15.1 

func (_c *SignalRepoInterface_Update_Call) RunAndReturn(run func(context.Context, models.SignalKey, []byte) error) *SignalRepoInterface_Update_Call

type UpdateExecutionFunc 

type UpdateExecutionFunc func(ctx context.Context, execution models.Execution) error

type UpdateLaunchPlanFunc 

type UpdateLaunchPlanFunc func(input models.LaunchPlan) error

type UpdateNodeExecutionFunc 

type UpdateNodeExecutionFunc func(ctx context.Context, nodeExecution *models.NodeExecution) error

type UpdateProjectFunction 

type UpdateProjectFunction func(ctx context.Context, projectUpdate models.Project) error

type UpdateTaskExecutionFunc 

type UpdateTaskExecutionFunc func(ctx context.Context, execution models.TaskExecution) error

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.