gormimpl

package
v1.0.15 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

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

Variables

This section is empty.

Functions

func NewDescriptionEntityRepo

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

NewDescriptionEntityRepo Returns an instance of DescriptionRepoInterface

func NewExecutionEventRepo

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

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

Returns an instance of NamedEntityRepoInterface

func NewNodeExecutionEventRepo

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 NewSignalRepo

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

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

DescriptionEntityRepo Implementation of DescriptionEntityRepoInterface.

func (*DescriptionEntityRepo) Get

type ExecutionEventRepo

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

func (*ExecutionEventRepo) Create

type ExecutionRepo

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

Implementation of ExecutionInterface.

func (*ExecutionRepo) Count

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

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

Implementation of NamedEntityRepoInterface.

func (*NamedEntityRepo) Get

func (*NamedEntityRepo) Update

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

type NodeExecutionEventRepo

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

func (*NodeExecutionEventRepo) Create

type NodeExecutionRepo

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

Implementation of NodeExecutionInterface.

func (*NodeExecutionRepo) Count

func (*NodeExecutionRepo) Create

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

func (*NodeExecutionRepo) Exists

func (*NodeExecutionRepo) Get

func (*NodeExecutionRepo) GetWithChildren

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

func (*ProjectRepo) UpdateProject

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

type ResourceRepo

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

func (*ResourceRepo) CreateOrUpdate

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

func (*ResourceRepo) Delete

func (*ResourceRepo) Get

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

func (*ResourceRepo) GetProjectLevel

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

func (*ResourceRepo) ListAll

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

type SignalRepo

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

SignalRepo is an implementation of SignalRepoInterface.

func (*SignalRepo) Get

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

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

List fetches all signals that match the provided input

func (*SignalRepo) Update

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

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