mocks

package
v0.0.0-...-267b159 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2023 License: Apache-2.0 Imports: 8 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 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 

func NewMockDescriptionEntityRepo() interfaces.DescriptionEntityRepoInterface

func NewMockExecutionRepo 

func NewMockExecutionRepo() interfaces.ExecutionRepoInterface

func NewMockLaunchPlanRepo 

func NewMockLaunchPlanRepo() interfaces.LaunchPlanRepoInterface

func NewMockNamedEntityRepo 

func NewMockNamedEntityRepo() interfaces.NamedEntityRepoInterface

func NewMockNodeExecutionRepo 

func NewMockNodeExecutionRepo() interfaces.NodeExecutionRepoInterface

func NewMockProjectRepo 

func NewMockProjectRepo() interfaces.ProjectRepoInterface

func NewMockRepository 

func NewMockRepository() interfaces.Repository

func NewMockResourceRepo 

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 

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

type CountNodeExecutionFunc 

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

type CountTaskExecutionFunc 

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

type CreateDescriptionEntityFunc 

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 

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 

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

type ExecutionEventRepoInterface 

type ExecutionEventRepoInterface struct {
	mock.Mock
}

ExecutionEventRepoInterface is an autogenerated mock type for the ExecutionEventRepoInterface type

func (*ExecutionEventRepoInterface) Create 

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

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

func (*ExecutionEventRepoInterface) OnCreate 

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

func (*ExecutionEventRepoInterface) OnCreateMatch 

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

type ExecutionEventRepoInterface_Create 

type ExecutionEventRepoInterface_Create struct {
	*mock.Call
}

func (ExecutionEventRepoInterface_Create) Return 

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

type ExistsNodeExecutionFunc 

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

type GetDescriptionEntityFunc 

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 

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 

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 

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

type ListDescriptionEntityFunc 

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 

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 

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

func (*MockDescriptionEntityRepo) Create 

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

func (*MockDescriptionEntityRepo) Get 

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

func (*MockDescriptionEntityRepo) List 

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

func (*MockDescriptionEntityRepo) SetCreateCallback 

func (r *MockDescriptionEntityRepo) SetCreateCallback(createFunction CreateDescriptionEntityFunc)

func (*MockDescriptionEntityRepo) SetGetCallback 

func (r *MockDescriptionEntityRepo) SetGetCallback(getFunction GetDescriptionEntityFunc)

func (*MockDescriptionEntityRepo) SetListCallback 

func (r *MockDescriptionEntityRepo) SetListCallback(listFunction ListDescriptionEntityFunc)

type MockExecutionRepo 

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

func (*MockExecutionRepo) Count 

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 

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 

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

func (*MockNamedEntityRepo) Get 

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

func (*MockNamedEntityRepo) List 

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

func (*MockNamedEntityRepo) SetGetCallback 

func (r *MockNamedEntityRepo) SetGetCallback(getFunction GetNamedEntityFunc)

func (*MockNamedEntityRepo) SetListCallback 

func (r *MockNamedEntityRepo) SetListCallback(listFunction ListNamedEntityFunc)

func (*MockNamedEntityRepo) SetUpdateCallback 

func (r *MockNamedEntityRepo) SetUpdateCallback(updateFunction UpdateNamedEntityFunc)

func (*MockNamedEntityRepo) Update 

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

type MockNodeExecutionRepo 

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

func (*MockNodeExecutionRepo) Count 

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 

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 

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 

func (r *MockNodeExecutionRepo) SetCountCallback(countFunction CountNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetCreateCallback 

func (r *MockNodeExecutionRepo) SetCreateCallback(createFunction CreateNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetExistsCallback 

func (r *MockNodeExecutionRepo) SetExistsCallback(existsFunction ExistsNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetGetCallback 

func (r *MockNodeExecutionRepo) SetGetCallback(getFunction GetNodeExecutionFunc)

func (*MockNodeExecutionRepo) SetGetWithChildrenCallback 

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 

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

func (*MockProjectRepo) UpdateProject 

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 

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

func (*MockRepository) ExecutionEventRepo 

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

func (*MockRepository) ExecutionRepo 

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

func (*MockRepository) GetGormDB 

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

func (*MockRepository) LaunchPlanRepo 

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

func (*MockRepository) NamedEntityRepo 

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

func (*MockRepository) NodeExecutionEventRepo 

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 

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

func (*MockRepository) SchedulableEntityRepo 

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

func (*MockRepository) ScheduleEntitiesSnapshotRepo 

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

func (*MockRepository) SignalRepo 

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 

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

func (*MockResourceRepo) CreateOrUpdate 

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

func (*MockResourceRepo) Delete 

func (r *MockResourceRepo) Delete(ctx context.Context, ID interfaces.ResourceID) error

func (*MockResourceRepo) Get 

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

func (*MockResourceRepo) GetProjectLevel 

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

func (*MockResourceRepo) GetRaw 

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

func (*MockResourceRepo) ListAll 

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 

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 

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 

type NodeExecutionEventRepoInterface struct {
	mock.Mock
}

NodeExecutionEventRepoInterface is an autogenerated mock type for the NodeExecutionEventRepoInterface type

func (*NodeExecutionEventRepoInterface) Create 

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

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

func (*NodeExecutionEventRepoInterface) OnCreate 

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

func (*NodeExecutionEventRepoInterface) OnCreateMatch 

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

type NodeExecutionEventRepoInterface_Create 

type NodeExecutionEventRepoInterface_Create struct {
	*mock.Call
}

func (NodeExecutionEventRepoInterface_Create) Return 

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

type SetActiveLaunchPlanFunc 

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

type SignalRepoInterface 

type SignalRepoInterface struct {
	mock.Mock
}

SignalRepoInterface is an autogenerated mock type for the SignalRepoInterface type

func (*SignalRepoInterface) Get 

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 

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

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

func (*SignalRepoInterface) List 

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 

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

func (*SignalRepoInterface) OnGetMatch 

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

func (*SignalRepoInterface) OnGetOrCreate 

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

func (*SignalRepoInterface) OnGetOrCreateMatch 

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

func (*SignalRepoInterface) OnList 

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

func (*SignalRepoInterface) OnListMatch 

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

func (*SignalRepoInterface) OnUpdate 

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

func (*SignalRepoInterface) OnUpdateMatch 

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

func (*SignalRepoInterface) Update 

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 

type SignalRepoInterface_Get struct {
	*mock.Call
}

func (SignalRepoInterface_Get) Return 

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

type SignalRepoInterface_GetOrCreate 

type SignalRepoInterface_GetOrCreate struct {
	*mock.Call
}

func (SignalRepoInterface_GetOrCreate) Return 

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

type SignalRepoInterface_List 

type SignalRepoInterface_List struct {
	*mock.Call
}

func (SignalRepoInterface_List) Return 

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

type SignalRepoInterface_Update 

type SignalRepoInterface_Update struct {
	*mock.Call
}

func (SignalRepoInterface_Update) Return 

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 

type UpdateNamedEntityFunc func(input models.NamedEntity) error

type UpdateNodeExecutionFunc 

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

type UpdateProjectFunction 

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.