pipeline

type AUDIT_RESPONSE int32

type AuditStepRequest struct {

	// 取消step对应的key
	// @gotags: json:"key"
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key"`
	// 审核的结果
	// @gotags: json:"audit_reponse"
	AuditReponse AUDIT_RESPONSE `` /* 137-byte string literal not displayed */
	// 审批时的反馈信息
	// @gotags: json:"audit_message"
	AuditMessage string `protobuf:"bytes,3,opt,name=audit_message,json=auditMessage,proto3" json:"audit_message"`
	// contains filtered or unexported fields
}

type CancelStepRequest struct {

	// 取消step对应的key
	// @gotags: json:"id"
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"id"`
	// contains filtered or unexported fields
}

type CancelWatchPipelineRequest struct {

	// @gotags: json:"watch_id"
	WatchId int64 `protobuf:"varint,2,opt,name=watch_id,json=watchId,proto3" json:"watch_id"`
	// contains filtered or unexported fields
}

type CreatePipelineRequest struct {

	// 模版id
	// @gotags: bson:"template_id" json:"template_id"
	TemplateId string `protobuf:"bytes,8,opt,name=template_id,json=templateId,proto3" json:"template_id" bson:"template_id"`
	// 触发事件
	// @gotags: bson:"hook_event" json:"hook_event"
	HookEvent *scm.WebHookEvent `protobuf:"bytes,9,opt,name=hook_event,json=hookEvent,proto3" json:"hook_event" bson:"hook_event"`
	// 所属域
	// @gotags: bson:"domain" json:"domain" validate:"required"
	Domain string `protobuf:"bytes,10,opt,name=domain,proto3" json:"domain" bson:"domain" validate:"required"`
	// 所属空间
	// @gotags: bson:"namespace" json:"namespace" validate:"required"
	Namespace string `protobuf:"bytes,11,opt,name=namespace,proto3" json:"namespace" bson:"namespace" validate:"required"`
	// 创建人
	// @gotags: bson:"create_by" json:"create_by" validate:"required"
	CreateBy string `protobuf:"bytes,12,opt,name=create_by,json=createBy,proto3" json:"create_by" bson:"create_by" validate:"required"`
	// 名称
	// @gotags: bson:"name" json:"name" validate:"required"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" bson:"name" validate:"required"`
	// 全局参数, Step执行时合并处理
	// @gotags: bson:"with" json:"with"
	With map[string]string `` /* 151-byte string literal not displayed */
	// 挂载文件
	// @gotags: bson:"mount" json:"mount"
	Mount *MountData `protobuf:"bytes,7,opt,name=mount,proto3" json:"mount" bson:"mount"`
	// 标签
	// @gotags: bson:"tags" json:"tags"
	Tags map[string]string `` /* 151-byte string literal not displayed */
	// 描述
	// @gotags: bson:"description" json:"description"
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description" bson:"description"`
	// 触发条件
	// @gotags: bson:"on" json:"on"
	On *Trigger `protobuf:"bytes,4,opt,name=on,proto3" json:"on" bson:"on"`
	// 具体编排阶段
	// @gotags: bson:"stages" json:"stages"
	Stages []*Stage `protobuf:"bytes,5,rep,name=stages,proto3" json:"stages" bson:"stages"`
	// contains filtered or unexported fields
}

