Documentation ¶
Index ¶
- func GetDB(ctx context.Context, dbConfig *runtimeInterfaces.DbConfig, ...) (*gorm.DB, error)
- func NewGormRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) interfaces.Repository
- type GormRepo
- 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) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface
- func (r *GormRepo) TaskRepo() interfaces.TaskRepoInterface
- func (r *GormRepo) WorkflowRepo() interfaces.WorkflowRepoInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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) 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
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. |
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 |
Click to show internal directories.
Click to hide internal directories.