repositories

Documentation

Overview

Package repositories This package provides the interfaces and implementations to save and retrieve schedules and snapshots from the DB. Along with activating and deactivating the schedules.

Index

• Variables
• type PostgresRepo
  • func (p *PostgresRepo) SchedulableEntityRepo() interfaces.SchedulableEntityRepoInterface
  • func (p *PostgresRepo) ScheduleEntitiesSnapshotRepo() interfaces.ScheduleEntitiesSnapShotRepoInterface
• type RepoConfig
• type SchedulerRepoInterface
  • func GetRepository(repoType RepoConfig, dbConfig config.DbConfig, scope promutils.Scope) SchedulerRepoInterface
  • func NewPostgresRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) SchedulerRepoInterface

Variables

var RepositoryConfigurationName = map[int32]string{
	0: "POSTGRES",
}

Types

type PostgresRepo

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

func (*PostgresRepo) SchedulableEntityRepo

func (p *PostgresRepo) SchedulableEntityRepo() interfaces.SchedulableEntityRepoInterface

func (*PostgresRepo) ScheduleEntitiesSnapshotRepo

func (p *PostgresRepo) ScheduleEntitiesSnapshotRepo() interfaces.ScheduleEntitiesSnapShotRepoInterface

type RepoConfig

type RepoConfig int32

const (
	POSTGRES RepoConfig = 0
)

type SchedulerRepoInterface

type SchedulerRepoInterface interface {
	SchedulableEntityRepo() interfaces.SchedulableEntityRepoInterface
	ScheduleEntitiesSnapshotRepo() interfaces.ScheduleEntitiesSnapShotRepoInterface
}

func GetRepository

func GetRepository(repoType RepoConfig, dbConfig config.DbConfig, scope promutils.Scope) SchedulerRepoInterface

func NewPostgresRepo

func NewPostgresRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) SchedulerRepoInterface