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 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 ListNodeExecutionEventFunc 

type ListNodeExecutionEventFunc func(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.NodeExecutionEventCollectionOutput, error)

type ListNodeExecutionFunc 

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

type ListProjectsFunction 

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

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

func (*MockExecutionRepo) Get 

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

func (*MockExecutionRepo) GetByID 

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

func (*MockExecutionRepo) List 

func (r *MockExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.ExecutionCollectionOutput, 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 (r *MockLaunchPlanRepo) Get(
	ctx context.Context, input interfaces.GetResourceInput) (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) Create 

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

func (*MockNodeExecutionRepo) Get 

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

func (*MockNodeExecutionRepo) List 

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

func (*MockNodeExecutionRepo) ListEvents 

func (r *MockNodeExecutionRepo) ListEvents(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.NodeExecutionEventCollectionOutput, error)

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

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 (r *MockRepository) ExecutionRepo() interfaces.ExecutionRepoInterface

func (*MockRepository) LaunchPlanRepo 

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

func (*MockRepository) NodeExecutionRepo 

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

func (*MockRepository) ProjectRepo 

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

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 MockTaskExecutionRepo 

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

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) 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 (r *MockTaskRepo) Get(ctx context.Context, input interfaces.GetResourceInput) (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) error

func (*MockWorkflowRepo) Get 

func (r *MockWorkflowRepo) Get(ctx context.Context, input interfaces.GetResourceInput) (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 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

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.