gormimpl

package
v0.3.20 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const Closure = "closure"
View Source
const Description = "description"
View Source
const Domain = "domain"
View Source
const DomainID = "domain_id"
View Source
const DomainName = "domain_name"
View Source
const Name = "name"
View Source
const Project = "project"
View Source
const ProjectID = "project_id"
View Source
const ProjectName = "project_name"
View Source
const ResourceType = "resource_type"
View Source
const State = "state"
View Source
const Version = "version"

Variables

This section is empty.

Functions

func NewExecutionRepo

func NewExecutionRepo(
	db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.ExecutionRepoInterface

Returns an instance of ExecutionRepoInterface

func NewLaunchPlanRepo

func NewLaunchPlanRepo(
	db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.LaunchPlanRepoInterface

Returns an instance of LaunchPlanRepoInterface

func NewNamedEntityRepo added in v0.1.5

func NewNamedEntityRepo(
	db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.NamedEntityRepoInterface

Returns an instance of NamedEntityRepoInterface

func NewNodeExecutionRepo

func NewNodeExecutionRepo(
	db *gorm.DB, errorTransformer errors.ErrorTransformer,
	scope promutils.Scope) interfaces.NodeExecutionRepoInterface

Returns an instance of NodeExecutionRepoInterface

func NewProjectRepo

func NewProjectRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer,
	scope promutils.Scope) interfaces.ProjectRepoInterface

func NewResourceRepo added in v0.2.0

func NewResourceRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer,
	scope promutils.Scope) interfaces.ResourceRepoInterface

func NewTaskExecutionRepo

func NewTaskExecutionRepo(
	db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.TaskExecutionRepoInterface

Returns an instance of TaskExecutionRepoInterface

func NewTaskRepo

func NewTaskRepo(
	db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.TaskRepoInterface

Returns an instance of TaskRepoInterface

func NewWorkflowRepo

func NewWorkflowRepo(
	db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.WorkflowRepoInterface

Returns an instance of WorkflowRepoInterface

func ValidateListInput

Validates there are no missing but required parameters in ListResourceInput

Types

type ExecutionRepo

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

Implementation of ExecutionInterface.

func (*ExecutionRepo) Create

func (r *ExecutionRepo) Create(ctx context.Context, input models.Execution) error

func (*ExecutionRepo) Get

func (*ExecutionRepo) GetByID

func (r *ExecutionRepo) GetByID(ctx context.Context, id uint) (models.Execution, error)

func (*ExecutionRepo) Update

func (r *ExecutionRepo) Update(ctx context.Context, event models.ExecutionEvent, execution models.Execution) error

func (*ExecutionRepo) UpdateExecution

func (r *ExecutionRepo) UpdateExecution(ctx context.Context, execution models.Execution) error

type LaunchPlanRepo

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

Implementation of LaunchPlanRepoInterface.

func (*LaunchPlanRepo) Create

func (r *LaunchPlanRepo) Create(ctx context.Context, input models.LaunchPlan) error

func (*LaunchPlanRepo) Get

func (*LaunchPlanRepo) ListLaunchPlanIdentifiers

func (*LaunchPlanRepo) SetActive

func (r *LaunchPlanRepo) SetActive(
	ctx context.Context, toEnable models.LaunchPlan, toDisable *models.LaunchPlan) error

This operation is performed as a two-step transaction because only one launch plan version can be active at a time. Transactional semantics are used to guarantee that setting the desired launch plan to active also disables the existing launch plan version (if any).

func (*LaunchPlanRepo) Update

func (r *LaunchPlanRepo) Update(ctx context.Context, input models.LaunchPlan) error

type NamedEntityRepo added in v0.1.5

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

Implementation of NamedEntityRepoInterface.

func (*NamedEntityRepo) Get added in v0.1.5

func (*NamedEntityRepo) List added in v0.1.5

func (*NamedEntityRepo) Update added in v0.1.5

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

type NodeExecutionRepo

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

Implementation of NodeExecutionInterface.

func (*NodeExecutionRepo) Create

Persist the node execution and the initial event that triggers this execution. If any of the persistence fails rollback the transaction all together.

func (*NodeExecutionRepo) Get

func (*NodeExecutionRepo) Update

func (r *NodeExecutionRepo) Update(ctx context.Context, event *models.NodeExecutionEvent, nodeExecution *models.NodeExecution) error

Persist the event that triggers an update in execution. If any of the persistence fails rollback the transaction all together.

type ProjectRepo

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

func (*ProjectRepo) Create

func (r *ProjectRepo) Create(ctx context.Context, project models.Project) error

func (*ProjectRepo) Get

func (r *ProjectRepo) Get(ctx context.Context, projectID string) (models.Project, error)

func (*ProjectRepo) ListAll

func (r *ProjectRepo) ListAll(ctx context.Context, sortParameter common.SortParameter) ([]models.Project, error)

func (*ProjectRepo) UpdateProject added in v0.3.3

func (r *ProjectRepo) UpdateProject(ctx context.Context, projectUpdate models.Project) error

type ResourceRepo added in v0.2.0

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

func (*ResourceRepo) CreateOrUpdate added in v0.2.0

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

func (*ResourceRepo) Delete added in v0.2.0

func (*ResourceRepo) Get added in v0.2.0

func (*ResourceRepo) GetRaw added in v0.2.0

func (*ResourceRepo) ListAll added in v0.2.3

func (r *ResourceRepo) ListAll(ctx context.Context, resourceType string) ([]models.Resource, error)

type TaskExecutionRepo

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

Implementation of TaskExecutionInterface.

func (*TaskExecutionRepo) Create

func (*TaskExecutionRepo) Get

func (*TaskExecutionRepo) Update

func (r *TaskExecutionRepo) Update(ctx context.Context, execution models.TaskExecution) error

type TaskRepo

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

Implementation of TaskRepoInterface.

func (*TaskRepo) Create

func (r *TaskRepo) Create(ctx context.Context, input models.Task) error

func (*TaskRepo) Get

func (*TaskRepo) ListTaskIdentifiers

type WorkflowRepo

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

Implementation of WorkflowRepoInterface.

func (*WorkflowRepo) Create

func (r *WorkflowRepo) Create(ctx context.Context, input models.Workflow) error

func (*WorkflowRepo) Get

func (*WorkflowRepo) ListIdentifiers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL