Documentation
¶
Index ¶
- Constants
- Variables
- func AuthorFromContext(ctx context.Context) *object.Signature
- func CleanRollout(ctx context.Context, cli GitStore) error
- func ClusterNamespaceFromCtx(ctx context.Context) (string, string)
- func DecodeArgoClusterName(full string) string
- func DecodeManifest(ctx context.Context, fs billy.Filesystem, manifest *Manifest, ...) error
- func DecodeResource(content []byte) (client.Object, error)
- func ForManifestFsFunc(fs billy.Filesystem, fun func(string, billy.Filesystem))
- func GenArgoClusterName(cluster string) string
- func GenArgoPrjNameFromRef(ref PathRef) string
- func GetCurrentCanaryStep(rollout *rolloutsv1alpha1.Rollout) (*rolloutsv1alpha1.CanaryStep, *int32)
- func InitOrUpdateKustomization(fs billy.Filesystem, labels, annotations map[string]string) error
- func IsPermmitedResource(obj runtime.Object) bool
- func ObjectPodTemplateFunc(obj client.Object, fun func(template *corev1.PodTemplateSpec))
- func ParseImagesFrom(obj client.Object) []string
- func ParseMainDeployment(ctx context.Context, store GitStore) (*appsv1.Deployment, error)
- func ParseMainStatefulSet(ctx context.Context, store GitStore) (*appsv1.StatefulSet, error)
- func ParseMainWorkload(ctx context.Context, store GitStore) (client.Object, error)
- func PromoteRollout(ctx context.Context, cli client.Client, namespace, name string, full bool) (*rolloutsv1alpha1.Rollout, error)
- func StringsContain(list []string, i string) bool
- func StringsIn(li []string, i string) bool
- func TaskNameOf(ref PathRef, taskname string) string
- func UpdateContentImages(ctx context.Context, store GitStore, images []string, version string) error
- func UpdatedReourcesLimits(obj client.Object, suggestion ResourceSuggestion) bool
- type AppReplicas
- type AppStoreDeployForm
- type ApplicationHandler
- func (h *ApplicationHandler) ArgoHistory(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) BatchUpdateImages(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) Create(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) CreateAppstoreApp(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) Delete(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) DeleteAppstoreApp(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) DeleteArgoResource(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) DeleteFile(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) DeleteHPA(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) DirectUpdateImage(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) EnableStrategyDeployment(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) Get(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GetAppstoreApp(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GetArgoResource(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GetHPA(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GetImages(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GetReplicas(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GetStrategyDeployment(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GitDiff(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GitLog(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GitPull(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) GitRevert(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) ImageHistory(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) List(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) ListAnalysisTemplate(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) ListAppstoreApp(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) ListFiles(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) ListImages(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) ListRelatedService(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) LocalAndRemoteCliFunc(req *restful.Request, resp *restful.Response, body interface{}, ...)
- func (h *ApplicationHandler) LocalCliFunc(req *restful.Request, resp *restful.Response, body interface{}, ...)
- func (h *ApplicationHandler) Regist(c *restful.Container)
- func (h *ApplicationHandler) Register(ws *restful.WebService)
- func (h *ApplicationHandler) RemoteCliFunc(req *restful.Request, resp *restful.Response, body interface{}, ...)
- func (h *ApplicationHandler) ResourceTree(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) SetHPA(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) SetReplicas(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) StrategyDeploymentControl(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) StrategyDeploymentStatus(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) SwitchStrategy(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) Sync(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) UpdateFile(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) UpdateFiles(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) UpdateImages(req *restful.Request, resp *restful.Response)
- func (h *ApplicationHandler) UpdateWorkloadResources(req *restful.Request, resp *restful.Response)
- type ApplicationProcessor
- func (p *ApplicationProcessor) BatchUpdateImages(ctx context.Context, ref PathRef, args []UpdateImageArgs) error
- func (h *ApplicationProcessor) Create(ctx context.Context, ref PathRef) error
- func (p *ApplicationProcessor) CreateIfNotExist(ctx context.Context, cli GitStore, obj client.Object) error
- func (p *ApplicationProcessor) DeleteHorizontalPodAutoscaler(ctx context.Context, ref PathRef) error
- func (h *ApplicationProcessor) Get(ctx context.Context, ref PathRef) (*DeploiedManifest, error)
- func (p *ApplicationProcessor) GetHorizontalPodAutoscaler(ctx context.Context, ref PathRef) (*v2beta1.HorizontalPodAutoscaler, error)
- func (p *ApplicationProcessor) GetReplicas(ctx context.Context, ref PathRef) (*int32, error)
- func (h *ApplicationProcessor) List(ctx context.Context, ref PathRef) ([]DeploiedManifest, error)
- func (p *ApplicationProcessor) PrepareDeploymentStrategy(ctx context.Context, ref PathRef, strategy DeploymentStrategy) error
- func (p *ApplicationProcessor) PrepareDeploymentStrategyWithImages(ctx context.Context, ref PathRef, strategy DeploymentStrategyWithImages) error
- func (p *ApplicationProcessor) ProvideFuntions() map[string]interface{}
- func (h *ApplicationProcessor) Remove(ctx context.Context, ref PathRef) error
- func (p *ApplicationProcessor) SetHorizontalPodAutoscaler(ctx context.Context, ref PathRef, scalerMetrics HPAMetrics) error
- func (p *ApplicationProcessor) SetReplicas(ctx context.Context, ref PathRef, replicas *int32) error
- func (h *ApplicationProcessor) Sync(ctx context.Context, ref PathRef, resources ...v1alpha1.SyncOperationResource) error
- func (h *ApplicationProcessor) Undo(ctx context.Context, ref PathRef, targetrev string) error
- func (p *ApplicationProcessor) UpdateImages(ctx context.Context, ref PathRef, images []string, version string) error
- func (p *ApplicationProcessor) WaitRollouts(ctx context.Context, ref PathRef) error
- type ApplicationTask
- type ArgoHistory
- type ArgoResourceDiff
- type ArgoResourceNode
- type ArgoResourceTree
- type BaseHandler
- func (h *BaseHandler) DirectRefNameFunc(req *restful.Request, ref *PathRef) error
- func (h *BaseHandler) GetRedis() *redis.Client
- func (h *BaseHandler) NamedRefFunc(req *restful.Request, resp *restful.Response, body interface{}, ...)
- func (h *BaseHandler) NoNameRefFunc(req *restful.Request, resp *restful.Response, body interface{}, ...)
- type BlueGreenDeploymentStrategy
- type CanaryDeploymentStrategy
- type ClusterNamespace
- type CommitImageDetails
- type Container
- type DatabseProcessor
- func (p *DatabseProcessor) GetEnvironmentWithCluster(ref PathRef) (*EnvironmentDetails, error)
- func (p *DatabseProcessor) RemoveDeploy(ctx context.Context, ref PathRef, deploy DeploiedManifest) error
- func (p *DatabseProcessor) SyncDeploies(ctx context.Context, ref PathRef, deploies []DeploiedManifest) error
- func (p *DatabseProcessor) SyncDeploy(ctx context.Context, ref PathRef, deploy DeploiedManifest) error
- type DeploiedHelm
- type DeploiedManifest
- type DeployImage
- type DeployImages
- type DeploymentStrategy
- type DeploymentStrategyType
- type DeploymentStrategyWithDeployment
- type DeploymentStrategyWithImages
- type EnvironmentDetails
- type ExtendCanaryStrategy
- type FileContent
- type FsStore
- func (c *FsStore) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
- func (c *FsStore) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
- func (c *FsStore) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
- func (c *FsStore) Get(ctx context.Context, key client.ObjectKey, into client.Object) error
- func (c *FsStore) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
- func (c *FsStore) ListAll(ctx context.Context) ([]client.Object, error)
- func (c *FsStore) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
- func (c *FsStore) RESTMapper() meta.RESTMapper
- func (c *FsStore) Scheme() *runtime.Scheme
- func (c *FsStore) Status() client.StatusWriter
- func (c *FsStore) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
- type GVKN
- type GitLog
- type GitStore
- type HPAMetrics
- type HandlerFunc
- type HarborFunc
- type HelmManifest
- type ImageDetails
- type ImageHandler
- func (h *ImageHandler) ImageTags(req *restful.Request, resp *restful.Response)
- func (h *ImageHandler) OnHarborFunc(req *restful.Request, resp *restful.Response, harborfun HarborFunc, ...)
- func (h *ImageHandler) Scan(req *restful.Request, resp *restful.Response)
- func (h *ImageHandler) Summary(req *restful.Request, resp *restful.Response)
- func (h *ImageHandler) Unpublishable(req *restful.Request, resp *restful.Response)
- func (h *ImageHandler) Vulnerabilities(req *restful.Request, resp *restful.Response)
- type ImageHistory
- type ImageSummaryItem
- type ImageTag
- type IngressPorts
- type IstioTrafficRouting
- type IstioVirtualService
- type LocalAndRemoteStoreFunc
- type LocalStoreFunc
- type Manifest
- type ManifestDeploy
- type ManifestHandler
- func (h *ManifestHandler) CreateManifest(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) CreateResource(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) DeleteFile(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) DeleteManifest(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) DeleteResource(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) GetFile(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) GetManifest(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) GetResource(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) GitDiff(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) GitLog(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) GitPull(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) GitRevert(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) ListFiles(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) ListManifest(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) ListMetas(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) ListResources(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) UpdateFile(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) UpdateFiles(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) UpdateManifest(req *restful.Request, resp *restful.Response)
- func (h *ManifestHandler) UpdateResource(req *restful.Request, resp *restful.Response)
- type ManifestListOption
- type ManifestListOptions
- type ManifestProcessor
- func (p *ManifestProcessor) ContentFunc(ctx context.Context, ref PathRef, fun RepositoryFileSystemFunc) error
- func (h *ManifestProcessor) Create(ctx context.Context, ref PathRef, manifest Manifest) error
- func (h *ManifestProcessor) Func(ctx context.Context, ref PathRef, funcs ...RepositoryFunc) error
- func (h *ManifestProcessor) Get(ctx context.Context, ref PathRef) (*Manifest, error)
- func (h *ManifestProcessor) List(ctx context.Context, ref PathRef, options ...ManifestListOption) ([]Manifest, error)
- func (h *ManifestProcessor) Remove(ctx context.Context, ref PathRef) error
- func (h *ManifestProcessor) StoreFunc(ctx context.Context, ref PathRef, ...) error
- func (h *ManifestProcessor) StoreUpdateFunc(ctx context.Context, ref PathRef, ...) error
- func (h *ManifestProcessor) Update(ctx context.Context, ref PathRef, manifest Manifest) error
- func (h *ManifestProcessor) UpdateContentFunc(ctx context.Context, ref PathRef, fun RepositoryFileSystemFunc, ...) error
- type ManifestRuntime
- type OCIFunc
- type PathRef
- func (p *PathRef) DecodeFrom(str string) error
- func (p PathRef) Encode() string
- func (p *PathRef) FromAnnotations(annotations map[string]string)
- func (p *PathRef) FromArgoLabel(labels map[string]string)
- func (p *PathRef) FromJsonBase64(str string)
- func (p PathRef) FullName() string
- func (p PathRef) GitBranch() string
- func (p PathRef) GitRef() git.RepositoryRef
- func (p PathRef) IsEmpty() bool
- func (p PathRef) JsonStringBase64() string
- func (p PathRef) Path() string
- type PodSpec
- type PodTemplateSpec
- type RecreatDeploymentStrategy
- type RefCompleteFunc
- type RegistryOptions
- type RelatedService
- type RemoteStoreFunc
- type Repository
- func (r *Repository) Diff(ctx context.Context, hash string) ([]git.FileDiff, error)
- func (r *Repository) FS(ctx context.Context) (billy.Filesystem, error)
- func (r *Repository) HistoryFiles(ctx context.Context, hash string) (*git.Commit, error)
- func (r *Repository) HistoryFunc(ctx context.Context, fun git.ContentVistitFunc) error
- type RepositoryFileSystemFunc
- type RepositoryFunc
- type ResourceSuggestion
- type ResourceSuggestionSpec
- type RolloutTrafficRouting
- type StrategyDeploymentControl
- type SyncRequest
- type TaskHandler
- type TaskProcessor
- func (p *TaskProcessor) GetTaskLatest(ctx context.Context, ref PathRef, typ string) (*workflow.Task, error)
- func (p *TaskProcessor) ListTasks(ctx context.Context, ref PathRef, typ string) ([]workflow.Task, error)
- func (p *TaskProcessor) SubmitTask(ctx context.Context, ref PathRef, typ string, steps []workflow.Step) error
- func (p *TaskProcessor) WatchTasks(ctx context.Context, ref PathRef, typ string, ...) error
- type UpdateImageArgs
Constants ¶
const ( // labels LabelTenant = gems.LabelTenant LabelProject = gems.LabelProject LabelApplication = gems.LabelApplication LabelEnvironment = gems.LabelEnvironment // application label LabelKeyFrom = application.LabelFrom // 区分是从 appstore 还是从应用 app 部署的argo LabelValueFromApp = application.LabelValueFromApp LabelValueFromAppStore = application.LabelValueFromAppStore // annotations AnnotationKeyCreator = application.AnnotationCreator // 创建人,仅用于当前部署实时更新,从kustomize部署的历史需要从gitcommit取得 AnnotationRef = application.AnnotationRef // 标志这个资源所属的项目环境,避免使用过多label造成干扰 AnnotationCluster = application.AnnotationCluster // 标志这个资源所属集群 AnnotationNamespace = application.AnnotationNamespace // 标志这个资源所属namespace )
const ( TaskFunction_Application_UpdateImages = "application_update_images" TaskFunction_Application_Sync = "application_sync" TaskFunction_Application_BatchUpdateImages = "application_batch_update_images" TaskFunction_Application_PrepareDeploymentStrategy = "application_preparedeploymentstrategy" TaskFunction_Application_WaitRollouts = "application_wait_rollouts" TaskFunction_Application_Undo = "application_undo" )
const ( AnnotationGeneratedByPlatformKey = application.AnnotationGeneratedByPlatformKey // 表示该资源是为了{for}自动生成的,需要在特定的时刻被清理 AnnotationGeneratedByPlatformValueRollouts = application.AnnotationGeneratedByPlatformValueRollouts // 表示该资源是为了rollouts而生成的 )
const ( AnalysisArgServiceName = "service-name" AnalysisArgNamespace = "namespace" )
const ( ReadmeFilename = "readme.md" MetaFilename = ".meta" )
const BaseEnv = "base"
const LabelIstioVersion = "version"
const StatusNoArgoApp = "NoArgoApp"
const (
TaskAddtionalKeyCommiter = "committer"
)
const TaskGroupApplication = "application"
Variables ¶
var ErrNotManagedRegistry = errors.New("unsupported image")
var ForFileContentFunc = git.ForFileContentFunc
var KustimizationFilename = konfig.DefaultKustomizationFileName()
var ResourceWhileList = []schema.GroupVersionKind{ {Group: corev1.GroupName}, {Group: appsv1.GroupName}, {Group: batchv1.GroupName}, {Group: extensionsv1beta1.GroupName}, {Group: networkingv1.GroupName}, {Group: storagev1.GroupName, Kind: "PersistentVolumeClaim"}, {Group: rollouts.Group}, }
ResourceWhileList 允许编排的资源类型
Functions ¶
func DecodeArgoClusterName ¶
func DecodeManifest ¶
func DecodeManifest(ctx context.Context, fs billy.Filesystem, manifest *Manifest, options ManifestListOptions) error
从应用编排根目录获取编排详情
func ForManifestFsFunc ¶
func ForManifestFsFunc(fs billy.Filesystem, fun func(string, billy.Filesystem))
func GenArgoClusterName ¶
func GenArgoPrjNameFromRef ¶
func GetCurrentCanaryStep ¶
func GetCurrentCanaryStep(rollout *rolloutsv1alpha1.Rollout) (*rolloutsv1alpha1.CanaryStep, *int32)
GetCurrentCanaryStep returns the current canary step. If there are no steps or the rollout has already executed the last step, the func returns nil
func IsPermmitedResource ¶
func ObjectPodTemplateFunc ¶
func ObjectPodTemplateFunc(obj client.Object, fun func(template *corev1.PodTemplateSpec))
func ParseImagesFrom ¶
func ParseMainDeployment ¶
func ParseMainStatefulSet ¶
func ParseMainWorkload ¶
func PromoteRollout ¶
func PromoteRollout(ctx context.Context, cli client.Client, namespace, name string, full bool) (*rolloutsv1alpha1.Rollout, error)
copy from: https://github.com/argoproj/argo-rollouts/blob/v1.1.0/pkg/kubectl-argo-rollouts/cmd/promote/promote.go#L92 默认下一步,full则跳过所有
func StringsContain ¶
func TaskNameOf ¶
func UpdateContentImages ¶
func UpdatedReourcesLimits ¶
func UpdatedReourcesLimits(obj client.Object, suggestion ResourceSuggestion) bool
Types ¶
type AppReplicas ¶
type AppReplicas struct {
Replicas *int32 `json:"replicas"`
}
type AppStoreDeployForm ¶
type AppStoreDeployForm struct { Name string `json:"name" binding:"required"` RepoURL string `json:"repoURL" binding:"required"` // 仓库index地址 Chart string `json:"chart" binding:"required"` // chart名称 ChartVersion string `json:"chartVersion" binding:"required"` // chart版本 Values json.RawMessage `json:"values" binding:"required"` }
type ApplicationHandler ¶
type ApplicationHandler struct { BaseHandler ApplicationProcessor *ApplicationProcessor Agents *agents.ClientSet Manifest ManifestHandler Task *TaskHandler // self cluster cli ArgoCD *argo.Client }
func MustNewApplicationDeployHandler ¶
func MustNewApplicationDeployHandler(commonbase base.BaseHandler, gitoptions *git.Options, argocli *argo.Client) *ApplicationHandler
func (*ApplicationHandler) ArgoHistory ¶
func (h *ApplicationHandler) ArgoHistory(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 部署历史 @Description 部署历史 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "name" @Success 200 {object} handlers.ResponseStruct{Data=handlers.PageData{Data=[]ArgoHistory}} "history" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/argohistory [get] @Security JWT
func (*ApplicationHandler) BatchUpdateImages ¶
func (h *ApplicationHandler) BatchUpdateImages(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 更新应用镜像并部署 @Description 更新部署镜像 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "应用名称,全部应用可设置为'_'" @Success 200 {object} handlers.ResponseStruct{Data=DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/_/images [put] @Security JWT
func (*ApplicationHandler) Create ¶
func (h *ApplicationHandler) Create(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 部署应用 @Description 应用部署 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Success 200 {object} handlers.ResponseStruct{Data=DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications [post] @Security JWT
func (*ApplicationHandler) CreateAppstoreApp ¶
func (h *ApplicationHandler) CreateAppstoreApp(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用商店部署 @Description 应用商店部署 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param body body AppStoreDeployForm true "chart 部署信息" @Success 200 {object} handlers.ResponseStruct{Data=[]DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/appstoreapplications [post] @Security JWT
func (*ApplicationHandler) Delete ¶
func (h *ApplicationHandler) Delete(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 删除应用 @Description 删除应用 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=string} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name} [delete] @Security JWT
func (*ApplicationHandler) DeleteAppstoreApp ¶
func (h *ApplicationHandler) DeleteAppstoreApp(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用商店应用列表 @Description 应用商店应用列表 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=[]DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/appstoreapplications [delete] @Security JWT
func (*ApplicationHandler) DeleteArgoResource ¶
func (h *ApplicationHandler) DeleteArgoResource(req *restful.Request, resp *restful.Response)
@Tags Application @Summary argo资源 @Description argo资源 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "appname" @params name query string "resourcename" @params group query string "group" @params version query string "version" @params namespace query string "namespace" @params kind query string "kind" @Success 200 {object} handlers.ResponseStruct{Data=string} "history" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/argoresource [delete] @Security JWT
func (*ApplicationHandler) DeleteFile ¶
func (h *ApplicationHandler) DeleteFile(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 删除文件 @Description 修改应用编排 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param filename path string true "file name" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/files/{filename} [delete] @Security JWT
func (*ApplicationHandler) DeleteHPA ¶
func (h *ApplicationHandler) DeleteHPA(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排HPA @Description 应用编排中HPA @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=HPAMetrics} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/hpa [delete] @Security JWT
func (*ApplicationHandler) DirectUpdateImage ¶
func (h *ApplicationHandler) DirectUpdateImage(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 更新应用镜像 @Description 更新应用镜像 @Accept json @Produce json @Param tenant path string true "租户名称" @Param project path string true "项目名称" @param environment path string true "环境名称" @Param application path string true "应用名称" @Param image query string true "需要更新的完整镜像(会根据镜像名称寻找编排中相似的镜像并更新tag)" @Param version query string false "istio version to set" @Success 200 {object} handlers.ResponseStruct{Data=object} "status" @Router /tenants/{tenant}/projects/{project}/environments/{environment}/applications/{application}/images [post] @Security JWT
func (*ApplicationHandler) EnableStrategyDeployment ¶
func (h *ApplicationHandler) EnableStrategyDeployment(req *restful.Request, resp *restful.Response)
@Tags StrategyDeployment @Summary 使用更新策略更新应用 @Description 使用更新策略更新应用 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "applicationname" @Param body body DeploymentStrategyWithImages true "reqbody" @Success 200 {object} handlers.ResponseStruct{Data=DeploymentStrategy} "-" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/strategydeploy [post] @Security JWT
开始灰度发布流程 灰度发布流程目前有如下几种: - 滚动更新,deployment rollingupdate 策略。 - 重新创建,deployment recreated 策略。 - 灰度发布,rollout canary 策略。 - 蓝绿发布,rollout bluegreen 策略。
func (*ApplicationHandler) Get ¶
func (h *ApplicationHandler) Get(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用部署 @Description 应用部署 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name} [get] @Security JWT
func (*ApplicationHandler) GetAppstoreApp ¶
func (h *ApplicationHandler) GetAppstoreApp(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用商店应用 @Description 应用商店应用 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/appstoreapplications/{name} [get] @Security JWT
func (*ApplicationHandler) GetArgoResource ¶
func (h *ApplicationHandler) GetArgoResource(req *restful.Request, resp *restful.Response)
@Tags Application @Summary argo资源 @Description argo资源 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "appname" @params name query string "resourcename" @params group query string "group" @params version query string "version" @params kind query string "kind" @Success 200 {object} handlers.ResponseStruct{Data=string} "history" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/argoresource [get] @Security JWT
func (*ApplicationHandler) GetHPA ¶
func (h *ApplicationHandler) GetHPA(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排中HPA @Description 应用编排中HPA @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=HPAMetrics} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/hpa [get] @Security JWT
func (*ApplicationHandler) GetImages ¶
func (h *ApplicationHandler) GetImages(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 更新应用镜像并部署 @Description 更新部署镜像 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "应用名称" @Param body body DeployImages true "更新参数" @Success 200 {object} handlers.ResponseStruct{Data=DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/images [get] @Security JWT
func (*ApplicationHandler) GetReplicas ¶
func (h *ApplicationHandler) GetReplicas(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排中副本数scale(包含运行时调整) @Description 应用编排中副本数scale @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param name query string true "workload name" @Param replicas query string true "scale replicas" @Success 200 {object} handlers.ResponseStruct{Data=AppReplicas} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/replicas [get] @Security JWT
func (*ApplicationHandler) GetStrategyDeployment ¶
func (h *ApplicationHandler) GetStrategyDeployment(req *restful.Request, resp *restful.Response)
@Tags StrategyDeployment @Summary 获取当前的应用更新策略 @Description 获取部署 @Accept json @Produce json @Param tenant_id path int true "tenautid" @Param project_id path int true "proid" @param environment_id path int true "envid" @Param name path string true "applicationname" @Success 200 {object} handlers.ResponseStruct{Data=DeploymentStrategyWithImages} "deploy" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/strategydeploy [get] @Security JWT 通过 argo app 将部署策略设置至,在sync是根据策略进行修改或者 rollout创建
func (*ApplicationHandler) GitDiff ¶
func (h *ApplicationHandler) GitDiff(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排文件diff @Description 应用编排文件diff @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param hash query string true "gitcommit hash" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/gitdiff [get] @Security JWT
func (*ApplicationHandler) GitLog ¶
func (h *ApplicationHandler) GitLog(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排文件历史 @Description 应用编排文件历史 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=[]FileContent} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/gitlog [get] @Security JWT
func (*ApplicationHandler) GitPull ¶
func (h *ApplicationHandler) GitPull(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排文件刷新 @Description 应用编排文件刷新(git pull) @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param hash query string true "gitcommit hash" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/gitpull [post] @Security JWT
func (*ApplicationHandler) GitRevert ¶
func (h *ApplicationHandler) GitRevert(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排文件回滚 @Description 应用编排文件回滚 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param hash query string true "gitcommit hash" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/gitrevert [post] @Security JWT
func (*ApplicationHandler) ImageHistory ¶
func (h *ApplicationHandler) ImageHistory(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 镜像历史 @Description 镜像历史(生成镜像跟踪功能数据) @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "name" @Success 200 {object} handlers.ResponseStruct{Data=string} "history" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/imagehistory [get] @Security JWT
func (*ApplicationHandler) List ¶
func (h *ApplicationHandler) List(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用列表 @Description 应用列表 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Success 200 {object} handlers.ResponseStruct{Data=[]DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications [get] @Security JWT
func (*ApplicationHandler) ListAnalysisTemplate ¶
func (h *ApplicationHandler) ListAnalysisTemplate(req *restful.Request, resp *restful.Response)
@Tags StrategyDeployment @Summary 获取支持的灰度分析 @Description 获取支持的灰度分析 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "applicationname" @param environment_id path int true "environment id" @Success 200 {object} handlers.ResponseStruct{Data=v1alpha1.AnalysisTemplate} "-" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/analysistemplate [get] @Security JWT
func (*ApplicationHandler) ListAppstoreApp ¶
func (h *ApplicationHandler) ListAppstoreApp(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用商店应用列表 @Description 应用商店应用列表 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Success 200 {object} handlers.ResponseStruct{Data=[]DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/appstoreapplications [get] @Security JWT
func (*ApplicationHandler) ListFiles ¶
func (h *ApplicationHandler) ListFiles(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 列举文件 @Description 应用编排内容 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=[]FileContent} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/application/{name}/files [get] @Security JWT
func (*ApplicationHandler) ListImages ¶
func (h *ApplicationHandler) ListImages(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用部署镜像 @Description 部署镜像 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "应用名称,全部应用可设置为'_'" @Success 200 {object} handlers.ResponseStruct{Data=DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/_/images [get] @Security JWT
func (*ApplicationHandler) ListRelatedService ¶
func (h *ApplicationHandler) ListRelatedService(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 获取对应的服务信息 @Description 获取对应的服务信息 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "applicationname" @Success 200 {object} handlers.ResponseStruct{Data=RelatedService} "-" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/services [get] @Security JWT
func (*ApplicationHandler) LocalAndRemoteCliFunc ¶
func (h *ApplicationHandler) LocalAndRemoteCliFunc(req *restful.Request, resp *restful.Response, body interface{}, fun LocalAndRemoteStoreFunc, msg string)
func (*ApplicationHandler) LocalCliFunc ¶
func (h *ApplicationHandler) LocalCliFunc(req *restful.Request, resp *restful.Response, body interface{}, fun LocalStoreFunc, msg string)
func (*ApplicationHandler) Regist ¶
func (h *ApplicationHandler) Regist(c *restful.Container)
func (*ApplicationHandler) Register ¶
func (h *ApplicationHandler) Register(ws *restful.WebService)
nolint: funlen,maintidex
func (*ApplicationHandler) RemoteCliFunc ¶
func (h *ApplicationHandler) RemoteCliFunc(req *restful.Request, resp *restful.Response, body interface{}, fun RemoteStoreFunc)
func (*ApplicationHandler) ResourceTree ¶
func (h *ApplicationHandler) ResourceTree(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 资源树实时状态(List/Watch) @Description 资源树实时状态 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "envid" @Param name path string true "应用名称,应用商店名称" @param watch query bool false "true"// 是否watch @Success 200 {object} handlers.ResponseStruct{Data=ArgoResourceTree} "summary" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/resourcetree [get] @Security JWT
func (*ApplicationHandler) SetHPA ¶
func (h *ApplicationHandler) SetHPA(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排中HPA @Description 应用编排中HPA @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param body body HPAMetrics true "hpa metrics" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/hpa [post] @Security JWT
func (*ApplicationHandler) SetReplicas ¶
func (h *ApplicationHandler) SetReplicas(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用编排中副本数scale(包含运行时调整) @Description 应用编排中副本数scale @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param name query string true "workload name" @Param body body AppReplicas true "scale replicas,body优先" @Param replicas query string true "scale replicas,如果body不存在值则使用该值" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/replicas [post] @Security JWT
func (*ApplicationHandler) StrategyDeploymentControl ¶
func (h *ApplicationHandler) StrategyDeploymentControl(req *restful.Request, resp *restful.Response)
@Tags StrategyDeployment @Summary 更新过程中的控制 @Description 更新控制 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "applicationname" @param body body StrategyDeploymentControl true "command" @Success 200 {object} handlers.ResponseStruct{Data=object} "-" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/application/{name}/strategydeploycontrol [post] @Security JWT
func (*ApplicationHandler) StrategyDeploymentStatus ¶
func (h *ApplicationHandler) StrategyDeploymentStatus(req *restful.Request, resp *restful.Response)
@Tags StrategyDeployment @Summary 更新过程中的实时状态 @Description 更新中的实时状态 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "applicationname" @param watch query bool false "watch 则返回 ssevent" @Success 200 {object} handlers.ResponseStruct{Data=rollout.RolloutInfo} "-" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/application/{name}/strategydeploystatus [get] @Security JWT
func (*ApplicationHandler) SwitchStrategy ¶
func (h *ApplicationHandler) SwitchStrategy(req *restful.Request, resp *restful.Response)
SwitchStrategy 用于在不同类型的发布策略中切换,切换时创建异步任务
func (*ApplicationHandler) Sync ¶
func (h *ApplicationHandler) Sync(req *restful.Request, resp *restful.Response)
@Tags Application @Summary Sync同步 @Description Sync同步 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @param environment_id path int true "environment id" @Param name path string true "name" @Param body body SyncRequest false "指定需要同步的资源,否则全部同步" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/sync [post] @Security JWT
func (*ApplicationHandler) UpdateFile ¶
func (h *ApplicationHandler) UpdateFile(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 写入文件 @Description 修改应用编排 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param filename path string true "file name" @Param body body string true "filecontent" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/files/{filename} [put] @Security JWT
func (*ApplicationHandler) UpdateFiles ¶
func (h *ApplicationHandler) UpdateFiles(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 写入多个文件 @Description 修改应用编排 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "name" @Param filename path string true "file name" @Param msg query string true "commit mesage" @Param body body []FileContent true "files" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/files [put] @Security JWT
func (*ApplicationHandler) UpdateImages ¶
func (h *ApplicationHandler) UpdateImages(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 更新应用镜像并部署 @Description 更新部署镜像 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "应用名称" @Param body body DeployImages true "更新参数" @Success 200 {object} handlers.ResponseStruct{Data=DeploiedManifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/images [put] @Security JWT
func (*ApplicationHandler) UpdateWorkloadResources ¶
func (h *ApplicationHandler) UpdateWorkloadResources(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 更新资源建议至 gitrepo @Description 更新资源建议至 gitrepo @Accept json @Produce json @Param cluster path string true "-" @Param group path string true "-" @Param version path string true "-" @param namespace path string true "-" @Param resource path string true "-" @Param name path string true "-" @Success 200 {object} handlers.ResponseStruct{Data=object} "-" @Router /v1/cluster/{cluster}/{group}/{version}/namespaces/{namespace}/{resource}/{name} [patch] @Security JWT
type ApplicationProcessor ¶
type ApplicationProcessor struct { Agents *agents.ClientSet Argo *argo.Client DataBase *DatabseProcessor Manifest *ManifestProcessor Task *TaskProcessor // contains filtered or unexported fields }
func NewApplicationProcessor ¶
func NewApplicationProcessor( gitp *git.SimpleLocalProvider, argo *argo.Client, redis *redis.Client, agents *agents.ClientSet, ) *ApplicationProcessor
func (*ApplicationProcessor) BatchUpdateImages ¶
func (p *ApplicationProcessor) BatchUpdateImages(ctx context.Context, ref PathRef, args []UpdateImageArgs) error
func (*ApplicationProcessor) Create ¶
func (h *ApplicationProcessor) Create(ctx context.Context, ref PathRef) error
func (*ApplicationProcessor) CreateIfNotExist ¶
func (*ApplicationProcessor) DeleteHorizontalPodAutoscaler ¶
func (p *ApplicationProcessor) DeleteHorizontalPodAutoscaler(ctx context.Context, ref PathRef) error
func (*ApplicationProcessor) Get ¶
func (h *ApplicationProcessor) Get(ctx context.Context, ref PathRef) (*DeploiedManifest, error)
func (*ApplicationProcessor) GetHorizontalPodAutoscaler ¶
func (p *ApplicationProcessor) GetHorizontalPodAutoscaler(ctx context.Context, ref PathRef) (*v2beta1.HorizontalPodAutoscaler, error)
func (*ApplicationProcessor) GetReplicas ¶
func (*ApplicationProcessor) List ¶
func (h *ApplicationProcessor) List(ctx context.Context, ref PathRef) ([]DeploiedManifest, error)
func (*ApplicationProcessor) PrepareDeploymentStrategy ¶
func (p *ApplicationProcessor) PrepareDeploymentStrategy(ctx context.Context, ref PathRef, strategy DeploymentStrategy) error
func (*ApplicationProcessor) PrepareDeploymentStrategyWithImages ¶
func (p *ApplicationProcessor) PrepareDeploymentStrategyWithImages( ctx context.Context, ref PathRef, strategy DeploymentStrategyWithImages) error
func (*ApplicationProcessor) ProvideFuntions ¶
func (p *ApplicationProcessor) ProvideFuntions() map[string]interface{}
ProvideFuntions 用于对异步任务框架指出所使用的方法
func (*ApplicationProcessor) Remove ¶
func (h *ApplicationProcessor) Remove(ctx context.Context, ref PathRef) error
func (*ApplicationProcessor) SetHorizontalPodAutoscaler ¶
func (p *ApplicationProcessor) SetHorizontalPodAutoscaler(ctx context.Context, ref PathRef, scalerMetrics HPAMetrics) error
func (*ApplicationProcessor) SetReplicas ¶
func (*ApplicationProcessor) Sync ¶
func (h *ApplicationProcessor) Sync(ctx context.Context, ref PathRef, resources ...v1alpha1.SyncOperationResource) error
func (*ApplicationProcessor) UpdateImages ¶
func (*ApplicationProcessor) WaitRollouts ¶
func (p *ApplicationProcessor) WaitRollouts(ctx context.Context, ref PathRef) error
type ApplicationTask ¶
type ApplicationTask struct { Name string `json:"name"` // 应用名称 Task workflow.Task `json:"task"` // 最新一次任务,如果不存在最新一次任务,则返回一个空任务 }
@Tags Application @Summary 应用列表的异步任务列表 @Description 应用列表的异步任务列表 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param names query string false "names,逗号','分隔,限制返回结果为这些name" @Success 200 {object} handlers.ResponseStruct{Data=[]ApplicationTask} "task status" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/_/tasks [get] @Security JWT
type ArgoHistory ¶
type ArgoHistory struct { ID string `json:"id,omitempty"` Name string `json:"name,omitempty"` Environment string `json:"environment,omitempty"` Tenant string `json:"tenant,omitempty"` Images []string `json:"images,omitempty"` // 发布的镜像 Status string `json:"status,omitempty"` // 如果发布,有发布的状态,从argocd取得 GitVersion string `json:"gitVersion,omitempty"` // 如果发布,有发布的 gitversion(commmit) commitid or branchname Publisher string `json:"publisher"` // 如果发布,有发布人 PublishAt metav1.Time `json:"publishAt"` // 如果发布,有发布时间 gitcommit 时间 }
type ArgoResourceDiff ¶
type ArgoResourceDiff struct { Group string `json:"group"` Kind string `json:"kind"` Namespace string `json:"namespace"` Name string `json:"name"` TargetState interface{} `json:"targetState"` LiveState interface{} `json:"liveState"` Diff interface{} `json:"diff"` // Diff contains the JSON patch between target and live resource Hook bool `json:"hook"` NormalizedLiveState interface{} `json:"normalizedLiveState"` PredictedLiveState interface{} `json:"predictedLiveState"` }
type ArgoResourceNode ¶
type ArgoResourceNode struct { v1alpha1.ResourceNode Sync string `json:"sync,omitempty"` }
type ArgoResourceTree ¶
type ArgoResourceTree struct { ArgoResourceNode Children []*ArgoResourceTree `json:"children,omitempty"` LiveState interface{} `json:"liveState,omitempty"` }
ResourceTree 跟节点是 argoapp
type BaseHandler ¶
type BaseHandler struct {
base.BaseHandler
}
func (*BaseHandler) DirectRefNameFunc ¶
func (h *BaseHandler) DirectRefNameFunc(req *restful.Request, ref *PathRef) error
func (*BaseHandler) GetRedis ¶
func (h *BaseHandler) GetRedis() *redis.Client
func (*BaseHandler) NamedRefFunc ¶
func (h *BaseHandler) NamedRefFunc(req *restful.Request, resp *restful.Response, body interface{}, fun HandlerFunc)
func (*BaseHandler) NoNameRefFunc ¶
func (h *BaseHandler) NoNameRefFunc(req *restful.Request, resp *restful.Response, body interface{}, fun HandlerFunc)
type BlueGreenDeploymentStrategy ¶
type BlueGreenDeploymentStrategy struct {
rolloutsv1alpha1.BlueGreenStrategy
}
type CanaryDeploymentStrategy ¶
type CanaryDeploymentStrategy struct {
ExtendCanaryStrategy
}
type ClusterNamespace ¶
type CommitImageDetails ¶
type Container ¶
type Container struct { Name string `json:"name,omitempty"` Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,8,opt,name=resources"` }
type DatabseProcessor ¶
func (*DatabseProcessor) GetEnvironmentWithCluster ¶
func (p *DatabseProcessor) GetEnvironmentWithCluster(ref PathRef) (*EnvironmentDetails, error)
func (*DatabseProcessor) RemoveDeploy ¶
func (p *DatabseProcessor) RemoveDeploy(ctx context.Context, ref PathRef, deploy DeploiedManifest) error
func (*DatabseProcessor) SyncDeploies ¶
func (p *DatabseProcessor) SyncDeploies(ctx context.Context, ref PathRef, deploies []DeploiedManifest) error
SyncDeploies full sync current deploies to database Use git store as database instead of orm database on application, but sometimes database as data source from other component, so we need to sync it
func (*DatabseProcessor) SyncDeploy ¶
func (p *DatabseProcessor) SyncDeploy(ctx context.Context, ref PathRef, deploy DeploiedManifest) error
type DeploiedHelm ¶
type DeploiedHelm struct { HelmManifest `json:",inline"` Runtime ManifestRuntime `json:"runtime"` }
type DeploiedManifest ¶
type DeploiedManifest struct { Manifest `json:",inline"` Runtime ManifestRuntime `json:"runtime"` }
func CompleteDeploiedManifestRuntime ¶
func CompleteDeploiedManifestRuntime(app *v1alpha1.Application, status *DeploiedManifest) *DeploiedManifest
type DeployImage ¶
type DeployImages ¶
type DeployImages struct { Name string `json:"name"` IstioVersion string `json:"istioVersion"` Kind string `json:"kind"` Images map[string]*DeployImage `json:"images"` // 当前准备发布的镜像(gitrepo 中) Published bool `json:"published"` // 是否已经发布至 argo PublishAt *metav1.Time `json:"publishAt"` // }
func ConvertDeploiedManifestToView ¶
func ConvertDeploiedManifestToView(dm DeploiedManifest) DeployImages
func (*DeployImages) PublishImages ¶
func (d *DeployImages) PublishImages() []string
type DeploymentStrategy ¶
type DeploymentStrategy struct { Type DeploymentStrategyType `json:"type,omitempty" validate:"required"` // 更新策略: in(Recreate,RollingUpdate,Canary,BlueGreen) Canary *CanaryDeploymentStrategy `json:"canary,omitempty"` BlueGreen *BlueGreenDeploymentStrategy `json:"blueGreen,omitempty"` Recreat *RecreatDeploymentStrategy `json:"recreat,omitempty"` Rolling *appsv1.RollingUpdateDeployment `json:"rolling,omitempty"` }
type DeploymentStrategyType ¶
type DeploymentStrategyType string
const ( RollingUpdateDeploymentStrategyType DeploymentStrategyType = DeploymentStrategyType(appsv1.RollingUpdateDeploymentStrategyType) RecreatDeploymentStrategyType DeploymentStrategyType = DeploymentStrategyType(appsv1.RecreateDeploymentStrategyType) CanaryDeploymentStrategyType DeploymentStrategyType = "Canary" BlueGreenDeploymentStrategyType DeploymentStrategyType = "BlueGreen" )
type DeploymentStrategyWithDeployment ¶
type DeploymentStrategyWithDeployment struct { Strategy DeploymentStrategy Deployment *appsv1.Deployment }
func ParseUpdateStrategyAndDeployment ¶
func ParseUpdateStrategyAndDeployment(ctx context.Context, store GitStore) (*DeploymentStrategyWithDeployment, error)
type DeploymentStrategyWithImages ¶
type DeploymentStrategyWithImages struct { DeployImages Strategy DeploymentStrategy `json:"strategy,omitempty"` }
type EnvironmentDetails ¶
type EnvironmentDetails struct { ClusterName string `json:"clusterName,omitempty"` ClusterKubeConfig []byte `json:"clusterKubeConfig,omitempty"` Namespace string `json:"namespace,omitempty"` EnvironmentName string `json:"environmentName,omitempty"` EnvironmentType string `json:"environmentType,omitempty"` }
type ExtendCanaryStrategy ¶
type ExtendCanaryStrategy struct { rolloutsv1alpha1.CanaryStrategy // TrafficRouting hosts all the supported service meshes supported to enable more fine-grained traffic routing TrafficRouting *RolloutTrafficRouting `json:"trafficRouting,omitempty" protobuf:"bytes,4,opt,name=trafficRouting"` }
ExtendCanaryStrategy 用于扩展原canary策略中 virtualservice 匹配的字段
func ExtendCanaryStrategyFromCanaryStrategy ¶
func ExtendCanaryStrategyFromCanaryStrategy(from *rolloutsv1alpha1.CanaryStrategy) *ExtendCanaryStrategy
func (*ExtendCanaryStrategy) ToCanaryStrategy ¶
func (s *ExtendCanaryStrategy) ToCanaryStrategy() *rolloutsv1alpha1.CanaryStrategy
type FileContent ¶
type FsStore ¶
type FsStore struct {
// contains filtered or unexported fields
}
func (*FsStore) DeleteAllOf ¶
func (*FsStore) List ¶
func (c *FsStore) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
func (*FsStore) RESTMapper ¶
func (c *FsStore) RESTMapper() meta.RESTMapper
RESTMapper returns the rest this client is using.
func (*FsStore) Status ¶
func (c *FsStore) Status() client.StatusWriter
type GVKN ¶
type GVKN struct { Group string `json:"group,omitempty" uri:"group"` Version string `json:"version,omitempty" uri:"version"` Kind string `json:"kind,omitempty" uri:"kind"` Name string `json:"name,omitempty" uri:"resourcename"` }
func (GVKN) GVK ¶
func (g GVKN) GVK() schema.GroupVersionKind
type HPAMetrics ¶
type HarborFunc ¶
type HelmManifest ¶
type HelmManifest struct { Name string `json:"name"` Description string `json:"description"` Kind string `json:"kind"` Creator string `json:"creator"` CreateAt metav1.Time `json:"createAt"` RepoURL string `json:"repoURL"` // 仓库index地址 Chart string `json:"chart"` // chart名称 ChartVersion string `json:"chartVersion"` // chart版本 Values string `json:"values"` }
type ImageDetails ¶
type ImageHandler ¶
type ImageHandler struct {
BaseHandler
}
func (*ImageHandler) ImageTags ¶
func (h *ImageHandler) ImageTags(req *restful.Request, resp *restful.Response)
@Tags ProjectImage @Summary 镜像tags @Description 查询镜像tags @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param application_id path int true "application id" @Param image query string true "eg. kubegems/nginx:v1.14" @Success 200 {object} handlers.ResponseStruct{Data=vuln.Report} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/images/tags [post] @Security JWT
func (*ImageHandler) OnHarborFunc ¶
func (h *ImageHandler) OnHarborFunc(req *restful.Request, resp *restful.Response, harborfun HarborFunc, ocifunc OCIFunc)
func (*ImageHandler) Scan ¶
func (h *ImageHandler) Scan(req *restful.Request, resp *restful.Response)
@Tags ProjectImage @Summary 镜像扫描 @Description 触发镜像扫描 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param image query string true "eg. kubegems/nginx:v1.14" @Success 200 {object} handlers.ResponseStruct{Data=vuln.Report} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/images/scan [post] @Security JWT
func (*ImageHandler) Summary ¶
func (h *ImageHandler) Summary(req *restful.Request, resp *restful.Response)
@Tags ProjectImage @Summary 镜像summary @Description 镜像summary @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param image query string true "eg. kubegems/nginx:v1.14" @Success 200 {object} handlers.ResponseStruct{Data=vuln.Report} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/images/summary [get] @Security JWT
func (*ImageHandler) Unpublishable ¶
func (h *ImageHandler) Unpublishable(req *restful.Request, resp *restful.Response)
@Tags ProjectImage @Summary 镜像不可发布标记 @Description 镜像不可发布标记 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param image query string true "eg. kubegems/nginx:v1.14" @Success 200 {object} handlers.ResponseStruct{Data=vuln.Report} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/images/unpublishable [get] @Security JWT
func (*ImageHandler) Vulnerabilities ¶
func (h *ImageHandler) Vulnerabilities(req *restful.Request, resp *restful.Response)
@Tags ProjectImage @Summary 镜像安全报告 @Description 镜像安全报告 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param image query string true "eg. kubegems/nginx:v1.14" @Success 200 {object} handlers.ResponseStruct{Data=vuln.Report} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/images/vulnerabilities [get] @Security JWT
type ImageHistory ¶
type ImageSummaryItem ¶
type ImageSummaryItem struct { Image string `json:"image,omitempty"` IsHarborRegistry bool `json:"isHarborRegistry,omitempty"` // 是否为受集群管理的镜像仓库且为 harbor 仓库 ScanStatus string `json:"scanStatus,omitempty"` // 扫描状态 Severity vuln.Severity `json:"severity,omitempty"` // 从低到高依次为 "None""Unknown" "Negligible" "Low""Medium""High""Critical" Report interface{} `json:"report,omitempty"` // harbor 报告原文: {"fixable": 122,"summary": {"Critical": 3,"High": 10,"Low": 61,"Medium": 125},"total": 199} Unpublishable bool `json:"unpublishable,omitempty"` // 不可发布状态,若为true则不可发布 Labels []harbor.Label `json:"labels,omitempty"` // harbor 标签 Status string `json:"status,omitempty"` UpdatedAt *metav1.Time `json:"updatedAt,omitempty"` // time.Time.Format(RFC3339) 格式,若非可管理仓库则为空 }
type IngressPorts ¶
type IstioTrafficRouting ¶
type IstioTrafficRouting struct { rolloutsv1alpha1.IstioTrafficRouting // VirtualService references an Istio VirtualService to modify to shape traffic VirtualService IstioVirtualService `json:"virtualService" protobuf:"bytes,1,opt,name=virtualService"` }
type IstioVirtualService ¶
type IstioVirtualService struct { rolloutsv1alpha1.IstioVirtualService Uri *istionetworkingv1alpha3.StringMatch `json:"uri,omitempty"` Headers map[string]*istionetworkingv1alpha3.StringMatch `json:"headers,omitempty"` IgnoreUriCase bool `json:"ignoreUriCase,omitempty"` }
根据header进行灰度
type LocalAndRemoteStoreFunc ¶
type LocalStoreFunc ¶
type Manifest ¶
type Manifest struct { Name string `json:"name"` Description string `json:"description"` Kind string `json:"kind"` Images []string `json:"images"` Creator string `json:"creator"` CreateAt metav1.Time `json:"createAt"` Labels map[string]string `json:"labels"` Annotations map[string]string `json:"annotations"` Ref PathRef `json:"ref"` IstioVersion string `json:"istioVersion"` }
type ManifestDeploy ¶
type ManifestDeploy struct { Cluster string Namespace string Name string Contents []unstructured.Unstructured }
type ManifestHandler ¶
type ManifestHandler struct { BaseHandler *ManifestProcessor }
func (*ManifestHandler) CreateManifest ¶
func (h *ManifestHandler) CreateManifest(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 创建应用编排 @Description 只创建一个空的应用没有内容文件 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param body body Manifest true "project meta" @Success 200 {object} handlers.ResponseStruct{Data=Manifest} "Application" @Router /v1/tenant/{tenaut_id}/project/{project_id}/manifests [post] @Security JWT
func (*ManifestHandler) CreateResource ¶
func (h *ManifestHandler) CreateResource(req *restful.Request, resp *restful.Response)
func (*ManifestHandler) DeleteFile ¶
func (h *ManifestHandler) DeleteFile(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 删除文件 @Description 修改应用编排 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "name" @Param filename path string true "file name" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/files/{filename} [delete] @Security JWT
func (*ManifestHandler) DeleteManifest ¶
func (h *ManifestHandler) DeleteManifest(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 删除创建应用编排 @Description 删除创建应用编排以及git内容 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "name" @Success 200 {object} handlers.ResponseStruct{Data=string} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name} [delete] @Security JWT
func (*ManifestHandler) DeleteResource ¶
func (h *ManifestHandler) DeleteResource(req *restful.Request, resp *restful.Response)
func (*ManifestHandler) GetFile ¶
func (h *ManifestHandler) GetFile(req *restful.Request, resp *restful.Response)
func (*ManifestHandler) GetManifest ¶
func (h *ManifestHandler) GetManifest(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 应用编排详情 @Description 应用编排详情 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "application name" @Success 200 {object} handlers.ResponseStruct{Data=Manifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name} [get] @Security JWT
func (*ManifestHandler) GetResource ¶
func (h *ManifestHandler) GetResource(req *restful.Request, resp *restful.Response)
func (*ManifestHandler) GitDiff ¶
func (h *ManifestHandler) GitDiff(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 应用编排文件diff @Description 应用编排文件diff @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "application name" @Param hash query string true "gitcommit hash" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/gitdiff [get] @Security JWT
func (*ManifestHandler) GitLog ¶
func (h *ManifestHandler) GitLog(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 应用编排文件历史 @Description 应用编排文件历史 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "name" @Success 200 {object} handlers.ResponseStruct{Data=[]GitLog} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/gitlog [get] @Security JWT
func (*ManifestHandler) GitPull ¶
func (h *ManifestHandler) GitPull(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 应用编排文件刷新 @Description 应用编排文件刷新(git pull) @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "application name" @Param hash query string true "gitcommit hash" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/gitpull [post] @Security JWT
func (*ManifestHandler) GitRevert ¶
func (h *ManifestHandler) GitRevert(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 应用编排文件回滚 @Description 回滚应用编排文件 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "application name" @Param hash query string true "gitcommit hash to rollback" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/gitrevert [get] @Security JWT
func (*ManifestHandler) ListFiles ¶
func (h *ManifestHandler) ListFiles(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 列举文件 @Description 应用编排内容 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "name" @Success 200 {object} handlers.ResponseStruct{Data=[]FileContent} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/files [get] @Security JWT
func (*ManifestHandler) ListManifest ¶
func (h *ManifestHandler) ListManifest(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 应用编排列表 @Description 应用编排列表 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Success 200 {object} handlers.ResponseStruct{Data=[]Manifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests [get] @Security JWT
func (*ManifestHandler) ListMetas ¶
func (h *ManifestHandler) ListMetas(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用内容类型摘要 @Description 对应用内所有资源进行列举,用于自动补全 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param application_id path int true "application id" @param environment_id path int true "environment id" @Param name path string true "name" @Param kind query string false "若设置,则仅显示设置的类型,例如 Deployment,StatefulSet,Job,ConfigMap" @Success 200 {object} handlers.ResponseStruct{Data=[]object} "类型信息" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/metas [get] @Security JWT
func (*ManifestHandler) ListResources ¶
func (h *ManifestHandler) ListResources(req *restful.Request, resp *restful.Response)
func (*ManifestHandler) UpdateFile ¶
func (h *ManifestHandler) UpdateFile(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 写入文件 @Description 修改应用编排 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "name" @Param filename path string true "file name" @Param body body FileContent true "filecontent" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/files/{filename} [put] @Security JWT
func (*ManifestHandler) UpdateFiles ¶
func (h *ManifestHandler) UpdateFiles(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 写入多个文件 @Description 修改应用编排 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "name" @Param filename path string true "file name" @Param msg query string true "commit mesage" @Param body body []FileContent true "files" @Success 200 {object} handlers.ResponseStruct{Data=string} "ok" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name}/files [put] @Security JWT
func (*ManifestHandler) UpdateManifest ¶
func (h *ManifestHandler) UpdateManifest(req *restful.Request, resp *restful.Response)
@Tags ApplicationManifest @Summary 修改应用编排描述 @Description 修改应用编排描述 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param name path string true "application name" @Param body body Manifest true "project meta" @Success 200 {object} handlers.ResponseStruct{Data=Manifest} "Application" @Router /v1/tenant/{tenant_id}/project/{project_id}/manifests/{name} [put] @Security JWT
func (*ManifestHandler) UpdateResource ¶
func (h *ManifestHandler) UpdateResource(req *restful.Request, resp *restful.Response)
type ManifestListOption ¶
type ManifestListOption func(*ManifestListOptions)
func WithImages ¶
func WithImages() ManifestListOption
type ManifestListOptions ¶
type ManifestListOptions struct {
WithImages bool // 解析资源中的镜像 和 istioVersion 更准确的kind等
}
type ManifestProcessor ¶
type ManifestProcessor struct {
GitProvider *git.SimpleLocalProvider
}
func NewManifestProcessor ¶
func NewManifestProcessor(GitProvider *git.SimpleLocalProvider) (*ManifestProcessor, error)
func (*ManifestProcessor) ContentFunc ¶
func (p *ManifestProcessor) ContentFunc(ctx context.Context, ref PathRef, fun RepositoryFileSystemFunc) error
func (*ManifestProcessor) Func ¶
func (h *ManifestProcessor) Func(ctx context.Context, ref PathRef, funcs ...RepositoryFunc) error
using ContentFunc StoreFunc instead of directly calling
func (*ManifestProcessor) List ¶
func (h *ManifestProcessor) List(ctx context.Context, ref PathRef, options ...ManifestListOption) ([]Manifest, error)
func (*ManifestProcessor) Remove ¶
func (h *ManifestProcessor) Remove(ctx context.Context, ref PathRef) error
func (*ManifestProcessor) StoreUpdateFunc ¶
func (*ManifestProcessor) UpdateContentFunc ¶
func (h *ManifestProcessor) UpdateContentFunc(ctx context.Context, ref PathRef, fun RepositoryFileSystemFunc, commitmsg string) error
type ManifestRuntime ¶
type ManifestRuntime struct { Status string `json:"status"` // 运行时状态 Kind string `json:"kind"` // 运行时负载类型 WorkloadName string `json:"workloadName"` // 运行时 Images []string `json:"images"` // 运行时镜像 Message string `json:"message"` // 运行时消息提示 CreateAt metav1.Time `json:"createAt"` // 运行时创建时间 Creator string `json:"creator"` // 运行时创建人 Raw interface{} `json:"raw"` // 运行时 DeployStatus string `json:"deployStatus"` // 异步部署的状态,取最新一个 IstioVersion string `json:"istioVersion"` // 运行时的 istio version }
type PathRef ¶
type PathRef struct { Tenant string `json:"tenant,omitempty"` Project string `json:"project,omitempty"` Env string `json:"environment,omitempty"` Name string `json:"name,omitempty"` }
PathRef 存储了从 租户项目环境应用 到 git仓库中的 group repo branch path的映射关系
func (*PathRef) DecodeFrom ¶
func (*PathRef) FromAnnotations ¶
func (*PathRef) FromArgoLabel ¶
func (*PathRef) FromJsonBase64 ¶
func (PathRef) GitRef ¶
func (p PathRef) GitRef() git.RepositoryRef
func (PathRef) JsonStringBase64 ¶
type PodTemplateSpec ¶
type PodTemplateSpec struct {
Spec PodSpec `json:"spec,omitempty"`
}
type RecreatDeploymentStrategy ¶
type RecreatDeploymentStrategy struct {
WaitShutdown bool `json:"waitShutdown,omitempty"` // 暂未使用
}
type RefCompleteFunc ¶
type RegistryOptions ¶
type RelatedService ¶
type RelatedService struct { ServiceIP string `json:"serviceIP"` Ports []corev1.ServicePort `json:"ports"` IngressPorts []IngressPorts `json:"ingresses"` }
type RemoteStoreFunc ¶
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
func (*Repository) HistoryFiles ¶
func (*Repository) HistoryFunc ¶
func (r *Repository) HistoryFunc(ctx context.Context, fun git.ContentVistitFunc) error
type RepositoryFileSystemFunc ¶
func FSStoreFunc ¶
func FSStoreFunc(funcs ...func(ctx context.Context, store GitStore) error) RepositoryFileSystemFunc
type RepositoryFunc ¶
type RepositoryFunc func(ctx context.Context, repository Repository) error
func Commit ¶
func Commit(msg string) RepositoryFunc
func FsFunc ¶
func FsFunc(funcs ...RepositoryFileSystemFunc) RepositoryFunc
func Pull ¶
func Pull() RepositoryFunc
func Revert ¶
func Revert(rev string) RepositoryFunc
func UpdateKustomizeCommit ¶
func UpdateKustomizeCommit(msg string) RepositoryFunc
type ResourceSuggestion ¶
type ResourceSuggestion struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ResourceSuggestionSpec `json:"spec,omitempty"` }
func (*ResourceSuggestion) DeepCopyObject ¶
func (r *ResourceSuggestion) DeepCopyObject() runtime.Object
type ResourceSuggestionSpec ¶
type ResourceSuggestionSpec struct {
Template PodTemplateSpec `json:"template"`
}
type RolloutTrafficRouting ¶
type RolloutTrafficRouting struct { rolloutsv1alpha1.RolloutTrafficRouting // Istio holds Istio specific configuration to route traffic Istio *IstioTrafficRouting `json:"istio,omitempty" protobuf:"bytes,1,opt,name=istio"` }
RolloutTrafficRouting hosts all the different configuration for supported service meshes to enable more fine-grained traffic routing
type SyncRequest ¶
type SyncRequest struct {
Resources []v1alpha1.SyncOperationResource `json:"resources,omitempty"`
}
type TaskHandler ¶
type TaskHandler struct { BaseHandler Processor *TaskProcessor }
func NewTaskHandler ¶
func NewTaskHandler(base BaseHandler) *TaskHandler
func (*TaskHandler) BatchList ¶
func (h *TaskHandler) BatchList(req *restful.Request, resp *restful.Response)
func (*TaskHandler) List ¶
func (h *TaskHandler) List(req *restful.Request, resp *restful.Response)
@Tags Application @Summary 应用异步任务 @Description 应用异步任务列表 @Accept json @Produce json @Param tenant_id path int true "tenaut id" @Param project_id path int true "project id" @Param environment_id path int true "environment_id" @Param name path string true "application name" @Param watch query string false "is watch sse ,sse key 为 'data'" @Param limit query int false "限制返回的条数,返回最新的n条记录" @Param type query string false "限制返回的任务类型,例如仅返回 部署镜像(update-image),切换模式(switch-strategy) 的任务" @Success 200 {object} handlers.ResponseStruct{Data=[]workflow.Task} "task status" @Router /v1/tenant/{tenant_id}/project/{project_id}/environment/{environment_id}/applications/{name}/tasks [get] @Security JWT
type TaskProcessor ¶
func (*TaskProcessor) GetTaskLatest ¶
func (*TaskProcessor) SubmitTask ¶
type UpdateImageArgs ¶
Source Files
¶
- base.go
- deploy.go
- deploy_addtional.go
- deploy_appstore.go
- deploy_argocd.go
- deploy_files.go
- deploy_images.go
- deploy_strategy.go
- deploy_strategy_ctrl.go
- deploy_strategy_struct.go
- deploy_updatesuggustion.go
- helper.go
- images.go
- manifest.go
- manifest_contentstore.go
- manifest_files.go
- manifest_store.go
- pathref.go
- processor_database.go
- processor_deploy.go
- processor_deploy_functions.go
- processor_deploy_strategy.go
- processor_manifest.go
- processor_repository.go
- processor_task.go
- regist.go
- tasks.go