type CreateStepRequest struct {

	// 名称
	// @gotags: json:"name" validate:"required"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" validate:"required"`
	// 具体动作
	// @gotags: json:"action" validate:"required"
	Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action" validate:"required"`
	// 是否需要审批, 审批通过后才能执行
	// @gotags: json:"with_audit"
	WithAudit bool `protobuf:"varint,3,opt,name=with_audit,json=withAudit,proto3" json:"with_audit"`
	// 审批参数, 有审批模块做具体实现
	// @gotags: json:"audit_params"
	AuditParams map[string]string `` /* 172-byte string literal not displayed */
	// 参数
	// @gotags: json:"with"
	With map[string]string `` /* 139-byte string literal not displayed */
	// step执行完成后, 是否需要通知
	// @gotags: json:"with_notify"
	WithNotify bool `protobuf:"varint,6,opt,name=with_notify,json=withNotify,proto3" json:"with_notify"`
	// 通知参数, 由通知模块做具体实现
	// @gotags: json:"notify_params"
	NotifyParams map[string]string `` /* 175-byte string literal not displayed */
	// WebHook配置, 用于和其他系统联动, 比如各种机器人
	// @gotags: json:"webhooks"
	Webhooks []*WebHook `protobuf:"bytes,8,rep,name=webhooks,proto3" json:"webhooks"`
	// 调度标签
	// @gotags: json:"node_selector"
	NodeSelector map[string]string `` /* 175-byte string literal not displayed */
	// 空间
	// @gotags: json:"namespace"
	Namespace string `protobuf:"bytes,10,opt,name=namespace,proto3" json:"namespace"`
	// contains filtered or unexported fields
}

type CreateWatchPipelineRequest struct {

	// @gotags: json:"mod"
	Mod PIPELINE_WATCH_MOD `protobuf:"varint,1,opt,name=mod,proto3,enum=infraboard.workflow.pipeline.PIPELINE_WATCH_MOD" json:"mod"`
	// 需要watch的pipeline id
	// @gotags: json:"id"
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id"`
	// watch整个namespace piplein 状态变化, 用于做namespace实时状态大屏
	// @gotags: json:"namespace"
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace"`
	// 并不执行真正的watch, 尝试运行, 主要用于链接前的检查工作
	// @gotags: json:"dry_run"
	DryRun bool `protobuf:"varint,4,opt,name=dry_run,json=dryRun,proto3" json:"dry_run"`
	// contains filtered or unexported fields
}

type DeletePipelineRequest struct {

	// 唯一ID
	// @gotags: json:"id"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
	// 只有所在在的空间
	// @gotags: json:"namespace"
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace"`
	// contains filtered or unexported fields
}

type DeleteStepRequest struct {

	// 唯一ID
	// @gotags: json:"key" validate:"required"
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key" validate:"required"`
	// contains filtered or unexported fields
}

type DescribePipelineRequest struct {

	// 唯一ID
	// @gotags: json:"id"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
	// 只有所在在的空间
	// @gotags: json:"namespace"
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace"`
	// contains filtered or unexported fields
}

type DescribeStepRequest struct {

	// 唯一ID
	// @gotags: json:"key"
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key"`
	// 唯一name
	// @gotags: json:"namespace"
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace"`
	// contains filtered or unexported fields
}

type Flow struct {
	// contains filtered or unexported fields
}

type MountData struct {

	// 挂载的根节点位置, 默认挂载点: workflow
	// @gotags: bson:"root" json:"root"
	Root string `protobuf:"bytes,1,opt,name=root,proto3" json:"root" bson:"root"`
	// 需要挂载的文件列表
	// @gotags: bson:"files" json:"files"
	Files []*MountFile `protobuf:"bytes,2,rep,name=files,proto3" json:"files" bson:"files"`
	// contains filtered or unexported fields
}

type MountFile struct {

	// 文件名称, 默认就是下载文件的名称
	// @gotags: bson:"name" json:"name"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" bson:"name"`
	// 文件下载地址
	// @gotags: bson:"download_url" json:"download_url"
	DownloadUrl string `protobuf:"bytes,2,opt,name=download_url,json=downloadUrl,proto3" json:"download_url" bson:"download_url"`
	// 是否解压
	// @gotags: bson:"unpack" json:"unpack"
	Unpack bool `protobuf:"varint,3,opt,name=unpack,proto3" json:"unpack" bson:"unpack"`
	// 解压目录
	// @gotags: bson:"unpack_dir" json:"unpack_dir"
	UnpackDir string `protobuf:"bytes,4,opt,name=unpack_dir,json=unpackDir,proto3" json:"unpack_dir" bson:"unpack_dir"`
	// contains filtered or unexported fields
}

