repositories

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 8, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

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

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

func (*PostgresRepo) ProjectDomainRepo added in v0.1.4

func (p *PostgresRepo) ProjectDomainRepo() interfaces.ProjectDomainRepoInterface

func (*PostgresRepo) ProjectRepo

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

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
	ProjectDomainRepo() interfaces.ProjectDomainRepoInterface
	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

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.
Shared utils for postgresql tests.
Shared utils for postgresql tests.
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL