repositories

package
v0.6.22 Latest Latest
Warning

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

Go to latest
Published: Sep 2, 2021 License: Apache-2.0 Imports: 7 Imported by: 5

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) ExecutionEventRepo added in v0.4.12

func (p *PostgresRepo) ExecutionEventRepo() interfaces.ExecutionEventRepoInterface

func (*PostgresRepo) ExecutionRepo

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

func (*PostgresRepo) LaunchPlanRepo

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

func (*PostgresRepo) NamedEntityRepo added in v0.1.5

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

func (*PostgresRepo) NodeExecutionEventRepo added in v0.4.12

func (p *PostgresRepo) NodeExecutionEventRepo() interfaces.NodeExecutionEventRepoInterface

func (*PostgresRepo) NodeExecutionRepo

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

func (*PostgresRepo) ProjectRepo

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

func (*PostgresRepo) ResourceRepo added in v0.3.38

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
	ExecutionEventRepo() interfaces.ExecutionEventRepoInterface
	ProjectRepo() interfaces.ProjectRepoInterface
	ResourceRepo() interfaces.ResourceRepoInterface
	NodeExecutionRepo() interfaces.NodeExecutionRepoInterface
	NodeExecutionEventRepo() interfaces.NodeExecutionEventRepoInterface
	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

Jump to

Keyboard shortcuts

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