repositories

Documentation

Index

• Variables
• type PostgresRepo
  • func (p *PostgresRepo) ExecutionRepo() interfaces.ExecutionRepoInterface
  • func (p *PostgresRepo) LaunchPlanRepo() interfaces.LaunchPlanRepoInterface
  • func (p *PostgresRepo) NodeExecutionRepo() interfaces.NodeExecutionRepoInterface
  • func (p *PostgresRepo) ProjectRepo() interfaces.ProjectRepoInterface
  • func (p *PostgresRepo) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface
  • func (p *PostgresRepo) TaskRepo() interfaces.TaskRepoInterface
  • func (p *PostgresRepo) WorkflowRepo() interfaces.WorkflowRepoInterface
• type RepoConfig
• type RepositoryInterface
  • func GetRepository(repoType RepoConfig, dbConfig config.DbConfig, scope promutils.Scope) RepositoryInterface
  • func NewPostgresRepo(db *gorm.DB, errorTransformer errors.ErrorTransformer, scope promutils.Scope) RepositoryInterface

Variables

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

Types

type PostgresRepo

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

func (*PostgresRepo) ExecutionRepo

func (p *PostgresRepo) ExecutionRepo() interfaces.ExecutionRepoInterface

func (*PostgresRepo) LaunchPlanRepo

func (p *PostgresRepo) LaunchPlanRepo() interfaces.LaunchPlanRepoInterface

func (*PostgresRepo) NodeExecutionRepo

func (p *PostgresRepo) NodeExecutionRepo() interfaces.NodeExecutionRepoInterface

func (*PostgresRepo) ProjectRepo

func (p *PostgresRepo) ProjectRepo() interfaces.ProjectRepoInterface

func (*PostgresRepo) TaskExecutionRepo

func (p *PostgresRepo) TaskExecutionRepo() interfaces.TaskExecutionRepoInterface

func (*PostgresRepo) TaskRepo

func (p *PostgresRepo) TaskRepo() interfaces.TaskRepoInterface

func (*PostgresRepo) WorkflowRepo

func (p *PostgresRepo) WorkflowRepo() interfaces.WorkflowRepoInterface

type RepoConfig

type RepoConfig int32

const (
	POSTGRES RepoConfig = 0
)

type RepositoryInterface

type RepositoryInterface interface {
	TaskRepo() interfaces.TaskRepoInterface
	WorkflowRepo() interfaces.WorkflowRepoInterface
	LaunchPlanRepo() interfaces.LaunchPlanRepoInterface
	ExecutionRepo() interfaces.ExecutionRepoInterface
	ProjectRepo() interfaces.ProjectRepoInterface
	NodeExecutionRepo() interfaces.NodeExecutionRepoInterface
	TaskExecutionRepo() interfaces.TaskExecutionRepoInterface
}

The RepositoryInterface indicates the methods that each Repository must support. A Repository indicates a Database which is collection of Tables/models. The goal is allow databases to be Plugged in easily.

func GetRepository

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

func NewPostgresRepo

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