type PARAM_VALUE_TYPE int32

type PIPELINE_STATUS int32

type PIPELINE_WATCH_MOD int32

type Pipeline struct {

	// 唯一ID
	// @gotags: bson:"_id" json:"id"
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" bson:"_id"`
	// 资源版本
	// @gotags: bson:"resource_version" json:"resource_version,omitempty"
	ResourceVersion int64 `` /* 131-byte string literal not displayed */
	// 所属域
	// @gotags: bson:"domain" json:"domain"
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain" bson:"domain"`
	// 所属空间
	// @gotags: bson:"namespace" json:"namespace"
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace" bson:"namespace"`
	// 创建时间
	// @gotags: bson:"create_at" json:"create_at"
	CreateAt int64 `protobuf:"varint,5,opt,name=create_at,json=createAt,proto3" json:"create_at" bson:"create_at"`
	// 创建人
	// @gotags: bson:"create_by" json:"create_by"
	CreateBy string `protobuf:"bytes,6,opt,name=create_by,json=createBy,proto3" json:"create_by" bson:"create_by"`
	// 模版id
	// @gotags: bson:"template_id" json:"template_id"
	TemplateId string `protobuf:"bytes,16,opt,name=template_id,json=templateId,proto3" json:"template_id" bson:"template_id"`
	// 名称
	// @gotags: bson:"name" json:"name"
	Name string `protobuf:"bytes,7,opt,name=name,proto3" json:"name" bson:"name"`
	// 全局参数, step执行时合并处理
	// @gotags: bson:"with" json:"with"
	With map[string]string `` /* 152-byte string literal not displayed */
	// 需要挂载的文件
	// @gotags: bson:"mount" json:"mount"
	Mount *MountData `protobuf:"bytes,14,opt,name=mount,proto3" json:"mount" bson:"mount"`
	// 标签
	// @gotags: bson:"tags" json:"tags"
	Tags map[string]string `` /* 151-byte string literal not displayed */
	// 描述
	// @gotags: bson:"description" json:"description"
	Description string `protobuf:"bytes,9,opt,name=description,proto3" json:"description" bson:"description"`
	// 触发条件
	// @gotags: bson:"on" json:"on"
	On *Trigger `protobuf:"bytes,10,opt,name=on,proto3" json:"on" bson:"on"`
	// 触发事件
	// @gotags: bson:"hook_event" json:"hook_event"
	HookEvent *scm.WebHookEvent `protobuf:"bytes,15,opt,name=hook_event,json=hookEvent,proto3" json:"hook_event" bson:"hook_event"`
	// 当前状态
	// @gotags: bson:"status" json:"status"
	Status *PipelineStatus `protobuf:"bytes,11,opt,name=status,proto3" json:"status" bson:"status"`
	// 具体编排阶段
	// @gotags: bson:"stages" json:"stages"
	Stages []*Stage `protobuf:"bytes,12,rep,name=stages,proto3" json:"stages" bson:"stages"`
	// contains filtered or unexported fields
}

type PipelineSet struct {

	// @gotags: bson:"total" json:"total"
	Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total" bson:"total"`
	// @gotags: bson:"items" json:"items"
	Items []*Pipeline `protobuf:"bytes,2,rep,name=items,proto3" json:"items" bson:"items"`
	// contains filtered or unexported fields
}

