gormimpl

Documentation

Index

• func NewSchedulableEntityRepo(db *gorm.DB, errorTransformer adminErrors.ErrorTransformer, ...) interfaces.SchedulableEntityRepoInterface
• func NewScheduleEntitiesSnapshotRepo(db *gorm.DB, errorTransformer flyteSchedulerDbErrors.ErrorTransformer, ...) interfaces2.ScheduleEntitiesSnapShotRepoInterface
• type SchedulableEntityRepo
  • func (r *SchedulableEntityRepo) Activate(ctx context.Context, input models.SchedulableEntity) error
  • func (r *SchedulableEntityRepo) Create(ctx context.Context, input models.SchedulableEntity) error
  • func (r *SchedulableEntityRepo) Deactivate(ctx context.Context, ID models.SchedulableEntityKey) error
  • func (r *SchedulableEntityRepo) Get(ctx context.Context, ID models.SchedulableEntityKey) (models.SchedulableEntity, error)
  • func (r *SchedulableEntityRepo) GetAll(ctx context.Context) ([]models.SchedulableEntity, error)
• type ScheduleEntitiesSnapshotRepo
  • func (r *ScheduleEntitiesSnapshotRepo) Read(ctx context.Context) (models.ScheduleEntitiesSnapshot, error)
  • func (r *ScheduleEntitiesSnapshotRepo) Write(ctx context.Context, input models.ScheduleEntitiesSnapshot) error

Functions

func NewSchedulableEntityRepo

func NewSchedulableEntityRepo(
	db *gorm.DB, errorTransformer adminErrors.ErrorTransformer, scope promutils.Scope) interfaces.SchedulableEntityRepoInterface

NewSchedulableEntityRepo Returns an instance of SchedulableEntityRepoInterface

func NewScheduleEntitiesSnapshotRepo

func NewScheduleEntitiesSnapshotRepo(
	db *gorm.DB, errorTransformer flyteSchedulerDbErrors.ErrorTransformer, scope promutils.Scope) interfaces2.ScheduleEntitiesSnapShotRepoInterface

NewScheduleEntitiesSnapshotRepo Returns an instance of ScheduleEntitiesSnapshotRepoInterface

Types

type SchedulableEntityRepo

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

SchedulableEntityRepo Implementation of SchedulableEntityRepoInterface.

func (*SchedulableEntityRepo) Activate

func (r *SchedulableEntityRepo) Activate(ctx context.Context, input models.SchedulableEntity) error

func (*SchedulableEntityRepo) Create

func (r *SchedulableEntityRepo) Create(ctx context.Context, input models.SchedulableEntity) error

func (*SchedulableEntityRepo) Deactivate

func (r *SchedulableEntityRepo) Deactivate(ctx context.Context, ID models.SchedulableEntityKey) error

func (*SchedulableEntityRepo) Get

func (r *SchedulableEntityRepo) Get(ctx context.Context, ID models.SchedulableEntityKey) (models.SchedulableEntity, error)

func (*SchedulableEntityRepo) GetAll

func (r *SchedulableEntityRepo) GetAll(ctx context.Context) ([]models.SchedulableEntity, error)

type ScheduleEntitiesSnapshotRepo

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

ScheduleEntitiesSnapshotRepo Implementation of ScheduleEntitiesSnapshotRepoInterface.

func (*ScheduleEntitiesSnapshotRepo) Read

func (r *ScheduleEntitiesSnapshotRepo) Read(ctx context.Context) (models.ScheduleEntitiesSnapshot, error)

func (*ScheduleEntitiesSnapshotRepo) Write

func (r *ScheduleEntitiesSnapshotRepo) Write(ctx context.Context, input models.ScheduleEntitiesSnapshot) error

TODO : always overwrite the existing snapshot instead of creating new rows