migrate

Documentation

Index

• func CombineEnvResources() error
• func ConvertCmToResource(cms []*models.EnvConfigMap) []*models.EnvResource
• func ConvertIngToResource(ings []*models.EnvIngress) []*models.EnvResource
• func ConvertPVCToResource(pvcs []*models.EnvPvc) []*models.EnvResource
• func ConvertSecretToResource(secrets []*models.EnvSecret) []*models.EnvResource
• func ExtractRootKeyFromFlat(flatKey string) string
• func GenerateEnvVariableAffectServices(productInfo *models.Product, renderset *models.RenderSet) (map[string]sets.String, map[string]*types.ServiceVariableKV, error)
• func HandleK8sYamlVars() error
• func MaxRevision(revisionList []int64) int64
• func RemoveEnvResource() error
• func RevertServiceCounter(allServices []*models.Service) error
• func UpdateServiceCounter(allServices []*models.Service) error
• func V1110ToV1120() error
• func V1120ToV1110() error
• func V1120ToV1130() error
• func V1130ToV1120() error
• func V1140ToV1150() error
• func V1150ToV1140() error
• func V1150ToV1160() error
• func V1160ToV1150() error
• func V1160ToV1170() error
• func V1170ToV1160() error
• func V1170ToV1180() error
• func V1180ToV1170() error
• func V1180ToV200() error
• func V130ToV131() error
• func V131ToV130() error
• func V131ToV140() error
• func V140ToV131() error
• func V140ToV150() error
• func V150ToV140() error
• func V160ToV170() error
• func V170ToV160() error
• func V200ToV1180() error
• func V200ToV210() error
• func V210ToV200() error
• func V210ToV220() error
• func V220ToV210() error
• func V220ToV230() error
• func V230ToV220() error
• type ApprovalV1150
• type ApprovalV1160CompatibleV1150
• type CronjobV1150
• type DataBulkUpdater
  • func (dbu *DataBulkUpdater) AddModel(wModel mongo.WriteModel) error
  • func (dbu *DataBulkUpdater) Write() error
• type WorkflowStageV1150
• type WorkflowStageV1160CompatibleV1150
  • func UpdateStages(list []*WorkflowStageV1150) []*WorkflowStageV1160CompatibleV1150
• type WorkflowTaskV1150
• type WorkflowV4TemplateV1150
• type WorkflowV4V1150

Functions

func CombineEnvResources

func CombineEnvResources() error

func ConvertCmToResource

func ConvertCmToResource(cms []*models.EnvConfigMap) []*models.EnvResource

func ConvertIngToResource

func ConvertIngToResource(ings []*models.EnvIngress) []*models.EnvResource

func ConvertPVCToResource

func ConvertPVCToResource(pvcs []*models.EnvPvc) []*models.EnvResource

func ConvertSecretToResource

func ConvertSecretToResource(secrets []*models.EnvSecret) []*models.EnvResource

func ExtractRootKeyFromFlat

func ExtractRootKeyFromFlat(flatKey string) string

func GenerateEnvVariableAffectServices

func GenerateEnvVariableAffectServices(productInfo *models.Product, renderset *models.RenderSet) (map[string]sets.String, map[string]*types.ServiceVariableKV, error)

GetAffectedServices fetch affected services key => services

func HandleK8sYamlVars

func HandleK8sYamlVars() error

func MaxRevision

func MaxRevision(revisionList []int64) int64

func RemoveEnvResource

func RemoveEnvResource() error

func RevertServiceCounter

func RevertServiceCounter(allServices []*models.Service) error

func UpdateServiceCounter

func UpdateServiceCounter(allServices []*models.Service) error

func V1110ToV1120

func V1110ToV1120() error

func V1120ToV1110

func V1120ToV1110() error

func V1120ToV1130

func V1120ToV1130() error

func V1130ToV1120

func V1130ToV1120() error

func V1140ToV1150

func V1140ToV1150() error

func V1150ToV1140

func V1150ToV1140() error

func V1150ToV1160

func V1150ToV1160() error

func V1160ToV1150

func V1160ToV1150() error

func V1160ToV1170

func V1160ToV1170() error

func V1170ToV1160

func V1170ToV1160() error

func V1170ToV1180

func V1170ToV1180() error

func V1180ToV1170

func V1180ToV1170() error

func V1180ToV200

func V1180ToV200() error

func V130ToV131

func V130ToV131() error

V130ToV131 migrates data from v1.3.0 to v1.3.1 with the following tasks: 1. Add field `SharedServices` for all projects 2. Add field `ProductName` in field `Services` for all envs 3. Change the ServiceTemplateCounterName format

func V131ToV130

func V131ToV130() error

V131ToV130 rollbacks the changes from v1.3.1 to v1.3.0 with the following tasks: 1. Remove field `SharedServices` for all projects 2. Remove field `ProductName` in field `Services` for all envs 3. Revert the ServiceTemplateCounterName format

func V131ToV140

func V131ToV140() error

func V140ToV131

func V140ToV131() error

