mocks

package
v1.1.131 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2023 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 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 NewMockDescriptionEntityRepo added in v1.1.67 

func NewMockDescriptionEntityRepo() interfaces.DescriptionEntityRepoInterface

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 CountExecutionFunc added in v1.1.36 

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

type CountNodeExecutionFunc added in v1.1.36 

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

type CountTaskExecutionFunc added in v1.1.36 

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

type CreateDescriptionEntityFunc added in v1.1.67 

type CreateDescriptionEntityFunc func(input models.DescriptionEntity) 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 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, descriptionEntity *models.DescriptionEntity) error

type CreateWorkflowFunc 

type CreateWorkflowFunc func(input models.Workflow, descriptionEntity *models.DescriptionEntity) 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 

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

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

func (*ExecutionEventRepoInterface) OnCreate added in v0.4.12 

func (_m *ExecutionEventRepoInterface) OnCreate(ctx context.Context, input models.ExecutionEvent) *ExecutionEventRepoInterface_Create

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 

func (_m ExecutionEventRepoInterface_Create) Return(_a0 error) *ExecutionEventRepoInterface_Create

type ExistsNodeExecutionFunc added in v1.1.36 

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

type GetDescriptionEntityFunc added in v1.1.67 

type GetDescriptionEntityFunc func(input interfaces.GetDescriptionEntityInput) (models.DescriptionEntity, 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 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 ListDescriptionEntityFunc added in v1.1.67 

type ListDescriptionEntityFunc func(input interfaces.ListResourceInput) (interfaces.DescriptionEntityCollectionOutput, 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 ListNamedEntityFunc added in v0.1.5 

type ListNamedEntityFunc func(input interfaces.ListNamedEntityInput) (interfaces.NamedEntityCollectionOutput, 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 MockDescriptionEntityRepo added in v1.1.67 

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

func (*MockDescriptionEntityRepo) Create added in v1.1.67 

func (r *MockDescriptionEntityRepo) Create(ctx context.Context, DescriptionEntity models.DescriptionEntity) (uint, error)

func (*MockDescriptionEntityRepo) Get added in v1.1.67 

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

func (*MockDescriptionEntityRepo) List added in v1.1.67 

func (r *MockDescriptionEntityRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.DescriptionEntityCollectionOutput, error)

func (*MockDescriptionEntityRepo) SetCreateCallback added in v1.1.67 

func (r *MockDescriptionEntityRepo) SetCreateCallback(createFunction CreateDescriptionEntityFunc)

func (*MockDescriptionEntityRepo) SetGetCallback added in v1.1.67 

func (r *MockDescriptionEntityRepo) SetGetCallback(getFunction GetDescriptionEntityFunc)

func (*MockDescriptionEntityRepo) SetListCallback added in v1.1.67 

func (r *MockDescriptionEntityRepo) SetListCallback(listFunction ListDescriptionEntityFunc)

type MockExecutionRepo 

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

func (*MockExecutionRepo) Count added in v1.1.36 

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) 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 added in v1.1.36 

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

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

func (*MockNamedEntityRepo) Get added in v0.1.5 

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

func (*MockNamedEntityRepo) List added in v0.1.5 

func (r *MockNamedEntityRepo) List(ctx context.Context, input interfaces.ListNamedEntityInput) (interfaces.NamedEntityCollectionOutput, error)

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) Count added in v1.1.36 

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

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

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 added in v1.1.36 

func (r *MockNodeExecutionRepo) SetCountCallback(countFunction CountNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetCreateCallback 

func (r *MockNodeExecutionRepo) SetCreateCallback(createFunction CreateNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetExistsCallback added in v1.1.36 

func (r *MockNodeExecutionRepo) SetExistsCallback(existsFunction ExistsNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetGetCallback 

func (r *MockNodeExecutionRepo) SetGetCallback(getFunction GetNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetGetWithChildrenCallback added in v1.1.36 

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

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

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) DescriptionEntityRepo added in v1.1.67 

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

func (*MockRepository) ExecutionEventRepo added in v0.4.12 

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

func (*MockRepository) ExecutionRepo 

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

func (*MockRepository) GetGormDB added in v0.6.100 

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

func (*MockRepository) LaunchPlanRepo 

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

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 (r *MockRepository) ProjectRepo() interfaces.ProjectRepoInterface

func (*MockRepository) ResourceRepo added in v0.3.38 

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

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) SignalRepo added in v1.1.61 

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 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 (r *MockResourceRepo) Delete(ctx context.Context, ID interfaces.ResourceID) error

func (*MockResourceRepo) Get added in v0.3.38 

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

func (*MockResourceRepo) GetProjectLevel added in v1.1.46 

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

func (*MockResourceRepo) GetRaw added in v0.3.38 

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

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) Count added in v1.1.36 

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 added in v1.1.36 

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

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

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

func (*NodeExecutionEventRepoInterface) OnCreate added in v0.4.12 

func (_m *NodeExecutionEventRepoInterface) OnCreate(ctx context.Context, input models.NodeExecutionEvent) *NodeExecutionEventRepoInterface_Create

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 

func (_m NodeExecutionEventRepoInterface_Create) Return(_a0 error) *NodeExecutionEventRepoInterface_Create

type SetActiveLaunchPlanFunc 

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

type SignalRepoInterface added in v1.1.61 

type SignalRepoInterface struct {
	mock.Mock
}

SignalRepoInterface is an autogenerated mock type for the SignalRepoInterface type

func (*SignalRepoInterface) Get added in v1.1.61 

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 added in v1.1.61 

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

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

func (*SignalRepoInterface) List added in v1.1.61 

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) OnGet added in v1.1.61 

func (_m *SignalRepoInterface) OnGet(ctx context.Context, input models.SignalKey) *SignalRepoInterface_Get

func (*SignalRepoInterface) OnGetMatch added in v1.1.61 

func (_m *SignalRepoInterface) OnGetMatch(matchers ...interface{}) *SignalRepoInterface_Get

func (*SignalRepoInterface) OnGetOrCreate added in v1.1.61 

func (_m *SignalRepoInterface) OnGetOrCreate(ctx context.Context, input *models.Signal) *SignalRepoInterface_GetOrCreate

func (*SignalRepoInterface) OnGetOrCreateMatch added in v1.1.61 

func (_m *SignalRepoInterface) OnGetOrCreateMatch(matchers ...interface{}) *SignalRepoInterface_GetOrCreate

func (*SignalRepoInterface) OnList added in v1.1.61 

func (_m *SignalRepoInterface) OnList(ctx context.Context, input interfaces.ListResourceInput) *SignalRepoInterface_List

func (*SignalRepoInterface) OnListMatch added in v1.1.61 

func (_m *SignalRepoInterface) OnListMatch(matchers ...interface{}) *SignalRepoInterface_List

func (*SignalRepoInterface) OnUpdate added in v1.1.61 

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

func (*SignalRepoInterface) OnUpdateMatch added in v1.1.61 

func (_m *SignalRepoInterface) OnUpdateMatch(matchers ...interface{}) *SignalRepoInterface_Update

func (*SignalRepoInterface) Update added in v1.1.61 

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_Get added in v1.1.61 

type SignalRepoInterface_Get struct {
	*mock.Call
}

func (SignalRepoInterface_Get) Return added in v1.1.61 

func (_m SignalRepoInterface_Get) Return(_a0 models.Signal, _a1 error) *SignalRepoInterface_Get

type SignalRepoInterface_GetOrCreate added in v1.1.61 

type SignalRepoInterface_GetOrCreate struct {
	*mock.Call
}

func (SignalRepoInterface_GetOrCreate) Return added in v1.1.61 

func (_m SignalRepoInterface_GetOrCreate) Return(_a0 error) *SignalRepoInterface_GetOrCreate

type SignalRepoInterface_List added in v1.1.61 

type SignalRepoInterface_List struct {
	*mock.Call
}

func (SignalRepoInterface_List) Return added in v1.1.61 

func (_m SignalRepoInterface_List) Return(_a0 []models.Signal, _a1 error) *SignalRepoInterface_List

type SignalRepoInterface_Update added in v1.1.61 

type SignalRepoInterface_Update struct {
	*mock.Call
}

func (SignalRepoInterface_Update) Return added in v1.1.61 

func (_m SignalRepoInterface_Update) Return(_a0 error) *SignalRepoInterface_Update

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

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.