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 NewProjectRepo 

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

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 

func ValidateListInput(input interfaces.ListResourceInput) adminErrors.FlyteAdminError

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 (r *DescriptionEntityRepo) Get(ctx context.Context, input interfaces.GetDescriptionEntityInput) (models.DescriptionEntity, error)

func (*DescriptionEntityRepo) List added in v1.1.67 

func (r *DescriptionEntityRepo) List(
	ctx context.Context, input interfaces.ListResourceInput) (interfaces.DescriptionEntityCollectionOutput, error)

type ExecutionEventRepo added in v0.4.12 

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

func (*ExecutionEventRepo) Create added in v0.4.12 

func (r *ExecutionEventRepo) Create(ctx context.Context, input models.ExecutionEvent) error

type ExecutionRepo 

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

Implementation of ExecutionInterface.

func (*ExecutionRepo) Count added in v1.1.36 

func (r *ExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

func (*ExecutionRepo) Create 

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

func (*ExecutionRepo) Get 

func (r *ExecutionRepo) Get(_ context.Context, input interfaces.Identifier) (models.Execution, error)

func (*ExecutionRepo) List 

func (r *ExecutionRepo) List(_ context.Context, input interfaces.ListResourceInput) (
	interfaces.ExecutionCollectionOutput, error)

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

func (*LaunchPlanRepo) List 

func (r *LaunchPlanRepo) List(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.LaunchPlanCollectionOutput, error)

func (*LaunchPlanRepo) ListLaunchPlanIdentifiers 

func (r *LaunchPlanRepo) ListLaunchPlanIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.LaunchPlanCollectionOutput, error)

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 (r *NamedEntityRepo) Get(ctx context.Context, input interfaces.GetNamedEntityInput) (models.NamedEntity, error)

func (*NamedEntityRepo) List added in v0.1.5 

func (r *NamedEntityRepo) List(ctx context.Context, input interfaces.ListNamedEntityInput) (
	interfaces.NamedEntityCollectionOutput, error)

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 

func (r *NodeExecutionEventRepo) Create(ctx context.Context, input models.NodeExecutionEvent) error

type NodeExecutionRepo 

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

Implementation of NodeExecutionInterface.

func (*NodeExecutionRepo) Count added in v1.1.36 

func (r *NodeExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

func (*NodeExecutionRepo) Create 

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

func (*NodeExecutionRepo) Exists added in v0.4.6 

func (r *NodeExecutionRepo) Exists(ctx context.Context, input interfaces.NodeExecutionResource) (bool, error)

func (*NodeExecutionRepo) Get 

func (r *NodeExecutionRepo) Get(ctx context.Context, input interfaces.NodeExecutionResource) (models.NodeExecution, error)

func (*NodeExecutionRepo) GetWithChildren added in v0.6.124 

func (r *NodeExecutionRepo) GetWithChildren(ctx context.Context, input interfaces.NodeExecutionResource) (models.NodeExecution, error)

func (*NodeExecutionRepo) List 

func (r *NodeExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.NodeExecutionCollectionOutput, error)

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 (r *ProjectRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Project, error)

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 (r *ResourceRepo) Delete(ctx context.Context, ID interfaces.ResourceID) error

func (*ResourceRepo) Get added in v0.3.38 

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

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 (r *ResourceRepo) GetRaw(ctx context.Context, ID interfaces.ResourceID) (models.Resource, error)

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 

func (s *SignalRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Signal, error)

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 (r *TaskExecutionRepo) Count(ctx context.Context, input interfaces.CountResourceInput) (int64, error)

func (*TaskExecutionRepo) Create 

func (r *TaskExecutionRepo) Create(ctx context.Context, input models.TaskExecution) error

func (*TaskExecutionRepo) Get 

func (r *TaskExecutionRepo) Get(ctx context.Context, input interfaces.GetTaskExecutionInput) (models.TaskExecution, error)

func (*TaskExecutionRepo) List 

func (r *TaskExecutionRepo) List(ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskExecutionCollectionOutput, error)

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

func (r *TaskRepo) List(
	ctx context.Context, input interfaces.ListResourceInput) (interfaces.TaskCollectionOutput, error)

func (*TaskRepo) ListTaskIdentifiers 

func (r *TaskRepo) ListTaskIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.TaskCollectionOutput, error)

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

func (*WorkflowRepo) List 

func (r *WorkflowRepo) List(
	ctx context.Context, input interfaces.ListResourceInput) (interfaces.WorkflowCollectionOutput, error)

func (*WorkflowRepo) ListIdentifiers 

func (r *WorkflowRepo) ListIdentifiers(ctx context.Context, input interfaces.ListResourceInput) (
	interfaces.WorkflowCollectionOutput, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.