func V140ToV150

func V140ToV150() error

V140ToV150 fill image path data for old data in product.services.containers use preset rules as patterns: {"image": "repository", "tag": "tag"}, {"image": "image"}

func V150ToV140

func V150ToV140() error

func V160ToV170

func V160ToV170() error

V160ToV170 refreshes the secret of all webhooks

func V170ToV160

func V170ToV160() error

func V200ToV1180

func V200ToV1180() error

func V200ToV210

func V200ToV210() error

func V210ToV200

func V210ToV200() error

func V210ToV220

func V210ToV220() error

func V220ToV210

func V220ToV210() error

func V220ToV230

func V220ToV230() error

func V230ToV220

func V230ToV220() error

Types

type ApprovalV1150

type ApprovalV1150 struct {
	// Type is the new field in 1.16 approval struct, which used to check whether the data is before 1.16
	Type            config.ApprovalType    `bson:"type,omitempty"              yaml:"type"                       json:"type"`
	Enabled         bool                   `bson:"enabled"                     yaml:"enabled"                    json:"enabled"`
	ApproveUsers    []*models.User         `bson:"approve_users"               yaml:"approve_users"              json:"approve_users"`
	Timeout         int                    `bson:"timeout"                     yaml:"timeout"                    json:"timeout"`
	NeededApprovers int                    `bson:"needed_approvers"            yaml:"needed_approvers"           json:"needed_approvers"`
	Description     string                 `bson:"description"                 yaml:"description"                json:"description"`
	RejectOrApprove config.ApproveOrReject `bson:"reject_or_approve"           yaml:"-"                          json:"reject_or_approve"`
}

type ApprovalV1160CompatibleV1150

type ApprovalV1160CompatibleV1150 struct {
	*ApprovalV1150 `json:",inline" bson:",inline"`
	NativeApproval *models.NativeApproval `bson:"native_approval"             yaml:"native_approval,omitempty"     json:"native_approval,omitempty"`
	LarkApproval   *models.LarkApproval   `bson:"lark_approval"               yaml:"lark_approval,omitempty"       json:"lark_approval,omitempty"`
}

ApprovalV1160CompatibleV1150 is the V1160 approval struct with V1150 fields

type CronjobV1150

type CronjobV1150 struct {
	ID             primitive.ObjectID `bson:"_id,omitempty"                       json:"id"`
	WorkflowV4Args *WorkflowV4V1150   `bson:"workflow_v4_args"                    json:"workflow_v4_args"`
}

type DataBulkUpdater

type DataBulkUpdater struct {
	Coll           *mongo.Collection
	WriteModels    []mongo.WriteModel
	WriteThreshold int
}

func (*DataBulkUpdater) AddModel

func (dbu *DataBulkUpdater) AddModel(wModel mongo.WriteModel) error

func (*DataBulkUpdater) Write

func (dbu *DataBulkUpdater) Write() error

type WorkflowStageV1150

type WorkflowStageV1150 struct {
	Name          string         `bson:"name"          yaml:"name"         json:"name"`
	Parallel      bool           `bson:"parallel"      yaml:"parallel"     json:"parallel"`
	ApprovalV1150 *ApprovalV1150 `bson:"approval"      yaml:"approval"     json:"approval"`
	Jobs          []*models.Job  `bson:"jobs"          yaml:"jobs"         json:"jobs"`
}

type WorkflowStageV1160CompatibleV1150

type WorkflowStageV1160CompatibleV1150 struct {
	Name     string                        `bson:"name"          yaml:"name"         json:"name"`
	Parallel bool                          `bson:"parallel"      yaml:"parallel"     json:"parallel"`
	Approval *ApprovalV1160CompatibleV1150 `bson:"approval"      yaml:"approval"     json:"approval"`
	Jobs     []*models.Job                 `bson:"jobs"          yaml:"jobs"         json:"jobs"`
}

func UpdateStages

func UpdateStages(list []*WorkflowStageV1150) []*WorkflowStageV1160CompatibleV1150

type WorkflowTaskV1150

type WorkflowTaskV1150 struct {
	ID                 primitive.ObjectID `bson:"_id,omitempty"       yaml:"id"                  json:"id"`
	OriginWorkflowArgs *WorkflowV4V1150   `bson:"origin_workflow_args"      json:"origin_workflow_args"`
}

type WorkflowV4TemplateV1150

type WorkflowV4TemplateV1150 struct {
	ID     primitive.ObjectID    `bson:"_id,omitempty"       yaml:"id"                  json:"id"`
	Stages []*WorkflowStageV1150 `bson:"stages"              yaml:"stages"             json:"stages"`
}

type WorkflowV4V1150

type WorkflowV4V1150 struct {
	ID     primitive.ObjectID    `bson:"_id,omitempty"       yaml:"-"            json:"id"`
	Stages []*WorkflowStageV1150 `bson:"stages"              yaml:"stages"       json:"stages"`
}

WorkflowV4V1150 is part of the older version of WorkflowV4, which used to update data