repositories

Documentation

Index

• func GetDB(ctx context.Context, dbConfig *database.DbConfig, logConfig *logger.Config) (*gorm.DB, error)
• func NewGormRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.Repository
• type GormRepo
  • func (r *GormRepo) DescriptionEntityRepo() interfaces.DescriptionEntityRepoInterface
  • func (r *GormRepo) ExecutionEventRepo() interfaces.ExecutionEventRepoInterface
  • func (r *GormRepo) ExecutionRepo() interfaces.ExecutionRepoInterface
  • func (r *GormRepo) GetGormDB() *gorm.DB
  • func (r *GormRepo) LaunchPlanRepo() interfaces.LaunchPlanRepoInterface
  • func (r *GormRepo) NamedEntityRepo() interfaces.NamedEntityRepoInterface
  • func (r *GormRepo) NodeExecutionEventRepo() interfaces.NodeExecutionEventRepoInterface
  • func (r *GormRepo) NodeExecutionRepo() interfaces.NodeExecutionRepoInterface
  • func (r *GormRepo) ProjectRepo() interfaces.ProjectRepoInterface
  • func (r *GormRepo) ResourceRepo() interfaces.ResourceRepoInterface
  • func (r *GormRepo) SchedulableEntityRepo() schedulerInterfaces.SchedulableEntityRepoInterface
  • func (r *GormRepo) ScheduleEntitiesSnapshotRepo() schedulerInterfaces.ScheduleEntitiesSnapShotRepoInterface
  • func (r *GormRepo) SignalRepo() interfaces.SignalRepoInterface
  • func (r *GormRepo) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface
  • func (r *GormRepo) TaskRepo() interfaces.TaskRepoInterface
  • func (r *GormRepo) WorkflowRepo() interfaces.WorkflowRepoInterface

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