repositories

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: May 5, 2022 License: Apache-2.0 Imports: 19 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetDB added in v0.6.100 

func GetDB(ctx context.Context, dbConfig *runtimeInterfaces.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 added in v0.6.100 

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

Types

type GormRepo added in v0.6.100 

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

func (*GormRepo) ExecutionEventRepo added in v0.6.100 

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

func (*GormRepo) ExecutionRepo added in v0.6.100 

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

func (*GormRepo) GetGormDB added in v0.6.100 

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

func (*GormRepo) LaunchPlanRepo added in v0.6.100 

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

func (*GormRepo) NamedEntityRepo added in v0.6.100 

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

func (*GormRepo) NodeExecutionEventRepo added in v0.6.100 

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

func (*GormRepo) NodeExecutionRepo added in v0.6.100 

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

func (*GormRepo) ProjectRepo added in v0.6.100 

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

func (*GormRepo) ResourceRepo added in v0.6.100 

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

func (*GormRepo) SchedulableEntityRepo added in v0.6.100 

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

func (*GormRepo) ScheduleEntitiesSnapshotRepo added in v0.6.100 

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

func (*GormRepo) TaskExecutionRepo added in v0.6.100 

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

func (*GormRepo) TaskRepo added in v0.6.100 

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

func (*GormRepo) WorkflowRepo added in v0.6.100 

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

Source Files

View all Source files

Directories

Path Synopsis
Generic errors used across files in repositories/ Postgres-specific implementation of an ErrorTransformer.
 Generic errors used across files in repositories/ Postgres-specific implementation of an ErrorTransformer.
gen
models
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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.