mocks

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Oct 18, 2019 License: Apache-2.0 Imports: 5 Imported by: 1

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() repositories.RepositoryInterface

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, event *models.NodeExecutionEvent, input *models.NodeExecution) 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 GetExecutionByIDFunc

type GetExecutionByIDFunc func(ctx context.Context, id uint) (models.Execution, error)

type GetExecutionFunc

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

type GetLaunchPlanFunc

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

type GetNodeExecutionFunc

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

type GetProjectFunction

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

type GetTaskExecutionFunc

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

type GetTaskFunc

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

type GetWorkflowFunc

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

type ListProjectsFunction

type ListProjectsFunction func(ctx context.Context, sortParameter common.SortParameter) ([]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) GetByID

func (r *MockExecutionRepo) GetByID(ctx context.Context, id uint) (models.Execution, error)

func (*MockExecutionRepo) SetCreateCallback

func (r *MockExecutionRepo) SetCreateCallback(createFunction CreateExecutionFunc)

func (*MockExecutionRepo) SetGetByIDCallback

func (r *MockExecutionRepo) SetGetByIDCallback(getByIDFunction GetExecutionByIDFunc)

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

func (*MockExecutionRepo) SetUpdateExecutionCallback

func (r *MockExecutionRepo) SetUpdateExecutionCallback(updateExecutionFunc UpdateExecutionFunc)

func (*MockExecutionRepo) Update

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

func (*MockExecutionRepo) UpdateExecution

func (r *MockExecutionRepo) UpdateExecution(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 MockNodeExecutionRepo

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

func (*MockNodeExecutionRepo) Create

func (*MockNodeExecutionRepo) Get

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

type MockProjectRepo

type MockProjectRepo struct {
	CreateFunction       CreateProjectFunction
	GetFunction          GetProjectFunction
	ListProjectsFunction ListProjectsFunction
}

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

func (r *MockProjectRepo) ListAll(ctx context.Context, sortParameter common.SortParameter) ([]models.Project, error)

type MockRepository

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

func (*MockRepository) ExecutionRepo

func (*MockRepository) LaunchPlanRepo

func (*MockRepository) NodeExecutionRepo

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

func (*MockRepository) ProjectRepo

func (*MockRepository) TaskExecutionRepo

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

func (*MockRepository) TaskRepo

func (*MockRepository) WorkflowRepo

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 SetActiveLaunchPlanFunc

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

type UpdateExecutionFunc

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

type UpdateFunc

type UpdateFunc func(ctx context.Context, event models.ExecutionEvent, execution models.Execution) error

type UpdateLaunchPlanFunc

type UpdateLaunchPlanFunc func(input models.LaunchPlan) error

type UpdateNodeExecutionFunc

type UpdateNodeExecutionFunc func(ctx context.Context, event *models.NodeExecutionEvent, nodeExecution *models.NodeExecution) 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