type PipelineStatus struct {

	// 当前正在执行step的flow number
	// @gotags: bson:"current_flow" json:"current_flow"
	CurrentFlow int64 `protobuf:"varint,1,opt,name=current_flow,json=currentFlow,proto3" json:"current_flow" bson:"current_flow"`
	// 开始时间
	// @gotags: bson:"start_at" json:"start_at"
	StartAt int64 `protobuf:"varint,2,opt,name=start_at,json=startAt,proto3" json:"start_at" bson:"start_at"`
	// 结束时间
	// @gotags: bson:"end_at" json:"end_at"
	EndAt int64 `protobuf:"varint,3,opt,name=end_at,json=endAt,proto3" json:"end_at" bson:"end_at"`
	// 当前状态
	// @gotags: bson:"status" json:"status"
	Status PIPELINE_STATUS `protobuf:"varint,4,opt,name=status,proto3,enum=infraboard.workflow.pipeline.PIPELINE_STATUS" json:"status" bson:"status"`
	// 由哪个调度器实例负责进行调度运行
	// @gotags: bson:"scheduler_node" json:"scheduler_node"
	SchedulerNode string `protobuf:"bytes,5,opt,name=scheduler_node,json=schedulerNode,proto3" json:"scheduler_node" bson:"scheduler_node"`
	// 执行结果
	// @gotags: bson:"message" json:"message"
	Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message" bson:"message"`
	// contains filtered or unexported fields
}

type QueryPipelineOptions struct {
	Node string
}

type QueryPipelineRequest struct {

	// @gotags: json:"page"
	Page *request.PageRequest `protobuf:"bytes,1,opt,name=page,proto3" json:"page"`
	// @gotags: json:"name"
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name"`
	// contains filtered or unexported fields
}

type QueryStepRequest struct {

	// @gotags: json:"page"
	Page *request.PageRequest `protobuf:"bytes,1,opt,name=page,proto3" json:"page"`
	// @gotags: json:"key"
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key"`
	// contains filtered or unexported fields
}

type STEP_CREATE_BY int32

type STEP_STATUS int32

