gormimpl

package
v1.9.24 Latest Latest
Warning

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

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

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 

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 NewProjectRepo 

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

func NewResourceRepo 

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

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 

func ValidateListInput(input interfaces.ListResourceInput) adminErrors.FlyteAdminError

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 

func (r *DescriptionEntityRepo) Get(ctx context.Context, input interfaces.GetDescriptionEntityInput) (models.DescriptionEntity, error)

func (*DescriptionEntityRepo) List 

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

type ExecutionEventRepo 

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

func (*ExecutionEventRepo) Create 

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 

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 

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

Implementation of NamedEntityRepoInterface.

func (*NamedEntityRepo) Get 

func (r *NamedEntityRepo) Get(ctx context.Context, input interfaces.GetNamedEntityInput) (models.NamedEntity, error)

func (*NamedEntityRepo) List 

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

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 

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 

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 

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 

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 

func (r *ProjectRepo) List(ctx context.Context, input interfaces.ListResourceInput) ([]models.Project, error)

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

func (*ResourceRepo) Get 

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 

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

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 

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 

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 (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.