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 (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
	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

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.