repositories

package
v1.9.36 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetDB

func GetDB(ctx context.Context, dbConfig *database.DbConfig, logConfig *logger.Config) (
	*gorm.DB, error)

GetDB uses the dbConfig to create gorm DB object. If the db doesn't exist for the dbConfig then a new one is created using the default db for the provider. eg : postgres has default dbName as postgres

func NewGormRepo

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

Types

type GormRepo

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

func (*GormRepo) DescriptionEntityRepo

func (r *GormRepo) DescriptionEntityRepo() interfaces.DescriptionEntityRepoInterface

func (*GormRepo) ExecutionEventRepo

func (r *GormRepo) ExecutionEventRepo() interfaces.ExecutionEventRepoInterface

func (*GormRepo) ExecutionRepo

func (r *GormRepo) ExecutionRepo() interfaces.ExecutionRepoInterface

func (*GormRepo) GetGormDB

func (r *GormRepo) GetGormDB() *gorm.DB

func (*GormRepo) LaunchPlanRepo

func (r *GormRepo) LaunchPlanRepo() interfaces.LaunchPlanRepoInterface

func (*GormRepo) NamedEntityRepo

func (r *GormRepo) NamedEntityRepo() interfaces.NamedEntityRepoInterface

func (*GormRepo) NodeExecutionEventRepo

func (r *GormRepo) NodeExecutionEventRepo() interfaces.NodeExecutionEventRepoInterface

func (*GormRepo) NodeExecutionRepo

func (r *GormRepo) NodeExecutionRepo() interfaces.NodeExecutionRepoInterface

func (*GormRepo) ProjectRepo

func (r *GormRepo) ProjectRepo() interfaces.ProjectRepoInterface

func (*GormRepo) ResourceRepo

func (r *GormRepo) ResourceRepo() interfaces.ResourceRepoInterface

func (*GormRepo) SchedulableEntityRepo

func (r *GormRepo) SchedulableEntityRepo() schedulerInterfaces.SchedulableEntityRepoInterface

func (*GormRepo) ScheduleEntitiesSnapshotRepo

func (r *GormRepo) ScheduleEntitiesSnapshotRepo() schedulerInterfaces.ScheduleEntitiesSnapShotRepoInterface

func (*GormRepo) SignalRepo

func (r *GormRepo) SignalRepo() interfaces.SignalRepoInterface

func (*GormRepo) TaskExecutionRepo

func (r *GormRepo) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface

func (*GormRepo) TaskRepo

func (r *GormRepo) TaskRepo() interfaces.TaskRepoInterface

func (*GormRepo) WorkflowRepo

func (r *GormRepo) WorkflowRepo() interfaces.WorkflowRepoInterface

Directories

Path Synopsis
Generic errors used across files in repositories/
Generic errors used across files in repositories/
gen
Mock implementation of a workflow repo to be used for tests.
Mock implementation of a workflow repo to be used for tests.
Handles translating gRPC request & response objects to and from repository model objects
Handles translating gRPC request & response objects to and from repository model objects

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL