mocks

package
v1.1.35 Latest Latest
Warning

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

Go to latest
Published: Aug 18, 2022 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Overview

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

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 NewMockNamedEntityRepo added in v0.1.5

func NewMockNamedEntityRepo() interfaces.NamedEntityRepoInterface

func NewMockNodeExecutionRepo

func NewMockNodeExecutionRepo() interfaces.NodeExecutionRepoInterface

func NewMockProjectRepo

func NewMockProjectRepo() interfaces.ProjectRepoInterface

func NewMockRepository

func NewMockRepository() interfaces.Repository

func NewMockResourceRepo added in v0.3.38

func NewMockResourceRepo() interfaces.ResourceRepoInterface

func NewMockTaskExecutionRepo

func NewMockTaskExecutionRepo() interfaces.TaskExecutionRepoInterface

func NewMockTaskRepo

func NewMockTaskRepo() interfaces.TaskRepoInterface

func NewMockWorkflowRepo

func NewMockWorkflowRepo() interfaces.WorkflowRepoInterface

Types

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 added in v0.3.38

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) error

type CreateWorkflowFunc

type CreateWorkflowFunc func(input models.Workflow) error

type DeleteResourceFunction added in v0.3.38

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

type ExecutionEventRepoInterface added in v0.4.12

type ExecutionEventRepoInterface struct {
	mock.Mock
}

ExecutionEventRepoInterface is an autogenerated mock type for the ExecutionEventRepoInterface type

func (*ExecutionEventRepoInterface) Create added in v0.4.12

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

func (*ExecutionEventRepoInterface) OnCreate added in v0.4.12

func (*ExecutionEventRepoInterface) OnCreateMatch added in v0.4.12

func (_m *ExecutionEventRepoInterface) OnCreateMatch(matchers ...interface{}) *ExecutionEventRepoInterface_Create

type ExecutionEventRepoInterface_Create added in v0.4.12

type ExecutionEventRepoInterface_Create struct {
	*mock.Call
}

func (ExecutionEventRepoInterface_Create) Return added in v0.4.12

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 GetNamedEntityFunc added in v0.1.5

type GetNamedEntityFunc func(input interfaces.GetNamedEntityInput) (models.NamedEntity, 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 added in v0.3.38

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 added in v0.3.38

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

type ListNamedEntityFunc added in v0.1.5

type ListProjectsFunction

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

type MockExecutionRepo

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

func (*MockExecutionRepo) Create

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

func (*MockExecutionRepo) Get

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) SetUpdateExecutionCallback

