repository

Documentation

Index

• Variables
• type Operations
  • func NewPipelineRepository(db *gorm.DB) Operations
• type PipelineRepository
  • func (r *PipelineRepository) CreatePipeline(pipeline model.Pipeline) error
  • func (r *PipelineRepository) DeletePipeline(namespace string, pipelineName string) error
  • func (r *PipelineRepository) GetPipelineByName(namespace string, pipelineName string) (model.Pipeline, error)
  • func (r *PipelineRepository) ListPipelines(query model.ListPipelineQuery) ([]model.Pipeline, uint64, uint64, error)
  • func (r *PipelineRepository) UpdatePipeline(pipeline model.Pipeline) error

Variables

var GetPipelineSelectField = []string{
	`"pipelines"."id" as id`,
	`"pipelines"."name"`,
	`"pipelines"."description"`,
	`"pipelines"."active"`,
	`"pipelines"."created_at"`,
	`"pipelines"."updated_at"`,
	`'Pipeline' as kind`,
	`CONCAT(namespace, '/', name) as full_name`,
}

var GetPipelineWithRecipeSelectField = []string{
	`"pipelines"."id" as id`,
	`"pipelines"."name"`,
	`"pipelines"."description"`,
	`"pipelines"."active"`,
	`"pipelines"."created_at"`,
	`"pipelines"."updated_at"`,
	`"pipelines"."recipe"`,
	`'Pipeline' as kind`,
	`CONCAT(namespace, '/', name) as full_name`,
}

Types

type Operations

type Operations interface {
	CreatePipeline(pipeline model.Pipeline) error
	ListPipelines(query model.ListPipelineQuery) ([]model.Pipeline, uint64, uint64, error)
	GetPipelineByName(namespace string, pipelineName string) (model.Pipeline, error)
	UpdatePipeline(pipeline model.Pipeline) error
	DeletePipeline(namespace string, pipelineName string) error
}

func NewPipelineRepository

func NewPipelineRepository(db *gorm.DB) Operations

type PipelineRepository

type PipelineRepository struct {
	DB *gorm.DB
}

func (*PipelineRepository) CreatePipeline

func (r *PipelineRepository) CreatePipeline(pipeline model.Pipeline) error

func (*PipelineRepository) DeletePipeline

func (r *PipelineRepository) DeletePipeline(namespace string, pipelineName string) error

func (*PipelineRepository) GetPipelineByName

func (r *PipelineRepository) GetPipelineByName(namespace string, pipelineName string) (model.Pipeline, error)

func (*PipelineRepository) ListPipelines

func (r *PipelineRepository) ListPipelines(query model.ListPipelineQuery) ([]model.Pipeline, uint64, uint64, error)

func (*PipelineRepository) UpdatePipeline

func (r *PipelineRepository) UpdatePipeline(pipeline model.Pipeline) error