impl

func (*PipelineServiceImpl) DescribePipelineTask ¶

func (i *PipelineServiceImpl) DescribePipelineTask(ctx context.Context, in *pipeline.DescribePipelineTaskRequest) (*pipeline.PipelineTask, error)

DescribePipelineTask implements runtime.Service.

func (*PipelineServiceImpl) Init ¶

func (i *PipelineServiceImpl) Init() error

func (*PipelineServiceImpl) Name ¶

func (i *PipelineServiceImpl) Name() string

func (*PipelineServiceImpl) QueryPipelineTask ¶

func (i *PipelineServiceImpl) QueryPipelineTask(ctx context.Context, in *pipeline.QueryPipelineRunTask) (*types.Set[*pipeline.PipelineTask], error)

Pipeline执行记录

func (*PipelineServiceImpl) RunPipeline ¶

func (i *PipelineServiceImpl) RunPipeline(ctx context.Context, in *pipeline.RunPipelineRequest) (*pipeline.PipelineTask, error)

RunPipeline implements runtime.Service.

func (*PipelineServiceImpl) SavePipelineRunTask ¶

func (s *PipelineServiceImpl) SavePipelineRunTask(ctx context.Context, in *pipeline.PipelineTask) error

func (*PipelineServiceImpl) UpdatePipelineTaskStatus ¶

func (i *PipelineServiceImpl) UpdatePipelineTaskStatus(ctx context.Context, in *pipeline.UpdatePipelineTaskStatusRequest) (*pipeline.PipelineTask, error)

更新Pipeline任务状态