type ServiceClient interface {
	// pipeline管理
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	QueryPipeline(ctx context.Context, in *QueryPipelineRequest, opts ...grpc.CallOption) (*PipelineSet, error)
	DescribePipeline(ctx context.Context, in *DescribePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	WatchPipeline(ctx context.Context, opts ...grpc.CallOption) (Service_WatchPipelineClient, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	// step管理
	CreateStep(ctx context.Context, in *CreateStepRequest, opts ...grpc.CallOption) (*Step, error)
	QueryStep(ctx context.Context, in *QueryStepRequest, opts ...grpc.CallOption) (*StepSet, error)
	DescribeStep(ctx context.Context, in *DescribeStepRequest, opts ...grpc.CallOption) (*Step, error)
	DeleteStep(ctx context.Context, in *DeleteStepRequest, opts ...grpc.CallOption) (*Step, error)
	CancelStep(ctx context.Context, in *CancelStepRequest, opts ...grpc.CallOption) (*Step, error)
	AuditStep(ctx context.Context, in *AuditStepRequest, opts ...grpc.CallOption) (*Step, error)
}

type ServiceServer interface {
	// pipeline管理
	CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error)
	QueryPipeline(context.Context, *QueryPipelineRequest) (*PipelineSet, error)
	DescribePipeline(context.Context, *DescribePipelineRequest) (*Pipeline, error)
	WatchPipeline(Service_WatchPipelineServer) error
	DeletePipeline(context.Context, *DeletePipelineRequest) (*Pipeline, error)
	// step管理
	CreateStep(context.Context, *CreateStepRequest) (*Step, error)
	QueryStep(context.Context, *QueryStepRequest) (*StepSet, error)
	DescribeStep(context.Context, *DescribeStepRequest) (*Step, error)
	DeleteStep(context.Context, *DeleteStepRequest) (*Step, error)
	CancelStep(context.Context, *CancelStepRequest) (*Step, error)
	AuditStep(context.Context, *AuditStepRequest) (*Step, error)
	// contains filtered or unexported methods
}

type Service_WatchPipelineClient interface {
	Send(*WatchPipelineRequest) error
	Recv() (*WatchPipelineResponse, error)
	grpc.ClientStream
}

type Service_WatchPipelineServer interface {
	Send(*WatchPipelineResponse) error
	Recv() (*WatchPipelineRequest, error)
	grpc.ServerStream
}

type Stage struct {

	// 阶段ID
	// @gotags: bson:"id" json:"id"
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id" bson:"id"`
	// 名称
	// @gotags: bson:"name" json:"name" validate:"required"
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" bson:"name" validate:"required"`
	// 依赖其他stage执行成功
	// @gotags: bson:"needs" json:"needs"
	Needs []string `protobuf:"bytes,3,rep,name=needs,proto3" json:"needs" bson:"needs"`
	// 具体步骤
	// @gotags: bson:"steps" json:"steps"
	Steps []*Step `protobuf:"bytes,4,rep,name=steps,proto3" json:"steps" bson:"steps"`
	// contains filtered or unexported fields
}

type Step struct {

	// Key 运行时标识符
	// @gotags: bson:"key" json:"key,omitempty"
	Key string `protobuf:"bytes,9,opt,name=key,proto3" json:"key,omitempty" bson:"key"`
	// step由那种控制器创建的, 也就是step类型
	// @gotags: bson:"create_type" json:"create_type"
	CreateType STEP_CREATE_BY `` /* 151-byte string literal not displayed */
	// 所属空间
	// @gotags: bson:"namespace" json:"namespace"
	Namespace string `protobuf:"bytes,17,opt,name=namespace,proto3" json:"namespace" bson:"namespace"`
	// 所属空间
	// @gotags: bson:"pipeline_id" json:"pipeline_id,omitempty"
	PipelineId string `protobuf:"bytes,18,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty" bson:"pipeline_id"`
	// 创建时间
	// @gotags: bson:"create_at" json:"create_at"
	CreateAt int64 `protobuf:"varint,19,opt,name=create_at,json=createAt,proto3" json:"create_at" bson:"create_at"`
	// 状态更新时间
	// @gotags: bson:"update_at" json:"update_at"
	UpdateAt int64 `protobuf:"varint,20,opt,name=update_at,json=updateAt,proto3" json:"update_at" bson:"update_at"`
	// 关联的应用部署id, 关联部署过后可以通过变量传递当前部署的配置
	// @gotags: bson:"deploy_id" json:"deploy_id"
	DeployId string `protobuf:"bytes,21,opt,name=deploy_id,json=deployId,proto3" json:"deploy_id" bson:"deploy_id"`
	// 资源版本
	// @gotags: bson:"resource_version" json:"resource_version,omitempty"
	ResourceVersion int64 `` /* 132-byte string literal not displayed */
	// 步骤ID
	// @gotags: bson:"id" json:"id"
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id" bson:"id"`
	// 名称
	// @gotags: bson:"name" json:"name" validate:"required"
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" bson:"name" validate:"required"`
	// 具体动作
	// @gotags: bson:"action" json:"action" validate:"required"
	Action string `protobuf:"bytes,3,opt,name=action,proto3" json:"action" bson:"action" validate:"required"`
	// 参数
	// @gotags: bson:"with" json:"with"
	With map[string]string `` /* 151-byte string literal not displayed */
	// 是否并行
	// @gotags: bson:"is_parallel" json:"is_parallel"
	IsParallel bool `protobuf:"varint,5,opt,name=is_parallel,json=isParallel,proto3" json:"is_parallel" bson:"is_parallel"`
	// 忽略失败
	// @gotags: bson:"ignore_failed" json:"ignore_failed"
	IgnoreFailed bool `protobuf:"varint,6,opt,name=ignore_failed,json=ignoreFailed,proto3" json:"ignore_failed" bson:"ignore_failed"`
	// 是否需要审批, 审批通过后才能执行
	// @gotags: bson:"with_audit" json:"with_audit"
	WithAudit bool `protobuf:"varint,10,opt,name=with_audit,json=withAudit,proto3" json:"with_audit" bson:"with_audit"`
	// 审批参数, 有审批模块做具体实现
	// @gotags: bson:"audit_params" json:"audit_params"
	AuditParams map[string]string `` /* 193-byte string literal not displayed */
	// step执行完成后, 是否需要通知
	// @gotags: bson:"with_notify" json:"with_notify"
	WithNotify bool `protobuf:"varint,11,opt,name=with_notify,json=withNotify,proto3" json:"with_notify" bson:"with_notify"`
	// 通知参数, 由通知模块做具体实现
	// @gotags: bson:"notify_params" json:"notify_params"
	NotifyParams map[string]string `` /* 197-byte string literal not displayed */
	// WebHook配置, 用于和其他系统联动, 比如各种机器人
	// @gotags: bson:"webhooks" json:"webhooks"
	Webhooks []*WebHook `protobuf:"bytes,15,rep,name=webhooks,proto3" json:"webhooks" bson:"webhooks"`
	// 调度标签
	// @gotags: bson:"node_selector" json:"node_selector"
	NodeSelector map[string]string `` /* 196-byte string literal not displayed */
	// 当前步骤的状态
	// @gotags: bson:"status" json:"status,omitempty"
	Status *StepStatus `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty" bson:"status"`
	// contains filtered or unexported fields
}

type StepSet struct {

	// @gotags: bson:"total" json:"total"
	Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total" bson:"total"`
	// @gotags: bson:"items" json:"items"
	Items []*Step `protobuf:"bytes,2,rep,name=items,proto3" json:"items" bson:"items"`
	// contains filtered or unexported fields
}

type StepStatus struct {

	// 当前该step的flow编号
	// @gotags: bson:"flow_number" json:"flow_number"
	FlowNumber int64 `protobuf:"varint,1,opt,name=flow_number,json=flowNumber,proto3" json:"flow_number" bson:"flow_number"`
	// 开始时间
	// @gotags: bson:"start_at" json:"start_at"
	StartAt int64 `protobuf:"varint,2,opt,name=start_at,json=startAt,proto3" json:"start_at" bson:"start_at"`
	// 结束时间
	// @gotags: bson:"end_at" json:"end_at"
	EndAt int64 `protobuf:"varint,3,opt,name=end_at,json=endAt,proto3" json:"end_at" bson:"end_at"`
	// 当前状态
	// @gotags: bson:"status" json:"status"
	Status STEP_STATUS `protobuf:"varint,4,opt,name=status,proto3,enum=infraboard.workflow.pipeline.STEP_STATUS" json:"status" bson:"status"`
	// 被调度到的节点
	// @gotags: bson:"scheduled_node" json:"scheduled_node"
	ScheduledNode string `protobuf:"bytes,5,opt,name=scheduled_node,json=scheduledNode,proto3" json:"scheduled_node" bson:"scheduled_node"`
	// 审批时间
	// @gotags: bson:"audit_at" json:"audit_at"
	AuditAt int64 `protobuf:"varint,9,opt,name=audit_at,json=auditAt,proto3" json:"audit_at" bson:"audit_at"`
	// 审批结果
	// @gotags: bson:"audit_response" json:"audit_response"
	AuditResponse AUDIT_RESPONSE `` /* 163-byte string literal not displayed */
	// 审批时的反馈信息
	// @gotags: bson:"audit_message" json:"audit_message"
	AuditMessage string `protobuf:"bytes,8,opt,name=audit_message,json=auditMessage,proto3" json:"audit_message" bson:"audit_message"`
	// 通知发送时间
	// @gotags: bson:"notify_at" json:"notify_at"
	NotifyAt int64 `protobuf:"varint,10,opt,name=notify_at,json=notifyAt,proto3" json:"notify_at" bson:"notify_at"`
	// 通知失败信息, 如果没有表示成功
	// @gotags: bson:"notify_error" json:"notify_error"
	NotifyError string `protobuf:"bytes,11,opt,name=notify_error,json=notifyError,proto3" json:"notify_error" bson:"notify_error"`
	// 执行结果
	// @gotags: bson:"message" json:"message"
	Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message" bson:"message"`
	// 执行完后的一些额外数据, 都以URL的方式返回
	// @gotags: bson:"response" json:"response"
	Response map[string]string `` /* 163-byte string literal not displayed */
	// 执行过程中的一些上下文信息
	// @gotags: bson:"context_map" json:"context_map,omitempty"
	ContextMap map[string]string `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Trigger struct {

	// 事件名称,那些事件可以触发
	// @gotags: bson:"events" json:"events"
	Events []string `protobuf:"bytes,1,rep,name=events,proto3" json:"events" bson:"events"`
	// 分支名称, 那些分支可以触发
	// @gotags: bson:"branches" json:"branches"
	Branches []string `protobuf:"bytes,2,rep,name=branches,proto3" json:"branches" bson:"branches"`
	// contains filtered or unexported fields
}

type UnimplementedServiceServer struct {
}

type UnsafeServiceServer interface {
	// contains filtered or unexported methods
}

type WatchPipelineRequest struct {

	// Types that are assignable to RequestUnion:
	//	*WatchPipelineRequest_CreateRequest
	//	*WatchPipelineRequest_CancelRequest
	RequestUnion isWatchPipelineRequest_RequestUnion `protobuf_oneof:"request_union"`
	// contains filtered or unexported fields
}

type WatchPipelineRequest_CancelRequest struct {
	CancelRequest *CancelWatchPipelineRequest `protobuf:"bytes,2,opt,name=cancel_request,json=cancelRequest,proto3,oneof"`
}

type WatchPipelineRequest_CreateRequest struct {
	CreateRequest *CreateWatchPipelineRequest `protobuf:"bytes,1,opt,name=create_request,json=createRequest,proto3,oneof"`
}

type WatchPipelineResponse struct {

	// @gotags: json:"watch_id"
	WatchId int64 `protobuf:"varint,1,opt,name=watch_id,json=watchId,proto3" json:"watch_id"`
	// @gotags: json:"pipeline"
	Pipeline *Pipeline `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline"`
	// contains filtered or unexported fields
}

type WebHook struct {

	// POST URL
	// @gotags: bson:"url" json:"url" validate:"required,url"
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url" bson:"url" validate:"required,url"`
	// 需要自定义添加的头, 用于身份认证
	// @gotags: bson:"header" json:"header"
	Header map[string]string `` /* 157-byte string literal not displayed */
	// 那些状态下触发
	// @gotags: bson:"events" json:"events"
	Events []STEP_STATUS `protobuf:"varint,3,rep,packed,name=events,proto3,enum=infraboard.workflow.pipeline.STEP_STATUS" json:"events" bson:"events"`
	// 简单的描述信息
	// @gotags: bson:"description" json:"description"
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description" bson:"description"`
	// 推送结果
	// @gotags: bson:"status" json:"status"
	Status *WebHookStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status" bson:"status"`
	// contains filtered or unexported fields
}

type WebHookStatus struct {

	// 开始时间
	// @gotags: bson:"start_at" json:"start_at"
	StartAt int64 `protobuf:"varint,1,opt,name=start_at,json=startAt,proto3" json:"start_at" bson:"start_at"`
	// 耗时多久，单位毫秒
	// @gotags: bson:"cost" json:"cost"
	Cost int64 `protobuf:"varint,2,opt,name=cost,proto3" json:"cost" bson:"cost"`
	// 是否推送成功
	// @gotags: bson:"success" json:"success"
	Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success" bson:"success"`
	// 异常时的错误信息
	// @gotags: bson:"message" json:"message"
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message" bson:"message"`
	// contains filtered or unexported fields
}