mocks

package
v0.3.2 Latest Latest
Warning

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

Go to latest
Published: Aug 12, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

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

func NewMockResourceRepo added in v0.2.0

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

type CreateOrUpdateResourceFunction added in v0.2.0

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.2.0

type DeleteResourceFunction func(ctx context.Context, ID interfaces.ResourceID) 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 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.GetNodeExecutionInput) (models.NodeExecution, error)

type GetProjectFunction

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

type GetResourceFunction added in v0.2.0

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.GetResourceInput) (models.Task, error)

type GetWorkflowFunc

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

type ListAllResourcesFunction added in v0.2.3

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, 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 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 {
	// 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) NamedEntityRepo added in v0.1.5

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

func (*MockRepository) NodeExecutionRepo

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

func (*MockRepository) ProjectRepo

func (*MockRepository) ResourceRepo added in v0.2.0

func (*MockRepository) TaskExecutionRepo

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

func (*MockRepository) TaskRepo

func (*MockRepository) WorkflowRepo

type MockResourceRepo added in v0.2.0

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

func (*MockResourceRepo) CreateOrUpdate added in v0.2.0

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

func (*MockResourceRepo) Delete added in v0.2.0

func (*MockResourceRepo) Get added in v0.2.0

func (*MockResourceRepo) GetRaw added in v0.2.0

func (*MockResourceRepo) ListAll added in v0.2.3

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

type UpdateNamedEntityFunc func(input models.NamedEntity) 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