model

Documentation

Index

• func StrategyIsValid(strategy []string, serviceDeployType string) bool
• type ApplyRuleTaskBody
• type DefaultTaskBody
• type Dependence
• type GroupStartTaskBody
• type GroupStopTaskBody
• type HorizontalScalingTaskBody
• type RestartTaskBody
• type RollBackTaskBody
• type RollingUpgradeTaskBody
• type StartTaskBody
• type StopTaskBody
• type Task
  • func NewTask(data []byte) (*Task, error)
  • func TransTask(task *pb.TaskMessage) (*Task, error)
• type TaskBody
  • func CreateTaskBody(taskType string) TaskBody
  • func NewTaskBody(taskType string, body []byte) TaskBody
• type TaskType
• type VerticalScalingTaskBody

Functions

func StrategyIsValid

func StrategyIsValid(strategy []string, serviceDeployType string) bool

StrategyIsValid 验证策略是否有效 策略包括以下值： prestart 先启动后关闭 prestop 先关闭后启动 rollingupdate 滚动形式 grayupdate 灰度形式 bluegreenupdate 蓝绿形式

Types

type ApplyRuleTaskBody

type ApplyRuleTaskBody struct {
	ServiceID     string `json:"service_id"`
	DeployVersion string `json:"deploy_version"`
	EventID       string `json:"event_id"`
	Action        string `json:"action"`
}

ApplyRuleTaskBody contains information for ApplyRuleTask

type DefaultTaskBody

type DefaultTaskBody map[string]interface{}

DefaultTaskBody 默认操作任务主体

type Dependence

type Dependence struct {
	CurrentServiceID string `json:"current_service_id"`
	DependServiceID  string `json:"depend_service_id"`
}

Dependence 依赖关系

type GroupStartTaskBody

type GroupStartTaskBody struct {
	Services    []StartTaskBody `json:"services"`
	Dependences []Dependence    `json:"dependences"`
	//组启动策略
	//顺序启动，无序并发启动
	Strategy []string `json:"strategy"`
}

GroupStartTaskBody 组应用启动操作任务主体

type GroupStopTaskBody

type GroupStopTaskBody struct {
	Services    []StartTaskBody `json:"services"`
	Dependences []Dependence    `json:"dependences"`
	//组关闭策略
	//顺序关系，无序并发关闭
	Strategy []string `json:"strategy"`
}

GroupStopTaskBody 组应用停止操作任务主体

type HorizontalScalingTaskBody

type HorizontalScalingTaskBody struct {
	TenantID  string `json:"tenant_id"`
	ServiceID string `json:"service_id"`
	Replicas  int32  `json:"replicas"`
	EventID   string `json:"event_id"`
}

HorizontalScalingTaskBody 水平伸缩操作任务主体

type RestartTaskBody

type RestartTaskBody struct {
	TenantID      string `json:"tenant_id"`
	ServiceID     string `json:"service_id"`
	DeployVersion string `json:"deploy_version"`
	EventID       string `json:"event_id"`
	//重启策略，此策略不保证生效
	//例如应用如果为有状态服务，此策略如配置为先启动后关闭，此策略不生效
	//无状态服务默认使用先启动后关闭，保证服务不受影响
	Strategy []string `json:"strategy"`
}

RestartTaskBody 重启操作任务主体

type RollBackTaskBody

type RollBackTaskBody struct {
	TenantID  string `json:"tenant_id"`
	ServiceID string `json:"service_id"`
	//当前版本
	CurrentDeployVersion string `json:"current_deploy_version"`
	//回滚目标版本
	OldDeployVersion string `json:"old_deploy_version"`
	EventID          string `json:"event_id"`
	//重启策略，此策略不保证生效
	//例如应用如果为有状态服务，此策略如配置为先启动后关闭，此策略不生效
	//无状态服务默认使用先启动后关闭，保证服务不受影响
	//如需使用滚动升级等策略，使用多策略方式
	Strategy []string `json:"strategy"`
}

RollBackTaskBody 回滚操作任务主体

type RollingUpgradeTaskBody

type RollingUpgradeTaskBody struct {
	TenantID         string   `json:"tenant_id"`
	ServiceID        string   `json:"service_id"`
	NewDeployVersion string   `json:"deploy_version"`
	EventID          string   `json:"event_id"`
	Strategy         []string `json:"strategy"`
}

RollingUpgradeTaskBody 升级操作任务主体

type StartTaskBody

type StartTaskBody struct {
	TenantID      string `json:"tenant_id"`
	ServiceID     string `json:"service_id"`
	DeployVersion string `json:"deploy_version"`
	EventID       string `json:"event_id"`
}

StartTaskBody 启动操作任务主体

type StopTaskBody

type StopTaskBody struct {
	TenantID      string `json:"tenant_id"`
	ServiceID     string `json:"service_id"`
	DeployVersion string `json:"deploy_version"`
	EventID       string `json:"event_id"`
}

StopTaskBody 停止操作任务主体

type Task

type Task struct {
	Type       TaskType  `json:"type"`
	Body       TaskBody  `json:"body"`
	CreateTime time.Time `json:"time,omitempty"`
	User       string    `json:"user"`
}

Task 任务

func NewTask

func NewTask(data []byte) (*Task, error)

NewTask 从json bytes data create task

func TransTask

func TransTask(task *pb.TaskMessage) (*Task, error)

TransTask transtask

type TaskBody

type TaskBody interface{}

TaskBody task body

func CreateTaskBody

func CreateTaskBody(taskType string) TaskBody

CreateTaskBody 通过类型串创建实体

func NewTaskBody

func NewTaskBody(taskType string, body []byte) TaskBody

type TaskType

type TaskType string

TaskType 任务类型

type VerticalScalingTaskBody

type VerticalScalingTaskBody struct {
	TenantID        string `json:"tenant_id"`
	ServiceID       string `json:"service_id"`
	ContainerCPU    int    `json:"container_cpu"`
	ContainerMemory int    `json:"container_memory"`
	EventID         string `json:"event_id"`
}

VerticalScalingTaskBody 垂直伸缩操作任务主体