service

Documentation

Index

• type PipelineService
  • func (p *PipelineService) CreatePipeline(pipeline model.Pipeline) (model.Pipeline, error)
  • func (p *PipelineService) DeletePipeline(namespace string, pipelineName string) error
  • func (p *PipelineService) GetPipelineByName(namespace string, pipelineName string) (model.Pipeline, error)
  • func (p *PipelineService) ListPipelines(query model.ListPipelineQuery) ([]model.Pipeline, uint64, uint64, error)
  • func (p *PipelineService) TriggerPipeline(namespace string, req *pipelinePB.TriggerPipelineRequest, ...) (*modelPB.TriggerModelResponse, error)
  • func (p *PipelineService) TriggerPipelineByUpload(namespace string, image bytes.Buffer, pipeline model.Pipeline) (*modelPB.TriggerModelBinaryFileUploadResponse, error)
  • func (p *PipelineService) UpdatePipeline(pipeline model.Pipeline) (model.Pipeline, error)
  • func (p *PipelineService) ValidateModel(namespace string, selectedModels []*model.Model) error
  • func (p *PipelineService) ValidateTriggerPipeline(namespace string, pipelineName string, pipeline model.Pipeline) error
• type Services
  • func NewPipelineService(r repository.Operations, modelServiceClient modelPB.ModelServiceClient) Services

Types

type PipelineService

type PipelineService struct {
	PipelineRepository repository.Operations
	ModelServiceClient modelPB.ModelServiceClient
}

func (*PipelineService) CreatePipeline

func (p *PipelineService) CreatePipeline(pipeline model.Pipeline) (model.Pipeline, error)

func (*PipelineService) DeletePipeline

func (p *PipelineService) DeletePipeline(namespace string, pipelineName string) error

func (*PipelineService) GetPipelineByName

func (p *PipelineService) GetPipelineByName(namespace string, pipelineName string) (model.Pipeline, error)

func (*PipelineService) ListPipelines

func (p *PipelineService) ListPipelines(query model.ListPipelineQuery) ([]model.Pipeline, uint64, uint64, error)

func (*PipelineService) TriggerPipeline

func (p *PipelineService) TriggerPipeline(namespace string, req *pipelinePB.TriggerPipelineRequest, pipeline model.Pipeline) (*modelPB.TriggerModelResponse, error)

func (*PipelineService) TriggerPipelineByUpload

func (p *PipelineService) TriggerPipelineByUpload(namespace string, image bytes.Buffer, pipeline model.Pipeline) (*modelPB.TriggerModelBinaryFileUploadResponse, error)

func (*PipelineService) UpdatePipeline

func (p *PipelineService) UpdatePipeline(pipeline model.Pipeline) (model.Pipeline, error)

func (*PipelineService) ValidateModel

func (p *PipelineService) ValidateModel(namespace string, selectedModels []*model.Model) error

func (*PipelineService) ValidateTriggerPipeline

func (p *PipelineService) ValidateTriggerPipeline(namespace string, pipelineName string, pipeline model.Pipeline) error

type Services

type Services 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
	TriggerPipeline(namespace string, trigger *pipelinePB.TriggerPipelineRequest, pipeline model.Pipeline) (*modelPB.TriggerModelResponse, error)
	ValidateTriggerPipeline(namespace string, pipelineName string, pipeline model.Pipeline) error
	TriggerPipelineByUpload(namespace string, buf bytes.Buffer, pipeline model.Pipeline) (*modelPB.TriggerModelBinaryFileUploadResponse, error)
	ValidateModel(namespace string, selectedModel []*model.Model) error
}

func NewPipelineService

func NewPipelineService(r repository.Operations, modelServiceClient modelPB.ModelServiceClient) Services