pipeline

Documentation

Index

• type BindNodeRequest
• type Controller
  • func (instance *Controller) DeleteBy(id string, ctx iris.Context) mvc.Response
  • func (instance *Controller) DeleteTaskBy(id string, ctx iris.Context) mvc.Response
  • func (instance *Controller) Get(ctx iris.Context) mvc.Response
  • func (instance *Controller) GetNodes(ctx iris.Context) mvc.Response
  • func (instance *Controller) GetTasks(ctx iris.Context) mvc.Response
  • func (instance *Controller) PatchBy(id string, ctx iris.Context) mvc.Response
  • func (instance *Controller) Post(ctx iris.Context) mvc.Response
  • func (instance *Controller) PostKiller(ctx iris.Context) mvc.Response
  • func (instance *Controller) PostNodes(ctx iris.Context) mvc.Response
  • func (instance *Controller) PostTask(ctx iris.Context) mvc.Response
  • func (instance *Controller) PutBy(id string, ctx iris.Context) mvc.Response
  • func (instance *Controller) PutSteps(ctx iris.Context) mvc.Response
  • func (instance *Controller) PutTaskBy(id string, ctx iris.Context) mvc.Response
• type KillPipelineRequest
• type PutStepsRequest

Types

type BindNodeRequest

type BindNodeRequest struct {
	PipelineId string   `json:"pipeline_id" validate:"required,uuid4"`
	NodesId    []string `json:"nodes_id" validate:"required"`
}

type Controller

type Controller struct {
	Service services.PipelineService
}

func (*Controller) DeleteBy

func (instance *Controller) DeleteBy(id string, ctx iris.Context) mvc.Response

删除流水线

func (*Controller) DeleteTaskBy

func (instance *Controller) DeleteTaskBy(id string, ctx iris.Context) mvc.Response

从流水线解绑任务

func (*Controller) Get

func (instance *Controller) Get(ctx iris.Context) mvc.Response

获取流水线列表

func (*Controller) GetNodes

func (instance *Controller) GetNodes(ctx iris.Context) mvc.Response

获取流水线绑定的节点

func (*Controller) GetTasks

func (instance *Controller) GetTasks(ctx iris.Context) mvc.Response

获取流水线绑定的任务

func (*Controller) PatchBy

func (instance *Controller) PatchBy(id string, ctx iris.Context) mvc.Response

同步流水线数据到 ETCD

func (*Controller) Post

func (instance *Controller) Post(ctx iris.Context) mvc.Response

创建流水线

func (*Controller) PostKiller

func (instance *Controller) PostKiller(ctx iris.Context) mvc.Response

创建强杀指令

func (*Controller) PostNodes

func (instance *Controller) PostNodes(ctx iris.Context) mvc.Response

绑定流水线到节点

func (*Controller) PostTask

func (instance *Controller) PostTask(ctx iris.Context) mvc.Response

绑定任务到流水线

func (*Controller) PutBy

func (instance *Controller) PutBy(id string, ctx iris.Context) mvc.Response

更新流水线

func (*Controller) PutSteps

func (instance *Controller) PutSteps(ctx iris.Context) mvc.Response

根据拖动顺序排序数据

func (*Controller) PutTaskBy

func (instance *Controller) PutTaskBy(id string, ctx iris.Context) mvc.Response

修改绑定关系

type KillPipelineRequest

type KillPipelineRequest struct {
	PipelineId string `json:"pipeline_id" validate:"required,uuid4"`
}

type PutStepsRequest

type PutStepsRequest struct {
	PipelineId string `json:"pipeline_id" validate:"required,uuid4"`
	Origin     int    `json:"origin" validate:"numeric"`
	Current    int    `json:"current" validate:"numeric"`
}