service

Documentation

Index

• type PipelineService
  • func NewPipelineService(r repository.PipelineRepository, modelServiceClient modelPB.ModelClient) PipelineService

Types

type PipelineService

type PipelineService interface {
	CreatePipeline(pipeline model.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) (model.Pipeline, error)
	DeletePipeline(namespace string, pipelineName string) error
	ValidateTriggerPipeline(namespace string, pipelineName string, pipeline model.Pipeline) error
	TriggerPipelineByUpload(namespace string, buf bytes.Buffer, pipeline model.Pipeline) (interface{}, error)
	ValidateModel(namespace string, selectedModel []*model.Model) error
}

func NewPipelineService

func NewPipelineService(r repository.PipelineRepository, modelServiceClient modelPB.ModelClient) PipelineService