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 ¶
- func NewMockExecutionRepo() interfaces.ExecutionRepoInterface
- func NewMockLaunchPlanRepo() interfaces.LaunchPlanRepoInterface
- func NewMockNodeExecutionRepo() interfaces.NodeExecutionRepoInterface
- func NewMockProjectRepo() interfaces.ProjectRepoInterface
- func NewMockRepository() repositories.RepositoryInterface
- func NewMockTaskExecutionRepo() interfaces.TaskExecutionRepoInterface
- func NewMockTaskRepo() interfaces.TaskRepoInterface
- func NewMockWorkflowRepo() interfaces.WorkflowRepoInterface
- type CreateExecutionFunc
- type CreateLaunchPlanFunc
- type CreateNodeExecutionFunc
- type CreateProjectFunction
- type CreateTaskExecutionFunc
- type CreateTaskFunc
- type CreateWorkflowFunc
- type GetExecutionByIDFunc
- type GetExecutionFunc
- type GetLaunchPlanFunc
- type GetNodeExecutionFunc
- type GetProjectFunction
- type GetTaskExecutionFunc
- type GetTaskFunc
- type GetWorkflowFunc
- type ListExecutionFunc
- type ListIdentifiersFunc
- type ListLaunchPlanFunc
- type ListLaunchPlanIdentifiersFunc
- type ListNodeExecutionEventFunc
- type ListNodeExecutionFunc
- type ListProjectsFunction
- type ListTaskExecutionFunc
- type ListTaskFunc
- type ListTaskIdentifiersFunc
- type ListWorkflowFunc
- type MockExecutionRepo
- func (r *MockExecutionRepo) Create(ctx context.Context, input models.Execution) error
- func (r *MockExecutionRepo) Get(ctx context.Context, input interfaces.GetResourceInput) (models.Execution, error)
- func (r *MockExecutionRepo) GetByID(ctx context.Context, id uint) (models.Execution, error)
- func (r *MockExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.ExecutionCollectionOutput, error)
- func (r *MockExecutionRepo) SetCreateCallback(createFunction CreateExecutionFunc)
- func (r *MockExecutionRepo) SetGetByIDCallback(getByIDFunction GetExecutionByIDFunc)
- func (r *MockExecutionRepo) SetGetCallback(getFunction GetExecutionFunc)
- func (r *MockExecutionRepo) SetListCallback(listFunction ListExecutionFunc)
- func (r *MockExecutionRepo) SetUpdateCallback(updateFunction UpdateFunc)
- func (r *MockExecutionRepo) SetUpdateExecutionCallback(updateExecutionFunc UpdateExecutionFunc)
- func (r *MockExecutionRepo) Update(ctx context.Context, event models.ExecutionEvent, execution models.Execution) error
- func (r *MockExecutionRepo) UpdateExecution(ctx context.Context, execution models.Execution) error
- type MockLaunchPlanRepo
- func (r *MockLaunchPlanRepo) Create(ctx context.Context, input models.LaunchPlan) error
- func (r *MockLaunchPlanRepo) Get(ctx context.Context, input interfaces.GetResourceInput) (models.LaunchPlan, error)
- func (r *MockLaunchPlanRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.LaunchPlanCollectionOutput, error)
- func (r *MockLaunchPlanRepo) ListLaunchPlanIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (interfaces.LaunchPlanCollectionOutput, error)
- func (r *MockLaunchPlanRepo) SetActive(ctx context.Context, toEnable models.LaunchPlan, toDisable *models.LaunchPlan) error
- func (r *MockLaunchPlanRepo) SetCreateCallback(createFunction CreateLaunchPlanFunc)
- func (r *MockLaunchPlanRepo) SetGetCallback(getFunction GetLaunchPlanFunc)
- func (r *MockLaunchPlanRepo) SetListCallback(listFunction ListLaunchPlanFunc)
- func (r *MockLaunchPlanRepo) SetListLaunchPlanIdentifiersCallback(fn ListLaunchPlanIdentifiersFunc)
- func (r *MockLaunchPlanRepo) SetSetActiveCallback(setActiveFunction SetActiveLaunchPlanFunc)
- func (r *MockLaunchPlanRepo) SetUpdateCallback(updateFunction UpdateLaunchPlanFunc)
- func (r *MockLaunchPlanRepo) Update(ctx context.Context, launchPlan models.LaunchPlan) error
- type MockNodeExecutionRepo
- func (r *MockNodeExecutionRepo) Create(ctx context.Context, event *models.NodeExecutionEvent, ...) error
- func (r *MockNodeExecutionRepo) Get(ctx context.Context, input interfaces.GetNodeExecutionInput) (models.NodeExecution, error)
- func (r *MockNodeExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.NodeExecutionCollectionOutput, error)
- func (r *MockNodeExecutionRepo) ListEvents(ctx context.Context, input interfaces.ListResourceInput) (interfaces.NodeExecutionEventCollectionOutput, error)
- func (r *MockNodeExecutionRepo) SetCreateCallback(createFunction CreateNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetGetCallback(getFunction GetNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetListCallback(listFunction ListNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetListEventCallback(listEventFunction ListNodeExecutionEventFunc)
- func (r *MockNodeExecutionRepo) SetUpdateCallback(updateFunction UpdateNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) Update(ctx context.Context, event *models.NodeExecutionEvent, ...) error
- type MockProjectRepo
- type MockRepository
- func (r *MockRepository) ExecutionRepo() interfaces.ExecutionRepoInterface
- func (r *MockRepository) LaunchPlanRepo() interfaces.LaunchPlanRepoInterface
- func (r *MockRepository) NodeExecutionRepo() interfaces.NodeExecutionRepoInterface
- func (r *MockRepository) ProjectRepo() interfaces.ProjectRepoInterface
- func (r *MockRepository) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface
- func (r *MockRepository) TaskRepo() interfaces.TaskRepoInterface
- func (r *MockRepository) WorkflowRepo() interfaces.WorkflowRepoInterface
- type MockTaskExecutionRepo
- func (r *MockTaskExecutionRepo) Create(ctx context.Context, input models.TaskExecution) error
- func (r *MockTaskExecutionRepo) Get(ctx context.Context, input interfaces.GetTaskExecutionInput) (models.TaskExecution, error)
- func (r *MockTaskExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskExecutionCollectionOutput, error)
- func (r *MockTaskExecutionRepo) SetCreateCallback(createFunction CreateTaskExecutionFunc)
- func (r *MockTaskExecutionRepo) SetGetCallback(getFunction GetTaskExecutionFunc)
- func (r *MockTaskExecutionRepo) SetListCallback(listFunction ListTaskExecutionFunc)
- func (r *MockTaskExecutionRepo) SetUpdateCallback(updateFunction UpdateTaskExecutionFunc)
- func (r *MockTaskExecutionRepo) Update(ctx context.Context, execution models.TaskExecution) error
- type MockTaskRepo
- func (r *MockTaskRepo) Create(ctx context.Context, input models.Task) error
- func (r *MockTaskRepo) Get(ctx context.Context, input interfaces.GetResourceInput) (models.Task, error)
- func (r *MockTaskRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error)
- func (r *MockTaskRepo) ListTaskIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error)
- func (r *MockTaskRepo) SetCreateCallback(createFunction CreateTaskFunc)
- func (r *MockTaskRepo) SetGetCallback(getFunction GetTaskFunc)
- func (r *MockTaskRepo) SetListCallback(listFunction ListTaskFunc)
- func (r *MockTaskRepo) SetListTaskIdentifiersCallback(listFunction ListTaskIdentifiersFunc)
- type MockWorkflowRepo
- func (r *MockWorkflowRepo) Create(ctx context.Context, input models.Workflow) error
- func (r *MockWorkflowRepo) Get(ctx context.Context, input interfaces.GetResourceInput) (models.Workflow, error)
- func (r *MockWorkflowRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error)
- func (r *MockWorkflowRepo) ListIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error)
- func (r *MockWorkflowRepo) SetCreateCallback(createFunction CreateWorkflowFunc)
- func (r *MockWorkflowRepo) SetGetCallback(getFunction GetWorkflowFunc)
- func (r *MockWorkflowRepo) SetListCallback(listFunction ListWorkflowFunc)
- func (r *MockWorkflowRepo) SetListIdentifiersFunc(fn ListIdentifiersFunc)
- type SetActiveLaunchPlanFunc
- type UpdateExecutionFunc
- type UpdateFunc
- type UpdateLaunchPlanFunc
- type UpdateNodeExecutionFunc
- type UpdateTaskExecutionFunc
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 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 CreateTaskExecutionFunc ¶
type CreateTaskExecutionFunc func(ctx context.Context, input models.TaskExecution) error
type CreateTaskFunc ¶
type CreateWorkflowFunc ¶
type GetExecutionByIDFunc ¶
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 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 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) Get ¶
func (r *MockExecutionRepo) Get(ctx context.Context, input interfaces.GetResourceInput) (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 ¶
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) 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) 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) 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 UpdateFunc ¶
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
Click to show internal directories.
Click to hide internal directories.