Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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) NamedEntityRepo

func (p *PostgresRepo) NamedEntityRepo() interfaces.NamedEntityRepoInterface

func (*PostgresRepo) NodeExecutionRepo

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

func (*PostgresRepo) ProjectRepo

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

func (*PostgresRepo) ResourceRepo

func (p *PostgresRepo) ResourceRepo() interfaces.ResourceRepoInterface

func (*PostgresRepo) TaskExecutionRepo

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

func (*PostgresRepo) TaskRepo

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
	ResourceRepo() interfaces.ResourceRepoInterface
	NodeExecutionRepo() interfaces.NodeExecutionRepoInterface
	TaskExecutionRepo() interfaces.TaskExecutionRepoInterface
	NamedEntityRepo() interfaces.NamedEntityRepoInterface
}

    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

    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