func (r *MockExecutionRepo) SetUpdateExecutionCallback(updateExecutionFunc 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 (*MockLaunchPlanRepo) ListLaunchPlanIdentifiers

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 MockNamedEntityRepo added in v0.1.5

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

func (*MockNamedEntityRepo) Get added in v0.1.5

func (*MockNamedEntityRepo) List added in v0.1.5

func (*MockNamedEntityRepo) SetGetCallback added in v0.1.5

func (r *MockNamedEntityRepo) SetGetCallback(getFunction GetNamedEntityFunc)

func (*MockNamedEntityRepo) SetListCallback added in v0.1.5

func (r *MockNamedEntityRepo) SetListCallback(listFunction ListNamedEntityFunc)

func (*MockNamedEntityRepo) SetUpdateCallback added in v0.1.5

func (r *MockNamedEntityRepo) SetUpdateCallback(updateFunction UpdateNamedEntityFunc)

func (*MockNamedEntityRepo) Update added in v0.1.5

func (r *MockNamedEntityRepo) Update(ctx context.Context, NamedEntity models.NamedEntity) error

type MockNodeExecutionRepo

type MockNodeExecutionRepo struct {
	GetWithChildrenFunction GetNodeExecutionFunc

	ExistsFunction func(ctx context.Context, input interfaces.NodeExecutionResource) (bool, error)
	// contains filtered or unexported fields
}

func (*MockNodeExecutionRepo) Create

func (*MockNodeExecutionRepo) Exists added in v0.4.6

func (*MockNodeExecutionRepo) Get

func (*MockNodeExecutionRepo) GetWithChildren added in v0.6.124

func (*MockNodeExecutionRepo) SetCreateCallback

func (r *MockNodeExecutionRepo) SetCreateCallback(createFunction CreateNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetGetCallback

func (r *MockNodeExecutionRepo) SetGetCallback(getFunction GetNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetListCallback

func (r *MockNodeExecutionRepo) SetListCallback(listFunction ListNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetListEventCallback

func (r *MockNodeExecutionRepo) SetListEventCallback(listEventFunction ListNodeExecutionEventFunc)

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 added in v0.3.38

func (*MockProjectRepo) UpdateProject added in v0.3.38

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) ExecutionEventRepo added in v0.4.12

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

func (*MockRepository) ExecutionRepo

func (*MockRepository) GetGormDB added in v0.6.100

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

func (*MockRepository) LaunchPlanRepo

func (*MockRepository) NamedEntityRepo added in v0.1.5

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

func (*MockRepository) NodeExecutionEventRepo added in v0.4.12

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

func (*MockRepository) NodeExecutionRepo

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

func (*MockRepository) ProjectRepo

func (*MockRepository) ResourceRepo added in v0.3.38

func (*MockRepository) SchedulableEntityRepo added in v0.6.23

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

func (*MockRepository) ScheduleEntitiesSnapshotRepo added in v0.6.23

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

func (*MockRepository) TaskExecutionRepo

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

func (*MockRepository) TaskRepo

func (*MockRepository) WorkflowRepo

type MockResourceRepo added in v0.3.38

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

func (*MockResourceRepo) CreateOrUpdate added in v0.3.38

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

func (*MockResourceRepo) Delete added in v0.3.38

func (*MockResourceRepo) Get added in v0.3.38

func (*MockResourceRepo) GetRaw added in v0.3.38

func (*MockResourceRepo) ListAll added in v0.3.38

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

type MockTaskExecutionRepo

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

func (*MockTaskExecutionRepo) Create

func (*MockTaskExecutionRepo) Get

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) error

func (*MockTaskRepo) Get

func (*MockTaskRepo) List

func (*MockTaskRepo) ListTaskIdentifiers

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) error

func (*MockWorkflowRepo) Get

func (*MockWorkflowRepo) ListIdentifiers

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 NodeExecutionEventRepoInterface added in v0.4.12

type NodeExecutionEventRepoInterface struct {
	mock.Mock
}

NodeExecutionEventRepoInterface is an autogenerated mock type for the NodeExecutionEventRepoInterface type

func (*NodeExecutionEventRepoInterface) Create added in v0.4.12

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

func (*NodeExecutionEventRepoInterface) OnCreate added in v0.4.12

func (*NodeExecutionEventRepoInterface) OnCreateMatch added in v0.4.12

func (_m *NodeExecutionEventRepoInterface) OnCreateMatch(matchers ...interface{}) *NodeExecutionEventRepoInterface_Create

type NodeExecutionEventRepoInterface_Create added in v0.4.12

type NodeExecutionEventRepoInterface_Create struct {
	*mock.Call
}

func (NodeExecutionEventRepoInterface_Create) Return added in v0.4.12

type SetActiveLaunchPlanFunc

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

type UpdateExecutionFunc

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

type UpdateLaunchPlanFunc

type UpdateLaunchPlanFunc func(input models.LaunchPlan) error

type UpdateNamedEntityFunc added in v0.1.5

type UpdateNamedEntityFunc func(input models.NamedEntity) error

type UpdateNodeExecutionFunc

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

type UpdateProjectFunction added in v0.3.38

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

type UpdateTaskExecutionFunc

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

Jump to

Keyboard shortcuts

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