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 ¶
- func NewMockDescriptionEntityRepo() interfaces.DescriptionEntityRepoInterface
- func NewMockExecutionRepo() interfaces.ExecutionRepoInterface
- func NewMockLaunchPlanRepo() interfaces.LaunchPlanRepoInterface
- func NewMockNamedEntityRepo() interfaces.NamedEntityRepoInterface
- func NewMockNodeExecutionRepo() interfaces.NodeExecutionRepoInterface
- func NewMockProjectRepo() interfaces.ProjectRepoInterface
- func NewMockRepository() interfaces.Repository
- func NewMockResourceRepo() interfaces.ResourceRepoInterface
- func NewMockTaskExecutionRepo() interfaces.TaskExecutionRepoInterface
- func NewMockTaskRepo() interfaces.TaskRepoInterface
- func NewMockWorkflowRepo() interfaces.WorkflowRepoInterface
- type CountExecutionFunc
- type CountNodeExecutionFunc
- type CountTaskExecutionFunc
- type CreateDescriptionEntityFunc
- 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 ExistsNodeExecutionFunc
- type GetDescriptionEntityFunc
- type GetExecutionFunc
- type GetLaunchPlanFunc
- type GetNamedEntityFunc
- type GetNodeExecutionFunc
- type GetProjectFunction
- type GetResourceFunction
- type GetTaskExecutionFunc
- type GetTaskFunc
- type GetWorkflowFunc
- type ListAllResourcesFunction
- type ListDescriptionEntityFunc
- type ListExecutionFunc
- type ListIdentifiersFunc
- type ListLaunchPlanFunc
- type ListLaunchPlanIdentifiersFunc
- type ListNamedEntityFunc
- type ListNodeExecutionFunc
- type ListProjectsFunction
- type ListTaskExecutionFunc
- type ListTaskFunc
- type ListTaskIdentifiersFunc
- type ListWorkflowFunc
- type MockDescriptionEntityRepo
- func (r *MockDescriptionEntityRepo) Create(ctx context.Context, DescriptionEntity models.DescriptionEntity) (uint, error)
- func (r *MockDescriptionEntityRepo) Get(ctx context.Context, input interfaces.GetDescriptionEntityInput) (models.DescriptionEntity, error)
- func (r *MockDescriptionEntityRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.DescriptionEntityCollectionOutput, error)
- func (r *MockDescriptionEntityRepo) SetCreateCallback(createFunction CreateDescriptionEntityFunc)
- func (r *MockDescriptionEntityRepo) SetGetCallback(getFunction GetDescriptionEntityFunc)
- func (r *MockDescriptionEntityRepo) SetListCallback(listFunction ListDescriptionEntityFunc)
- type MockExecutionRepo
- func (r *MockExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)
- 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) SetCountCallback(countFunction CountExecutionFunc)
- 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) 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) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)
- 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) GetWithChildren(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) SetCountCallback(countFunction CountNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetCreateCallback(createFunction CreateNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetExistsCallback(existsFunction ExistsNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetGetCallback(getFunction GetNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetGetWithChildrenCallback(getWithChildrenFunction GetNodeExecutionFunc)
- func (r *MockNodeExecutionRepo) SetListCallback(listFunction ListNodeExecutionFunc)
- 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) DescriptionEntityRepo() interfaces.DescriptionEntityRepoInterface
- func (r *MockRepository) ExecutionEventRepo() interfaces.ExecutionEventRepoInterface
- func (r *MockRepository) ExecutionRepo() interfaces.ExecutionRepoInterface
- func (r *MockRepository) GetGormDB() *gorm.DB
- 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) SignalRepo() interfaces.SignalRepoInterface
- 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) GetProjectLevel(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) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)
- 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) SetCountCallback(countFunction CountTaskExecutionFunc)
- 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 SignalRepoInterface
- func (_m *SignalRepoInterface) Get(ctx context.Context, input models.SignalKey) (models.Signal, error)
- func (_m *SignalRepoInterface) GetOrCreate(ctx context.Context, input *models.Signal) error
- func (_m *SignalRepoInterface) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Signal, error)
- func (_m *SignalRepoInterface) OnGet(ctx context.Context, input models.SignalKey) *SignalRepoInterface_Get
- func (_m *SignalRepoInterface) OnGetMatch(matchers ...interface{}) *SignalRepoInterface_Get
- func (_m *SignalRepoInterface) OnGetOrCreate(ctx context.Context, input *models.Signal) *SignalRepoInterface_GetOrCreate
- func (_m *SignalRepoInterface) OnGetOrCreateMatch(matchers ...interface{}) *SignalRepoInterface_GetOrCreate
- func (_m *SignalRepoInterface) OnList(ctx context.Context, input interfaces.ListResourceInput) *SignalRepoInterface_List
- func (_m *SignalRepoInterface) OnListMatch(matchers ...interface{}) *SignalRepoInterface_List
- func (_m *SignalRepoInterface) OnUpdate(ctx context.Context, input models.SignalKey, value []byte) *SignalRepoInterface_Update
- func (_m *SignalRepoInterface) OnUpdateMatch(matchers ...interface{}) *SignalRepoInterface_Update
- func (_m *SignalRepoInterface) Update(ctx context.Context, input models.SignalKey, value []byte) error
- type SignalRepoInterface_Get
- type SignalRepoInterface_GetOrCreate
- type SignalRepoInterface_List
- type SignalRepoInterface_Update
- type UpdateExecutionFunc
- type UpdateLaunchPlanFunc
- type UpdateNamedEntityFunc
- type UpdateNodeExecutionFunc
- type UpdateProjectFunction
- type UpdateTaskExecutionFunc
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 CreateLaunchPlanFunc ¶
type CreateLaunchPlanFunc func(input models.LaunchPlan) error
type CreateNodeExecutionFunc ¶
type CreateNodeExecutionFunc func(ctx context.Context, input *models.NodeExecution) error
type CreateProjectFunction ¶
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 ¶
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 ¶
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 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 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, executionTagModel []*models.ExecutionTag) 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)
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) List ¶
func (r *MockProjectRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Project, error)
func (*MockProjectRepo) UpdateProject ¶
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 (*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)
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 ¶
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 ¶
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 ¶
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 ¶
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
type SignalRepoInterface_Get ¶
func (SignalRepoInterface_Get) Return ¶
func (_m SignalRepoInterface_Get) Return(_a0 models.Signal, _a1 error) *SignalRepoInterface_Get
type SignalRepoInterface_GetOrCreate ¶
func (SignalRepoInterface_GetOrCreate) Return ¶
func (_m SignalRepoInterface_GetOrCreate) Return(_a0 error) *SignalRepoInterface_GetOrCreate
type SignalRepoInterface_List ¶
func (SignalRepoInterface_List) Return ¶
func (_m SignalRepoInterface_List) Return(_a0 []models.Signal, _a1 error) *SignalRepoInterface_List
type SignalRepoInterface_Update ¶
func (SignalRepoInterface_Update) Return ¶
func (_m SignalRepoInterface_Update) Return(_a0 error) *SignalRepoInterface_Update
type UpdateExecutionFunc ¶
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 UpdateTaskExecutionFunc ¶
type UpdateTaskExecutionFunc func(ctx context.Context, execution models.TaskExecution) error
Source Files
¶
- description_entity_repo.go
- execution_event_repo_interface.go
- execution_repo.go
- launch_plan_repo.go
- named_entity_metadata_repo.go
- node_execution_event_repo_interface.go
- node_execution_repo.go
- project_repo.go
- repository.go
- resource.go
- signal_repo_interface.go
- task_execution_repo.go
- task_repo.go
- workflow_repo.go