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 ¶
- func NewMockExecutionRepo() interfaces.ExecutionRepoInterface
- func NewMockLaunchPlanRepo() interfaces.LaunchPlanRepoInterface
- func NewMockNamedEntityRepo() interfaces.NamedEntityRepoInterface
- func NewMockNodeExecutionRepo() interfaces.NodeExecutionRepoInterface
- func NewMockProjectRepo() interfaces.ProjectRepoInterface
- func NewMockRepository() repositories.RepositoryInterface
- func NewMockResourceRepo() interfaces.ResourceRepoInterface
- func NewMockTaskExecutionRepo() interfaces.TaskExecutionRepoInterface
- func NewMockTaskRepo() interfaces.TaskRepoInterface
- func NewMockWorkflowRepo() interfaces.WorkflowRepoInterface
- type CreateExecutionFunc
- type CreateLaunchPlanFunc
- type CreateNodeExecutionFunc
- type CreateOrUpdateResourceFunction
- type CreateProjectFunction
- type CreateTaskExecutionFunc
- type CreateTaskFunc
- type CreateWorkflowFunc
- type DeleteResourceFunction
- type ExecutionEventRepoInterface
- func (_m *ExecutionEventRepoInterface) Create(ctx context.Context, input models.ExecutionEvent) error
- func (_m *ExecutionEventRepoInterface) OnCreate(ctx context.Context, input models.ExecutionEvent) *ExecutionEventRepoInterface_Create
- func (_m *ExecutionEventRepoInterface) OnCreateMatch(matchers ...interface{}) *ExecutionEventRepoInterface_Create
- type ExecutionEventRepoInterface_Create
- type GetExecutionFunc
- type GetLaunchPlanFunc
- type GetNamedEntityFunc
- type GetNodeExecutionFunc
- type GetProjectFunction
- type GetResourceFunction
- type GetTaskExecutionFunc
- type GetTaskFunc
- type GetWorkflowFunc
- type ListAllResourcesFunction
- type ListExecutionFunc
- type ListIdentifiersFunc
- type ListLaunchPlanFunc
- type ListLaunchPlanIdentifiersFunc
- type ListNamedEntityFunc
- 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.Identifier) (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) SetGetCallback(getFunction GetExecutionFunc)
- func (r *MockExecutionRepo) SetListCallback(listFunction ListExecutionFunc)
- func (r *MockExecutionRepo) SetUpdateCallback(updateFunction UpdateExecutionFunc)
- func (r *MockExecutionRepo) SetUpdateExecutionCallback(updateExecutionFunc UpdateExecutionFunc)
- func (r *MockExecutionRepo) Update(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.Identifier) (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 MockNamedEntityRepo
- func (r *MockNamedEntityRepo) Get(ctx context.Context, input interfaces.GetNamedEntityInput) (models.NamedEntity, error)
- func (r *MockNamedEntityRepo) List(ctx context.Context, input interfaces.ListNamedEntityInput) (interfaces.NamedEntityCollectionOutput, error)
- func (r *MockNamedEntityRepo) SetGetCallback(getFunction GetNamedEntityFunc)
- func (r *MockNamedEntityRepo) SetListCallback(listFunction ListNamedEntityFunc)
- func (r *MockNamedEntityRepo) SetUpdateCallback(updateFunction UpdateNamedEntityFunc)
- func (r *MockNamedEntityRepo) Update(ctx context.Context, NamedEntity models.NamedEntity) error
- type MockNodeExecutionRepo
- func (r *MockNodeExecutionRepo) Create(ctx context.Context, input *models.NodeExecution) error
- func (r *MockNodeExecutionRepo) Exists(ctx context.Context, input interfaces.NodeExecutionResource) (bool, error)
- func (r *MockNodeExecutionRepo) Get(ctx context.Context, input interfaces.NodeExecutionResource) (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, nodeExecution *models.NodeExecution) error
- type MockProjectRepo
- func (r *MockProjectRepo) Create(ctx context.Context, project models.Project) error
- func (r *MockProjectRepo) Get(ctx context.Context, projectID string) (models.Project, error)
- func (r *MockProjectRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Project, error)
- func (r *MockProjectRepo) UpdateProject(ctx context.Context, projectUpdate models.Project) error
- type MockRepository
- func (r *MockRepository) ExecutionEventRepo() interfaces.ExecutionEventRepoInterface
- func (r *MockRepository) ExecutionRepo() interfaces.ExecutionRepoInterface
- func (r *MockRepository) LaunchPlanRepo() interfaces.LaunchPlanRepoInterface
- func (r *MockRepository) NamedEntityRepo() interfaces.NamedEntityRepoInterface
- func (r *MockRepository) NodeExecutionEventRepo() interfaces.NodeExecutionEventRepoInterface
- func (r *MockRepository) NodeExecutionRepo() interfaces.NodeExecutionRepoInterface
- func (r *MockRepository) ProjectRepo() interfaces.ProjectRepoInterface
- func (r *MockRepository) ResourceRepo() interfaces.ResourceRepoInterface
- func (r *MockRepository) SchedulableEntityRepo() sIface.SchedulableEntityRepoInterface
- func (r *MockRepository) ScheduleEntitiesSnapshotRepo() sIface.ScheduleEntitiesSnapShotRepoInterface
- func (r *MockRepository) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface
- func (r *MockRepository) TaskRepo() interfaces.TaskRepoInterface
- func (r *MockRepository) WorkflowRepo() interfaces.WorkflowRepoInterface
- type MockResourceRepo
- func (r *MockResourceRepo) CreateOrUpdate(ctx context.Context, input models.Resource) error
- func (r *MockResourceRepo) Delete(ctx context.Context, ID interfaces.ResourceID) error
- func (r *MockResourceRepo) Get(ctx context.Context, ID interfaces.ResourceID) (models.Resource, error)
- func (r *MockResourceRepo) GetRaw(ctx context.Context, ID interfaces.ResourceID) (models.Resource, error)
- func (r *MockResourceRepo) ListAll(ctx context.Context, resourceType string) ([]models.Resource, error)
- 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.Identifier) (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.Identifier) (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 NodeExecutionEventRepoInterface
- func (_m *NodeExecutionEventRepoInterface) Create(ctx context.Context, input models.NodeExecutionEvent) error
- func (_m *NodeExecutionEventRepoInterface) OnCreate(ctx context.Context, input models.NodeExecutionEvent) *NodeExecutionEventRepoInterface_Create
- func (_m *NodeExecutionEventRepoInterface) OnCreateMatch(matchers ...interface{}) *NodeExecutionEventRepoInterface_Create
- type NodeExecutionEventRepoInterface_Create
- type SetActiveLaunchPlanFunc
- type UpdateExecutionFunc
- type UpdateLaunchPlanFunc
- type UpdateNamedEntityFunc
- type UpdateNodeExecutionFunc
- type UpdateProjectFunction
- 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 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.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 CreateExecutionFunc ¶
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 CreateProjectFunction ¶
type CreateTaskExecutionFunc ¶
type CreateTaskExecutionFunc func(ctx context.Context, input models.TaskExecution) error
type CreateTaskFunc ¶
type CreateWorkflowFunc ¶
type DeleteResourceFunction ¶ added in v0.3.38
type DeleteResourceFunction func(ctx context.Context, ID interfaces.ResourceID) error
type ExecutionEventRepoInterface ¶ added in v0.4.12
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
func (ExecutionEventRepoInterface_Create) Return ¶ added in v0.4.12
func (_m ExecutionEventRepoInterface_Create) Return(_a0 error) *ExecutionEventRepoInterface_Create
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 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 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 ListNodeExecutionEventFunc ¶
type ListNodeExecutionEventFunc func(ctx context.Context, input interfaces.ListResourceInput) ( interfaces.NodeExecutionEventCollectionOutput, error)
type ListNodeExecutionFunc ¶
type ListNodeExecutionFunc func(ctx context.Context, input interfaces.ListResourceInput) ( interfaces.NodeExecutionCollectionOutput, error)
type ListProjectsFunction ¶
type ListProjectsFunction func(ctx context.Context, 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 MockExecutionRepo ¶
type MockExecutionRepo struct {
// contains filtered or unexported fields
}
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) 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) SetUpdateExecutionCallback ¶
func (r *MockExecutionRepo) SetUpdateExecutionCallback(updateExecutionFunc UpdateExecutionFunc)
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 { ExistsFunction func(ctx context.Context, input interfaces.NodeExecutionResource) (bool, error) // contains filtered or unexported fields }
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) 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, nodeExecution *models.NodeExecution) error
type MockProjectRepo ¶
type MockProjectRepo struct { CreateFunction CreateProjectFunction GetFunction GetProjectFunction ListProjectsFunction ListProjectsFunction UpdateProjectFunction UpdateProjectFunction }
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
type MockRepository ¶
type MockRepository struct { ExecutionEventRepoIface interfaces.ExecutionEventRepoInterface NodeExecutionEventRepoIface interfaces.NodeExecutionEventRepoInterface // contains filtered or unexported fields }
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) 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) 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 (*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) GetRaw ¶ added in v0.3.38
func (r *MockResourceRepo) GetRaw(ctx context.Context, ID interfaces.ResourceID) ( models.Resource, error)
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.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) 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
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
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 UpdateExecutionFunc ¶
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 UpdateTaskExecutionFunc ¶
type UpdateTaskExecutionFunc func(ctx context.Context, execution models.TaskExecution) error
Click to show internal directories.
Click to hide internal directories.