deploy

README

应用部署(Task)

负责应用的部署

Documentation

Index

• Constants
• func RegisterRunner(t cluster.TYPE, r Runner)
• type DeployRecord
  • func NewDeployRecord(req DeployRequest) *DeployRecord
  • func (d *DeployRecord) AddDeployTask(tasks ...*task.Task) *DeployRecord
  • func (d *DeployRecord) String() string
  • func (d DeployRecord) TableName() string
• type DeployRequest
  • func NewDeployRequest() *DeployRequest
  • func (d *DeployRequest) String() string
• type DescribeDeployRecordRequest
  • func NewDescribeDeployRecordRequest(id string) *DescribeDeployRecordRequest
• type QueryDeployRecordRequest
  • func NewQueryDeployRecordRequest() *QueryDeployRecordRequest
• type Runner
  • func GetRunner(t cluster.TYPE) Runner
• type Service
  • func GetService() Service

Constants

const (
	ANNOTATION_CLUSTER_ID = "cluster_id"
	ANNOTATION_DEPLOY_ID  = "deploy_id"
)

const (
	APP_NAME = "deploy"
)

const (
	DEPLOY_LABEL_KEY = "deploy_id"
)

Functions

func RegisterRunner

func RegisterRunner(t cluster.TYPE, r Runner)

Types

type DeployRecord

type DeployRecord struct {
	// 部署记录Id
	Id string `json:"id" bson:"_id" gorm:"column:id;primaryKey"`
	// 部署记录创建时间
	CreateAt time.Time `json:"create_at" bson:"create_at" gorm:"column:create_at"`
	// 部署任务的参数
	DeployRequest
	// 部署任务的状态, 通过查询任务平台获取
	DeployTasks []*task.Task `json:"deploy_tasks" bson:"deploy_tasks" gorm:"-"`
}

func NewDeployRecord

func NewDeployRecord(req DeployRequest) *DeployRecord

func (*DeployRecord) AddDeployTask

func (d *DeployRecord) AddDeployTask(tasks ...*task.Task) *DeployRecord

func (*DeployRecord) String

func (d *DeployRecord) String() string

func (DeployRecord) TableName

func (d DeployRecord) TableName() string

type DeployRequest

type DeployRequest struct {
	// 服务部署集群Id, 维护有关联的服务，部署配置也在这里
	ClusterId string `json:"cluster_id"`
	// 该部署集群, 需要部署哪个制品(包)
	ArtifcatId string `json:"artifcat_id"`
}

func NewDeployRequest

func NewDeployRequest() *DeployRequest

func (*DeployRequest) String

func (d *DeployRequest) String() string

type DescribeDeployRecordRequest

type DescribeDeployRecordRequest struct {
	Id string `json:"id" bson:"_id"`
}

func NewDescribeDeployRecordRequest

func NewDescribeDeployRecordRequest(id string) *DescribeDeployRecordRequest

type QueryDeployRecordRequest

type QueryDeployRecordRequest struct {
	policy.ResourceScope
	*request.PageRequest
}

func NewQueryDeployRecordRequest

func NewQueryDeployRecordRequest() *QueryDeployRecordRequest

type Runner

type Runner interface {
	// 执行部署
	RunDeploy(ctx context.Context, req *DeployRequest) (*DeployRecord, error)
}

func GetRunner

func GetRunner(t cluster.TYPE) Runner

type Service

type Service interface {
	// 服务部署
	Deploy(context.Context, *DeployRequest) (*DeployRecord, error)
	// 查询部署记录
	QueryDeployRecord(context.Context, *QueryDeployRecordRequest) (*types.Set[*DeployRecord], error)
	// 查询部署详情
	DescribeDeployRecord(context.Context, *DescribeDeployRecordRequest) (*DeployRecord, error)
}

func GetService

func GetService() Service