gormimpl

package
v1.1.131 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const AdminTagsTableName = "admin_tags"
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"
View Source
const Version = "version"

Variables

This section is empty.

Functions

func NewDescriptionEntityRepo added in v1.1.67

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

NewDescriptionEntityRepo Returns an instance of DescriptionRepoInterface

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 NewSignalRepo added in v1.1.61

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

Returns an instance of SignalRepoInterface

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 DescriptionEntityRepo added in v1.1.67

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

DescriptionEntityRepo Implementation of DescriptionEntityRepoInterface.

func (*DescriptionEntityRepo) Get added in v1.1.67

func (*DescriptionEntityRepo) List added in v1.1.67

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) Count added in v1.1.36

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) Count added in v1.1.36

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

Get returns the most-specific attribute setting for the given ResourceType.

func (*ResourceRepo) GetProjectLevel added in v1.1.46

func (r *ResourceRepo) GetProjectLevel(ctx context.Context, ID interfaces.ResourceID) (models.Resource, error)

GetProjectLevel differs from Get in that it returns only the project-level attribute setting for the given ResourceType if it exists. The reason this exists is because we want to return project level attributes to Flyte Console, regardless of whether a more specific setting exists.

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 SignalRepo added in v1.1.61

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

SignalRepo is an implementation of SignalRepoInterface.

func (*SignalRepo) Get added in v1.1.61

func (s *SignalRepo) Get(ctx context.Context, input models.SignalKey) (models.Signal, error)

Get retrieves a signal model from the database store.

func (*SignalRepo) GetOrCreate added in v1.1.61

func (s *SignalRepo) GetOrCreate(ctx context.Context, input *models.Signal) error

GetOrCreate returns a signal if it already exists, if not it creates a new one given the input

func (*SignalRepo) List added in v1.1.61

List fetches all signals that match the provided input

func (*SignalRepo) Update added in v1.1.61

func (s *SignalRepo) Update(ctx context.Context, input models.SignalKey, value []byte) error

Update sets the value field on the specified signal model

type TaskExecutionRepo

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

Implementation of TaskExecutionInterface.

func (*TaskExecutionRepo) Count added in v1.1.36

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(_ context.Context, input models.Task, descriptionEntity *models.DescriptionEntity) 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(_ context.Context, input models.Workflow, descriptionEntity *models.DescriptionEntity) 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