gormimpl

package
v1.1.12 Latest Latest
Warning

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

Go to latest
Published: May 27, 2022 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

View Source
const Description = "description"
View Source
const Domain = "domain"
View Source
const ID = "id"
View Source
const Name = "name"
View Source
const Project = "project"
View Source
const ResourceType = "resource_type"
View Source
const State = "state"

Variables

This section is empty.

Functions

func NewExecutionEventRepo added in v0.4.12

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

Returns an instance of ExecutionRepoInterface

func NewExecutionRepo

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

Returns an instance of ExecutionRepoInterface

func NewLaunchPlanRepo

func NewLaunchPlanRepo(
	db *gorm.DB, errorTransformer adminErrors.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 NewNodeExecutionEventRepo added in v0.4.12

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

Returns an instance of NodeExecutionRepoInterface

func NewNodeExecutionRepo

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

Returns an instance of NodeExecutionRepoInterface

func NewResourceRepo added in v0.3.38

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

func NewTaskExecutionRepo

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

Returns an instance of TaskExecutionRepoInterface

func NewTaskRepo

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

Returns an instance of TaskRepoInterface

func NewWorkflowRepo

func NewWorkflowRepo(
	db *gorm.DB, errorTransformer flyteAdminDbErrors.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 ExecutionEventRepo added in v0.4.12

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

func (*ExecutionEventRepo) Create added in v0.4.12

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) Update

func (r *ExecutionRepo) Update(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 NodeExecutionEventRepo added in v0.4.12

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

func (*NodeExecutionEventRepo) Create added in v0.4.12

type NodeExecutionRepo

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

Implementation of NodeExecutionInterface.

func (*NodeExecutionRepo) Create

func (r *NodeExecutionRepo) Create(ctx context.Context, execution *models.NodeExecution) error

func (*NodeExecutionRepo) Exists added in v0.4.6

func (*NodeExecutionRepo) Get

func (*NodeExecutionRepo) GetWithChildren added in v0.6.124

func (*NodeExecutionRepo) Update

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

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) List added in v0.3.38

func (*ProjectRepo) UpdateProject added in v0.3.38

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

type ResourceRepo added in v0.3.38

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

func (*ResourceRepo) CreateOrUpdate added in v0.3.38

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

func (*ResourceRepo) Delete added in v0.3.38

func (*ResourceRepo) Get added in v0.3.38

func (*ResourceRepo) GetRaw added in v0.3.38

func (*ResourceRepo) ListAll added in v0.3.38

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 (r *TaskRepo) Get(ctx context.Context, input interfaces.Identifier) (models.Task, error)

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