service

package

Go to main page

Versions in this module

v2

v2.3.1

Apr 26, 2024

v2.3.0

Apr 19, 2024

Changes in this version

type FetchResourceArgs

+ Production bool

type ListCommonEnvCfgHistoryArgs

+ Production bool

type ListConfigMapArgs

+ Production bool

type RollBackConfigMapArgs

+ Production bool

type ScaleArgs

+ Production bool

type SyncEnvResourceArg

+ Production bool

type UpdateContainerImageArgs

+ Production bool

v2.2.0

Feb 23, 2024

Changes in this version

+ const K8sBetaVersionForEphemeralContainer

+ const Timeout

+ const ZadigDebugContainerName

+ var ClusterInformersMap sync.Map

+ var ClusterStopChanMap sync.Map

+ var DefaultCleanWhiteList = []string

+ var ErrUnsupportedService = errors.New(...)

+ func AutoDeployHelmServiceToEnvs(userName, requestID, projectName string, ...) error

+ func AutoDeployYamlServiceToEnvs(userName, requestID string, serviceTemplate *commonmodels.Service, ...) error

+ func BulkCopyHelmProduct(projectName, user, requestID string, arg CopyHelmProductArg, ...) error

+ func BulkCopyYamlProduct(projectName, user, requestID string, arg CopyYamlProductArg, ...) error

+ func CalculateK8sProductStatus(productInfo *commonmodels.Product, log *zap.SugaredLogger) (string, error)

+ func CalculateNonK8sProductStatus(productInfo *commonmodels.Product, log *zap.SugaredLogger) (string, error)

+ func CheckServicesDeployedInSubEnvs(ctx context.Context, productName, envName string, services []string) (map[string][]string, error)

+ func CheckWorkloadsK8sServices(ctx context.Context, envName, productName string) ([]string, error)

+ func CleanProductCronJob(requestID string, log *zap.SugaredLogger)

+ func CleanProducts()

+ func ConnectSshPmExec(c *gin.Context, username, envName, productName, ip, hostId string, ...) error

+ func CopyHelmProduct(productName, userName, requestID string, args []*CreateSingleProductArg, ...) error

+ func CopyYamlProduct(user, requestID, projectName string, args []*CreateSingleProductArg, ...) (err error)

+ func CreateCommonEnvCfg(args *models.CreateUpdateCommonEnvCfgArgs, userName string, ...) error

+ func CreateHelmProduct(productName, userName, requestID string, args []*CreateSingleProductArg, ...) error

+ func CreateHostProductionProduct(productName, userName, requestID string, args []*CreateSingleProductArg, ...) error

+ func CreateProduct(user, requestID string, args *ProductCreateArg, log *zap.SugaredLogger) (err error)

+ func CreateYamlProduct(productName, userName, requestID string, args []*CreateSingleProductArg, ...) error

+ func DeleteClusterInformer(clusterID string)

+ func DeleteCommonEnvCfg(envName, productName, objectName string, ...) error

+ func DeletePod(envName, productName, podName string, log *zap.SugaredLogger) error

+ func DeleteProduct(username, envName, productName, requestID string, isDelete bool, ...) (err error)

+ func DeleteProductHelmReleases(userName, requestID, envName, productName string, releases []string, ...) (err error)

+ func DeleteProductServices(userName, requestID, envName, productName string, serviceNames []string, ...) (err error)

+ func DeleteProductionProduct(username, envName, productName, requestID string, log *zap.SugaredLogger) (err error)

+ func DisableBaseEnv(ctx context.Context, envName, productName string) error

+ func DisableIstioGrayscale(ctx context.Context, envName, productName string) error

+ func DownloadFile(envName, productName, podName, container, path string, log *zap.SugaredLogger) ([]byte, string, error)

+ func EnableBaseEnv(ctx context.Context, envName, productName string) error

+ func EnableIstioGrayscale(ctx context.Context, envName, productName string) error

+ func EnsureDeleteShareEnvConfig(ctx context.Context, env *commonmodels.Product, ...) error

+ func EnsureDeleteZadigService(ctx context.Context, env *commonmodels.Product, svcName string, ...) error

+ func EnsureGrayEnvConfig(ctx context.Context, env *commonmodels.Product, kclient client.Client, ...) error

+ func EnsureProductionNamespace(createArgs []*CreateSingleProductArg) error

+ func EnsureUpdateZadigService(ctx context.Context, env *commonmodels.Product, svcName string, ...) error

+ func EnvAnalysisNotification(projectName, envName, result string, ...) error

+ func EnvSleep(productName, envName string, isEnable, isProduction bool, ...) error

+ func ExportProductionYaml(envName, productName, serviceName string, log *zap.SugaredLogger) ([]string, error)

+ func ExportYaml(envName, productName, serviceName, source string, log *zap.SugaredLogger) []string

+ func FetchServiceYaml(productName, envName, serviceName string, _ *zap.SugaredLogger) (string, error)

+ func GeneEstimatedValues(productName, envName, serviceOrReleaseName, scene, format string, ...) (interface{}, error)

+ func GetAffectedServices(productName, envName string, arg *K8sRendersetArg, log *zap.SugaredLogger) (map[string][]string, error)

+ func GetBundleResources(logger *zap.SugaredLogger) ([]*resourceSpec, error)

+ func GetEnvAnalysisHistory(projectName string, production bool, envName string, pageNum, pageSize int, ...) ([]*ai.EnvAIAnalysis, int64, error)

+ func GetEnvServiceList(ctx context.Context, productName, baseEnvName string) ([][]string, error)

+ func GetEstimatedRenderCharts(productName, envName string, getSvcRenderArgs []*commonservice.GetSvcRenderArg, ...) ([]*commonservice.HelmSvcRenderArg, error)

+ func GetGlobalVariableCandidate(productName, envName string, log *zap.SugaredLogger) ([]*commontypes.ServiceVariableKV, error)

+ func GetGlobalVariables(productName, envName string, log *zap.SugaredLogger) ([]*commontypes.GlobalVariableKV, int64, error)

+ func GetInitProduct(productTmplName string, envType types.EnvType, isBaseEnv bool, ...) (*commonmodels.Product, error)

+ func GetIstioGrayscaleConfig(ctx context.Context, envName, productName string) (commonmodels.IstioGrayscale, error)

+ func GetK8sResourceYaml(args *FetchResourceArgs, log *zap.SugaredLogger) (string, error)

+ func GetMergedYamlContent(arg *YamlContentRequestArg, paths []string) (string, error)

+ func GetPodDetailInfo(projectName, envName, podName string, log *zap.SugaredLogger) (*resource.Pod, error)

+ func GetProductAndFilterNs(namespace, workloadName, svcName string) (*models.Product, bool)

+ func GetProductDeployType(projectName string) (string, error)

+ func GetProductInfo(username, envName, productName string, log *zap.SugaredLogger) (*commonmodels.Product, error)

+ func GetService(envName, productName, serviceName string, production bool, workLoadType string, ...) (ret *commonservice.SvcResp, err error)

+ func GetServiceContainer(envName, productName, serviceName, container string, log *zap.SugaredLogger) error

+ func GetServiceWorkloads(svcTmpl *commonmodels.Service, env *commonmodels.Product, ...) ([]*commonservice.Workload, error)

+ func GetZadigReleaseServiceImpl(releaseType, serviceName string, _ string, env *commonmodels.Product, ...) (ret *commonservice.SvcResp, err error)

+ func InitializeEnvironment(projectKey string, envArgs []*commonmodels.Product, envType string, ...) error

+ func InstallService(helmClient *helmtool.HelmClient, param *kube.ReleaseInstallParam) error

+ func ListDeploymentNames(clusterID, namespace string, log *zap.SugaredLogger) ([]string, error)

+ func ListGroups(serviceName, envName, productName string, perPage, page int, production bool, ...) ([]*commonservice.ServiceResp, int, error)

+ func ListKubeEvents(env string, productName string, name string, rtype string, ...) ([]*resource.Event, error)

+ func ListNamespace(clusterID string, log *zap.SugaredLogger) ([]string, error)

+ func ListPodEvents(envName, productName, podName string, log *zap.SugaredLogger) ([]*resource.Event, error)

+ func ListProductionGroups(serviceName, envName, productName string, perPage, page int, ...) ([]*commonservice.ServiceResp, int, error)

+ func ListServicePods(productName, envName string, serviceName string, log *zap.SugaredLogger) ([]*resource.Pod, error)

+ func MigrateHistoryConfigMaps(envName, productName string, log *zap.SugaredLogger) ([]*models.EnvResource, error)

+ func NewClusterInformerFactory(clusterID string, cls *kubernetes.Clientset) (informers.SharedInformerFactory, error)

+ func OpenAPICreateCommonEnvCfg(projectName string, args *OpenAPIEnvCfgArgs, userName string, ...) error

+ func OpenAPICreateK8sEnv(args *OpenAPICreateEnvArgs, userName, requestID string, ...) error

+ func OpenAPICreateProductionEnv(args *OpenAPICreateEnvArgs, userName, requestID string, ...) error

+ func OpenAPIDeleteCommonEnvCfg(projectName, envName, cfgType, name string, logger *zap.SugaredLogger) error

+ func OpenAPIDeleteProductionEnvCommonEnvCfg(projectName, envName, cfgType, name string, logger *zap.SugaredLogger) error

+ func OpenAPIGetGlobalVariables(projectName, envName string, production bool, logger *zap.SugaredLogger) ([]*commontypes.GlobalVariableKV, error)

+ func OpenAPIRestartService(projectName, envName, serviceName string, logger *zap.SugaredLogger) error

+ func OpenAPIScale(req *OpenAPIScaleServiceReq, logger *zap.SugaredLogger) error

+ func OpenAPIUpdateCommonEnvCfg(projectName string, args *OpenAPIEnvCfgArgs, userName string, ...) error

+ func OpenAPIUpdateEnvBasicInfo(args *EnvBasicInfoArgs, userName, projectName, envName string, production bool, ...) error

+ func OpenAPIUpdateGlobalVariables(args *OpenAPIEnvGlobalVariables, ...) error

+ func OpenAPIUpdateYamlService(req *OpenAPIServiceVariablesReq, ...) error

+ func PatchDebugContainer(ctx context.Context, projectName, envName, podName, debugImage string) error

+ func PatchWorkload(ctx context.Context, projectName, envName, serviceName, devImage string) (*types.WorkloadInfo, error)

+ func ReInstallHelmProductionSvcInAllEnvs(productName string, templateSvc *commonmodels.Service) error

+ func ReInstallHelmSvcInAllEnvs(productName string, templateSvc *commonmodels.Service) error

+ func RecoverWorkload(ctx context.Context, projectName, envName, serviceName string) error

+ func ResetProductsStatus()

+ func RestartScale(args *RestartScaleArgs, _ *zap.SugaredLogger) error

+ func RestartService(envName string, args *SvcOptArgs, log *zap.SugaredLogger) (err error)

+ func RollBackConfigMap(envName string, args *RollBackConfigMapArgs, userName, userID string, ...) error

+ func RollbackEnvServiceVersion(ctx *internalhandler.Context, projectName, envName, serviceName string, ...) error

+ func Scale(args *ScaleArgs, logger *zap.SugaredLogger) error

+ func SetIstioGrayscaleConfig(ctx context.Context, envName, productName string, ...) error

+ func SetupIstioGrayscalePortalService(ctx context.Context, productName, envName, serviceName string, ...) error

+ func SetupPortalService(ctx context.Context, productName, envName, serviceName string, ...) error

+ func StartClusterInformer()

+ func SyncEnvResource(args *SyncEnvResourceArg, log *zap.SugaredLogger) error

+ func SyncHelmProductEnvironment(productName, envName, requestID string, log *zap.SugaredLogger) error

+ func SyncYamlFromSource(yamlData *templatemodels.CustomYaml, curValue string) (bool, string, error)

+ func UpdateCVMProduct(envName, productName, user, requestID string, log *zap.SugaredLogger) error

+ func UpdateCommonEnvCfg(args *models.CreateUpdateCommonEnvCfgArgs, userName string, ...) error

+ func UpdateConfigMap(args *models.CreateUpdateCommonEnvCfgArgs, userName string, ...) error

+ func UpdateContainerImage(requestID, username string, args *UpdateContainerImageArgs, ...) error

+ func UpdateEnvConfigs(projectName, envName string, arg *EnvConfigsArgs, production *bool, ...) error

+ func UpdateHelmProductCharts(productName, envName, userName, requestID string, args *EnvRendersetArg, ...) error

+ func UpdateHelmProductRenderset(productName, envName, userName, requestID string, args *EnvRendersetArg, ...) error

+ func UpdateOrCreateIngress(args *models.CreateUpdateCommonEnvCfgArgs, userName string, isCreate bool, ...) error

+ func UpdateProductAlias(envName, productName, alias string) error

+ func UpdateProductDefaultValues(productName, envName, userName, requestID string, args *EnvRendersetArg, ...) error

+ func UpdateProductDefaultValuesWithRender(product *commonmodels.Product, _ *models.RenderSet, userName, requestID string, ...) error

+ func UpdateProductGlobalVariables(productName, envName, userName, requestID string, currentRevision int64, ...) error

+ func UpdateProductGlobalVariablesWithRender(product *commonmodels.Product, productRenderset *models.RenderSet, ...) error

+ func UpdateProductRecycleDay(envName, productName string, recycleDay int) error

+ func UpdateProductRegistry(envName, productName, registryID string, log *zap.SugaredLogger) (err error)

+ func UpdateProductVariable(productName, envName, username, requestID string, ...) error

+ func UpdateProductionEnvConfigs(projectName, envName string, arg *EnvConfigsArgs, logger *zap.SugaredLogger) error

+ func UpdatePvc(args *models.CreateUpdateCommonEnvCfgArgs, userName string, ...) error

+ func UpdateSecret(args *models.CreateUpdateCommonEnvCfgArgs, userName string, ...) error

+ func UpdateService(args *SvcOptArgs, log *zap.SugaredLogger) error

+ func UpsertEnvAnalysisCron(projectName, envName string, production *bool, req *EnvAnalysisCronArg, ...) error

+ func UpsertEnvSleepCron(projectName, envName string, production *bool, req *EnvSleepCronArg, ...) error

+ func VersionLessThan121(ver *k8sversion.Info) bool

+ func VisitDeployment(deployment *appsv1.Deployment) (sets.String, sets.String, sets.String)

+ func VisitStatefulSet(sts *appsv1.StatefulSet) (sets.String, sets.String, sets.String)

+ type AutoCreateProductParam struct

+ EnvType string

+ ProductName string

+ RegistryID string

+ RequestId string

+ UserName string

+ type AutoCreator struct

+ Param *AutoCreateProductParam

+ func (autoCreator *AutoCreator) Create(envName string) (string, error)

+ type AvailableNamespace struct

+ Used bool

+ func ListAvailableNamespaces(clusterID, listType string, log *zap.SugaredLogger) ([]*AvailableNamespace, error)

+ type CfgRepoInfo struct

+ GitRepoConfig *GitRepoConfig

+ LoadPath string

+ type ChartImagesResp struct

+ ServiceImages []*ServiceImages

+ func GetImageInfos(productName, envName, serviceNames string, log *zap.SugaredLogger) (*ChartImagesResp, error)

+ type ChartInfo struct

+ Revision int64

+ ServiceName string

+ type ConfigTmplData struct

+ Key string

+ Value string

+ type ContainerNotFound struct

+ Container string

+ EnvName string

+ ProductName string

+ ServiceName string

+ func (c *ContainerNotFound) Error() string

+ type CopyHelmProductArg struct

+ Items []HelmProductItem

+ type CopyYamlProductArg struct

+ Items []YamlProductItem

+ type CreateEnvRequest struct

+ Auto bool

+ EnvType string

+ ProjectName string

+ Scene string

+ Type string

+ type CreateSingleProductArg struct

+ Alias string

+ BaseEnvName string

+ BaseName string

+ ChartValues []*ProductHelmServiceCreationInfo

+ ClusterID string

+ DefaultValues string

+ EnvConfigs []*commonmodels.CreateUpdateCommonEnvCfgArgs

+ EnvName string

+ GlobalVariables []*commontypes.GlobalVariableKV

+ HelmDefaultValues string

+ IsExisted bool

+ IstioGrayscale commonmodels.IstioGrayscale

+ Namespace string

+ ProductName string

+ Production bool

+ RegistryID string

+ Services [][]*ProductK8sServiceCreationInfo

+ ShareEnv commonmodels.ProductShareEnv

+ ValuesData *commonservice.ValuesDataArgs

+ type DefaultValuesResp struct

+ DefaultVariable string

+ YamlData *templatemodels.CustomYaml

+ func GetDefaultValues(productName, envName string, log *zap.SugaredLogger) (*DefaultValuesResp, error)

+ type DeployStatus string

+ const StatusDeployed

+ const StatusUnDeployed

+ type DiffEnvServiceVersionsResponse struct

+ Type string

+ VariableYamlA string

+ VariableYamlB string

+ YamlA string

+ YamlB string

+ func DiffEnvServiceVersions(ctx *internalhandler.Context, projectName, envName, serviceName string, ...) (DiffEnvServiceVersionsResponse, error)

+ type EnvAnalysisCronArg struct

+ Cron string

+ Enable bool

+ func GetEnvAnalysisCron(projectName, envName string, production *bool, logger *zap.SugaredLogger) (*EnvAnalysisCronArg, error)

+ type EnvAnalysisRespone struct

+ Result string

+ func EnvAnalysis(projectName, envName string, production *bool, triggerName string, ...) (*EnvAnalysisRespone, error)

+ type EnvBasicInfoArgs struct

+ Alias string

+ RegistryID string

+ type EnvCfgArgs struct

+ AutoSync bool

+ CommonEnvCfgType string

+ GitRepoConfig *template.GitRepoConfig

+ Name string

+ YamlData string

+ type EnvConfigsArgs struct

+ AnalysisConfig *models.AnalysisConfig

+ NotificationConfigs []*models.NotificationConfig

+ func GetEnvConfigs(projectName, envName string, production *bool, logger *zap.SugaredLogger) (*EnvConfigsArgs, error)

+ func GetProductionEnvConfigs(projectName, envName string, logger *zap.SugaredLogger) (*EnvConfigsArgs, error)

+ type EnvGroupRequest struct

+ Page int

+ PerPage int

+ ProjectName string

+ ServiceName string

+ type EnvRenderChartArg struct

+ ChartValues []*commonservice.HelmSvcRenderArg

+ type EnvRendersetArg struct

+ ChartValues []*commonservice.HelmSvcRenderArg

+ DefaultValues string

+ DeployType string

+ UpdateServiceTmpl bool

+ ValuesData *commonservice.ValuesDataArgs

+ type EnvResp struct

+ Alias string

+ BaseName string

+ BaseRefs []string

+ ClusterID string

+ ClusterName string

+ Error string

+ IsExisted bool

+ IsFavorite bool

+ IsPublic bool

+ IstioGrayscaleBaseEnv string

+ IstioGrayscaleEnable bool

+ IstioGrayscaleIsBase bool

+ Name string

+ Namespace string

+ Production bool

+ ProjectName string

+ RegistryID string

+ ShareEnvBaseEnv string

+ ShareEnvEnable bool

+ ShareEnvIsBase bool

+ SharedNS bool

+ Source string

+ Status string

+ UpdateBy string

+ UpdateTime int64

+ func ListProductionEnvs(userId string, projectName string, envNames []string, log *zap.SugaredLogger) ([]*EnvResp, error)

+ func ListProducts(userID, projectName string, envNames []string, production bool, ...) ([]*EnvResp, error)

+ type EnvSleepCronArg struct

+ AwakeCron string

+ AwakeCronEnable bool

+ SleepCron string

+ SleepCronEnable bool

+ func GetEnvSleepCron(projectName, envName string, production *bool, logger *zap.SugaredLogger) (*EnvSleepCronArg, error)

+ type EnvStatus struct

+ EnvName string

+ ErrMessage string

+ Status string

+ func AutoCreateProduct(productName, envType, requestID string, log *zap.SugaredLogger) []*EnvStatus

+ func OpenAPIApplyYamlService(projectKey string, req *OpenAPIApplyYamlServiceReq, production bool, ...) ([]*EnvStatus, error)

+ func UpdateMultiCVMProducts(envNames []string, productName, user, requestID string, log *zap.SugaredLogger) ([]*EnvStatus, error)

+ func UpdateMultipleHelmChartEnv(requestID, userName string, args *UpdateMultiHelmProductArg, production bool, ...) ([]*EnvStatus, error)

+ func UpdateMultipleHelmEnv(requestID, userName string, args *UpdateMultiHelmProductArg, production bool, ...) ([]*EnvStatus, error)

+ func UpdateMultipleK8sEnv(args []*UpdateEnv, envNames []string, productName, requestID string, ...) ([]*EnvStatus, error)

+ type EnvoyAddress struct

+ SocketAddress EnvoySocketAddress

+ type EnvoyClusterConfigLoadAssignment struct

+ ClusterName string

+ Endpoints []EnvoyLBEndpoints

+ type EnvoyEndpoint struct

+ Address EnvoyAddress

+ type EnvoyEndpoints struct

+ Endpoint EnvoyEndpoint

+ type EnvoyLBEndpoints struct

+ LBEndpoints []EnvoyEndpoints

+ type EnvoySocketAddress struct

+ Address string

+ PortValue int

+ Protocol string

+ type EstimateValuesArg struct

+ ChartName string

+ ChartRepo string

+ ChartVersion string

+ DefaultValues string

+ OverrideValues []*commonservice.KVPair

+ OverrideYaml string

+ Production bool

+ type ExternalProductCreator struct

+ func (creator *ExternalProductCreator) Create(user, requestID string, args *ProductCreateArg, log *zap.SugaredLogger) error

+ type FetchResourceArgs struct

+ EnvName string

+ Name string

+ Page int

+ PageSize int

+ ProjectName string

+ ResourceTypes string

+ Type string

+ type GetEnvServiceVersionYamlResponse struct

+ Type string

+ VariableYaml string

+ Yaml string

+ func GetEnvServiceVersionYaml(ctx *internalhandler.Context, projectName, envName, serviceName string, ...) (GetEnvServiceVersionYamlResponse, error)

+ type GetPortalServiceResponse struct

+ DefaultGatewayAddress string

+ Servers []SetupPortalServiceRequest

+ func GetIstioGrayscalePortalService(ctx context.Context, productName, envName, serviceName string) (GetPortalServiceResponse, error)

+ func GetPortalService(ctx context.Context, productName, envName, serviceName string) (GetPortalServiceResponse, error)

+ type GetReleaseInstanceDeployStatusResponse struct

+ ChartName string

+ ChartVersion string

+ ReleaseName string

+ Status string

+ Values string

+ func GetReleaseInstanceDeployStatus(productName string, request *HelmDeployStatusCheckRequest) ([]*GetReleaseInstanceDeployStatusResponse, error)

+ type GitRepoConfig struct

+ Branch string

+ CodehostKey string

+ Owner string

+ Repo string

+ ValuesPaths []string

+ type GlobalVariables struct

+ ProductionVariables []*commontypes.ServiceVariableKV

+ Variables []*commontypes.ServiceVariableKV

+ type HelmChartsResp struct

+ ChartInfos []*ChartInfo

+ FileInfos []*types.FileInfo

+ func GetChartInfos(productName, envName, serviceName string, log *zap.SugaredLogger) (*HelmChartsResp, error)

+ type HelmDeployStatusCheckRequest struct

+ ClusterID string

+ EnvName string

+ Namespace string

+ Services []string

+ type HelmProductCreator struct

+ func (creator *HelmProductCreator) Create(user, requestID string, args *ProductCreateArg, log *zap.SugaredLogger) error

+ type HelmProductItem struct

+ BaseName string

+ ChartValues []*commonservice.HelmSvcRenderArg

+ DefaultValues string

+ NewName string

+ OldName string

+ ValuesData *commonservice.ValuesDataArgs

+ type HelmReleaseQueryArgs struct

+ Filter string

+ ProjectName string

+ type HelmReleaseResp struct

+ AppVersion string

+ Chart string

+ ChartRepo string

+ DeployStrategy string

+ Error string

+ IsHelmChartDeploy bool

+ OverrideValues string

+ OverrideYaml string

+ ReleaseName string

+ Revision int

+ ServiceName string

+ Status ReleaseStatus

+ Updatable bool

+ func ListReleases(args *HelmReleaseQueryArgs, envName string, production bool, ...) ([]*HelmReleaseResp, error)

+ type IProductCreator interface

+ Create func(string, string, *ProductCreateArg, *zap.SugaredLogger) error

+ type ImageData struct

+ ImageName string

+ ImageTag string

+ Selected bool

+ type IstioGrayscaleChecks struct

+ NamespaceHasIstioLabel bool

+ PodsHaveIstioProxy bool

+ WorkloadsHaveK8sService bool

+ WorkloadsReady bool

+ type IstioGrayscaleReady struct

+ Checks IstioGrayscaleChecks

+ IsReady bool

+ func CheckIstioGrayscaleReady(ctx context.Context, envName, op, productName string) (*IstioGrayscaleReady, error)

+ func (s *IstioGrayscaleReady) CheckAndSetReady(state ShareEnvOp)

+ type K8sDeployStatusCheckRequest struct

+ ClusterID string

+ EnvName string

+ Namespace string

+ Services []*commonservice.K8sSvcRenderArg

+ type K8sRendersetArg struct

+ VariableYaml string

+ type K8sResource struct

+ ResourceGroup string

+ ResourceKind string

+ ResourceName string

+ ResourceVersion string

+ func ListAllK8sResourcesInNamespace(clusterID, namespace string, log *zap.SugaredLogger) ([]*K8sResource, error)

+ type K8sResourceResp struct

+ Count int

+ Resources []SortableByCreationTime

+ Workloads []interface{}

+ func ListConfigMapOverview(page, pageSize int, namespace string, kc client.Client) (*K8sResourceResp, error)

+ func ListCronJobs(page, pageSize int, clusterID, namespace string, kc client.Client, ...) (*K8sResourceResp, error)

+ func ListDaemonSets(page, pageSize int, namespace string, kc client.Client) (*K8sResourceResp, error)

+ func ListDeployments(page, pageSize int, namespace string, kc client.Client, ...) (*K8sResourceResp, error)

+ func ListIngressOverview(page, pageSize int, clusterID, namespace string, kc client.Client, ...) (*K8sResourceResp, error)

+ func ListJobs(page, pageSize int, namespace string, kc client.Client) (*K8sResourceResp, error)

+ func ListK8sResOverview(args *FetchResourceArgs, log *zap.SugaredLogger) (*K8sResourceResp, error)

+ func ListK8sSecretOverview(page, pageSize int, namespace string, kc client.Client) (*K8sResourceResp, error)

+ func ListPVCs(page, pageSize int, namespace string, kc client.Client) (*K8sResourceResp, error)

+ func ListServices(page, pageSize int, namespace string, kc client.Client, ...) (*K8sResourceResp, error)

+ func ListStatefulSets(page, pageSize int, namespace string, kc client.Client, ...) (*K8sResourceResp, error)

+ type K8sService struct

+ func (k *K8sService) GetGroupService(service *commonmodels.ProductService, ...) *commonservice.ServiceResp

+ type K8sYamlProductCreator struct

+ func (creator *K8sYamlProductCreator) Create(user, requestID string, args *ProductCreateArg, log *zap.SugaredLogger) error

+ type ListCommonEnvCfgHistoryArgs struct

+ AutoSync bool

+ CommonEnvCfgType config.CommonEnvCfgType

+ EnvName string

+ Name string

+ ProjectName string

+ type ListCommonEnvCfgHistoryRes struct

+ CreateTime int64

+ EnvName string

+ ID primitive.ObjectID

+ Name string

+ Namespace string

+ ProductName string

+ SourceDetail *models.CreateFromRepo

+ Type string

+ UpdateUserName string

+ YamlData string

+ func ListEnvResourceHistory(args *ListCommonEnvCfgHistoryArgs, log *zap.SugaredLogger) ([]*ListCommonEnvCfgHistoryRes, error)

+ func ListLatestEnvResources(args *ListCommonEnvCfgHistoryArgs, log *zap.SugaredLogger) ([]*ListCommonEnvCfgHistoryRes, error)

+ type ListConfigMapArgs struct

+ EnvName string

+ ProductName string

+ ServiceName string

+ type ListConfigMapRes struct

+ CmData map[string]string

+ CmName string

+ Immutable bool

+ func ListConfigMaps(args *ListConfigMapArgs, log *zap.SugaredLogger) ([]*ListConfigMapRes, error)

+ type ListEnvServiceVersionsResponse struct

+ CreateBy string

+ CreateTime int64

+ Revision int64

+ ServiceName string

+ func ListEnvServiceVersions(ctx *internalhandler.Context, projectName, envName, serviceName string, ...) ([]ListEnvServiceVersionsResponse, error)

+ type ListIngressesResponse struct

+ Address string

+ ErrorReason string

+ HostInfo string

+ IngressName string

+ Ports string

+ func ListIngresses(envName, productName string, log *zap.SugaredLogger) ([]*ListIngressesResponse, error)

+ type ListPodsInfoRespone struct

+ CreateTime int64

+ Images []string

+ Name string

+ Ready string

+ Status string

+ func ListPodsInfo(projectName, envName string, log *zap.SugaredLogger) ([]*ListPodsInfoRespone, error)

+ type ListPvcsResponse struct

+ AccessModes string

+ Capacity string

+ PvcName string

+ Status string

+ StorageClass string

+ Volume string

+ func ListPvcs(envName, productName string, log *zap.SugaredLogger) ([]*ListPvcsResponse, error)

+ type ListSecretsResponse struct

+ SecretName string

+ SecretType string

+ func ListSecrets(envName, productName string, log *zap.SugaredLogger) ([]*ListSecretsResponse, error)

+ type MatchedEnv struct

+ EnvName string

+ Namespace string

+ type MigrateHistoryConfigMapsRes struct

+ type NodeResp struct

+ Labels []string

+ Nodes []*internalresource.Node

+ func ListAvailableNodes(clusterID string, log *zap.SugaredLogger) (*NodeResp, error)

+ type OpenAPIApplyYamlServiceReq struct

+ EnvName string

+ ServiceList []*YamlServiceWithKV

+ func (req *OpenAPIApplyYamlServiceReq) Validate() error

+ type OpenAPICreateEnvArgs struct

+ Alias string

+ ChartValues []*ProductHelmServiceCreationInfo

+ ClusterID string

+ EnvConfigs []*EnvCfgArgs

+ EnvName string

+ GlobalVariables []*commontypes.GlobalVariableKV

+ Namespace string

+ Production bool

+ ProjectName string

+ RegistryID string

+ Services []*OpenAPICreateServiceArgs

+ func (env *OpenAPICreateEnvArgs) Validate() error

+ type OpenAPICreateServiceArgs struct

+ Containers []*commonmodels.Container

+ DeployStrategy string

+ ServiceName string

+ Status string

+ Type string

+ VariableKVs []*commontypes.RenderVariableKV

+ type OpenAPIDeleteYamlServiceFromEnvReq struct

+ EnvName string

+ ServiceNames []string

+ func (req *OpenAPIDeleteYamlServiceFromEnvReq) Validate() error

+ type OpenAPIEnvCfgArgs struct

+ AutoSync bool

+ CommonEnvCfgType config.CommonEnvCfgType

+ CreatedBy string

+ CreatedTime int64

+ EnvName string

+ Name string

+ ProductName string

+ RestartAssociatedSvc bool

+ ServiceName string

+ Services []string

+ SourceDetail *commonmodels.CreateFromRepo

+ UpdateBy string

+ UpdateTime int64

+ YamlData string

+ func (req *OpenAPIEnvCfgArgs) Validate() error

+ type OpenAPIEnvCfgBrief struct

+ CommonEnvCfgType config.CommonEnvCfgType

+ EnvName string

+ Name string

+ ProjectName string

+ UpdateBy string

+ UpdateTime int64

+ func OpenAPIListCommonEnvCfg(projectName, envName string, cfgType string, logger *zap.SugaredLogger) ([]*OpenAPIEnvCfgBrief, error)

+ type OpenAPIEnvCfgConfigMapDetail struct

+ CmData map[string]string

+ CommonEnvCfgType config.CommonEnvCfgType

+ CreatedBy string

+ CreatedTime int64

+ EnvName string

+ Immutable bool

+ Name string

+ ProjectName string

+ Services []string

+ SourceDetail *CfgRepoInfo

+ UpdateBy string

+ UpdateTime int64

+ YamlData string

+ type OpenAPIEnvCfgDetail struct

+ ConfigMapDetail *OpenAPIEnvCfgConfigMapDetail

+ IngressDetail *OpenAPIEnvCfgIngressDetail

+ PvcDetail *OpenAPIEnvCfgPvcDetail

+ SecretDetail *OpenAPIEnvCfgSecretDetail

+ func OpenAPIGetCommonEnvCfg(projectName, envName, cfgType, name string, logger *zap.SugaredLogger) (*OpenAPIEnvCfgDetail, error)

+ type OpenAPIEnvCfgIngressDetail struct

+ Address string

+ CommonEnvCfgType config.CommonEnvCfgType

+ CreatedBy string

+ CreatedTime int64

+ EnvName string

+ ErrorReason string

+ HostInfo string

+ Name string

+ Ports string

+ ProjectName string

+ Services []string

+ SourceDetail *CfgRepoInfo

+ UpdateBy string

+ UpdateTime int64

+ YamlData string

+ type OpenAPIEnvCfgPvcDetail struct

+ AccessModes string

+ Capacity string

+ CommonEnvCfgType config.CommonEnvCfgType

+ CreatedBy string

+ CreatedTime int64

+ EnvName string

+ Name string

+ ProjectName string

+ Services []string

+ SourceDetail *CfgRepoInfo

+ Status string

+ StorageClass string

+ UpdateBy string

+ UpdateTime int64

+ Volume string

+ YamlData string

+ type OpenAPIEnvCfgSecretDetail struct

+ CommonEnvCfgType config.CommonEnvCfgType

+ CreatedBy string

+ CreatedTime int64

+ EnvName string

+ Name string

+ ProjectName string

+ SecretType string

+ Services []string

+ SourceDetail *CfgRepoInfo

+ UpdateBy string

+ UpdateTime int64

+ YamlData string

+ type OpenAPIEnvDetail struct

+ Alias string

+ ChartValues []*ProductHelmServiceCreationInfo

+ ClusterID string

+ EnvName string

+ GlobalVariables []*commontypes.GlobalVariableKV

+ Namespace string

+ ProjectName string

+ RegistryID string

+ Services []*OpenAPIServiceDetail

+ Status string

+ UpdateBy string

+ UpdateTime int64

+ func GetEnvDetail(projectName, envName string, logger *zap.SugaredLogger) (*OpenAPIEnvDetail, error)

+ type OpenAPIEnvGlobalVariables struct

+ GlobalVariables []*commontypes.GlobalVariableKV

+ type OpenAPIEnvServiceDetail struct

+ DeployStrategy string

+ Error string

+ Images []string

+ ServiceName string

+ Status string

+ Type string

+ Variables []*commontypes.ServiceVariableKV

+ type OpenAPIListEnvBrief struct

+ Alias string

+ ClusterID string

+ EnvName string

+ Namespace string

+ Production bool

+ RegistryID string

+ Status string

+ UpdateBy string

+ UpdateTime int64

+ func OpenAPIListEnvs(userID, projectName string, envNames []string, production bool, ...) ([]*OpenAPIListEnvBrief, error)

+ func OpenAPIListProductionEnvs(userId string, projectName string, envNames []string, log *zap.SugaredLogger) ([]*OpenAPIListEnvBrief, error)

+ type OpenAPIScaleServiceReq struct

+ EnvName string

+ ProjectKey string

+ TargetReplicas int

+ WorkloadName string

+ WorkloadType string

+ func (req *OpenAPIScaleServiceReq) Validate() error

+ type OpenAPIServiceDetail struct

+ Containers []*commonmodels.Container

+ ServiceName string

+ Status string

+ Type string

+ VariableKVs []*commontypes.ServiceVariableKV

+ type OpenAPIServiceVariablesReq struct

+ ServiceList []*ServiceVariable

+ type PMProductCreator struct

+ func (creator *PMProductCreator) Create(user, requestID string, args *ProductCreateArg, log *zap.SugaredLogger) error

+ type PMService struct

+ type PreviewServiceArgs struct

+ EnvName string

+ ProductName string

+ ServiceModules []*commonmodels.Container

+ ServiceName string

+ UpdateServiceRevision bool

+ VariableKVs []*commontypes.RenderVariableKV

+ type ProductCreateArg struct

+ type ProductHelmServiceCreationInfo struct

+ DeployStrategy string

+ type ProductIngressInfo struct

+ EnvName string

+ IngressInfos []*commonservice.IngressInfo

+ type ProductK8sServiceCreationInfo struct

+ DeployStrategy string

+ type ProductParams struct

+ EnvName string

+ IsPublic bool

+ PermissionUUIDs []string

+ RoleID int

+ type ProductResp struct

+ ClusterID string

+ ClusterName string

+ EnvName string

+ Error string

+ ID string

+ IsExisted bool

+ IsLocal bool

+ IsProd bool

+ IsPublic bool

+ IstioGrayscaleBaseEnv string

+ IstioGrayscaleEnable bool

+ IstioGrayscaleIsBase bool

+ Namespace string

+ ProductName string

+ RecycleDay int

+ RegisterID string

+ RelatedEnvs []*SharedNSEnvs

+ Render *commonmodels.RenderInfo

+ Services [][]*commonmodels.ProductService

+ ShareEnvBaseEnv string

+ ShareEnvEnable bool

+ ShareEnvIsBase bool

+ Source string

+ Status string

+ UpdateBy string

+ UpdateTime int64

+ Vars []*templatemodels.RenderKV

+ YamlData *templatemodels.CustomYaml

+ func GetProduct(username, envName, productName string, log *zap.SugaredLogger) (*ProductResp, error)

+ type ProductRevision struct

+ CurrentRevision int64

+ EnvName string

+ ID string

+ IsPublic bool

+ NextRevision int64

+ ProductName string

+ ServiceRevisions []*SvcRevision

+ Updatable bool

+ func GetProductRevision(product *commonmodels.Product, allServiceTmpls []*commonmodels.Service, ...) (*ProductRevision, error)

+ func ListProductSnapsByOption(deployType string, log *zap.SugaredLogger) ([]*ProductRevision, error)

+ func ListProductsRevision(productName, envName string, production bool, log *zap.SugaredLogger) (prodRevs []*ProductRevision, err error)

+ func (pr *ProductRevision) GroupsUpdated() bool

+ type RawYamlResp struct

+ YamlContent string

+ type ReleaseFilter struct

+ Name string

+ Status ReleaseStatus

+ type ReleaseStatus string

+ const HelmReleaseStatusDeployed

+ const HelmReleaseStatusFailed

+ const HelmReleaseStatusNotDeployed

+ const HelmReleaseStatusPending

+ type ResourceCommon struct

+ CreationTime string

+ Images []*WorkloadImage

+ Name string

+ Type string

+ func (rc *ResourceCommon) GetCreationTime() string

+ type ResourceConfigMap struct

+ type ResourceDeployStatus struct

+ GVK schema.GroupVersionKind

+ Name string

+ OverrideKvs []*commonservice.KVPair

+ OverrideYaml string

+ Status DeployStatus

+ Type string

+ type ResourceIngress struct

+ Address string

+ Class string

+ Hosts string

+ Ports string

+ type ResourcePVC struct

+ AccessModes string

+ Capacity string

+ Status string

+ StorageClass string

+ Volume string

+ type ResourceResponseBase struct

+ AutoSync bool

+ CreateTime time.Time

+ EnvName string

+ Name string

+ ProjectName string

+ Services []string

+ SourceDetail *models.CreateFromRepo

+ Type config.CommonEnvCfgType

+ UpdateUserName string

+ YamlData string

+ type ResourceSecret struct

+ SecretType string

+ type ResourceService struct

+ ClusterIP string

+ Ports string

+ ServiceType string

+ type ResourceWithLabel interface

+ GetLabels func() map[string]string

+ SetLabels func(labels map[string]string)

+ SetNamespace func(ns string)

+ func GetResourceByCfgType(namespace, name string, cfgType config.CommonEnvCfgType, client client.Client, ...) (ResourceWithLabel, error)

+ type RestartScaleArgs struct

+ EnvName string

+ Name string

+ ProductName string

+ ServiceName string

+ Type string

+ type RollBackConfigMapArgs struct

+ DestinConfigName string

+ EnvName string

+ ProductName string

+ ServiceName string

+ SrcConfigName string

+ type ScaleArgs struct

+ EnvName string

+ Name string

+ Number int

+ ProductName string

+ ServiceName string

+ Type string

+ type ServiceDeployStatus struct

+ Resources []*ResourceDeployStatus

+ ServiceName string

+ func GetReleaseDeployStatus(productName string, request *HelmDeployStatusCheckRequest) ([]*ServiceDeployStatus, error)

+ func GetResourceDeployStatus(productName string, request *K8sDeployStatusCheckRequest, ...) ([]*ServiceDeployStatus, error)

+ type ServiceImages struct

+ Images []*ImageData

+ ServiceName string

+ type ServiceMatchedDeploymentContainers struct

+ Deployment struct{ ... }

+ ServiceName string

+ func ListCanaryDeploymentServiceInfo(clusterID, namespace string, log *zap.SugaredLogger) ([]*ServiceMatchedDeploymentContainers, error)

+ type ServiceVariable struct

+ ServiceName string

+ Variables []*commontypes.RenderVariableKV

+ type SetIstioGrayscaleConfigRequest struct

+ GrayscaleStrategy commonmodels.GrayscaleStrategyType

+ HeaderMatchConfigs []commonmodels.IstioHeaderMatchConfig

+ WeightConfigs []commonmodels.IstioWeightConfig

+ type SetupPortalServiceRequest struct

+ Host string

+ PortNumber uint32

+ PortProtocol string

+ type ShareEnvOp string

+ const ShareEnvDisable

+ const ShareEnvEnable

+ type ShareEnvReady struct

+ Checks ShareEnvReadyChecks

+ IsReady bool

+ func CheckShareEnvReady(ctx context.Context, envName, op, productName string) (*ShareEnvReady, error)

+ func (s *ShareEnvReady) CheckAndSetReady(state ShareEnvOp)

+ type ShareEnvReadyChecks struct

+ NamespaceHasIstioLabel bool

+ PodsHaveIstioProxy bool

+ VirtualServicesDeployed bool

+ WorkloadsHaveK8sService bool

+ WorkloadsReady bool

+ type SharedNSEnvs struct

+ EnvName string

+ Production bool

+ ProjectName string

+ func FindNsUseEnvs(productInfo *commonmodels.Product, log *zap.SugaredLogger) ([]*SharedNSEnvs, error)

+ type SortableByCreationTime interface

+ GetCreationTime func() string

+ type SvcDataSet struct

+ ProdSvc *models.ProductService

+ SvcRelease *release.Release

+ TmplSvc *models.Service

+ type SvcDiffResult struct

+ ChartName string

+ Current TmplYaml

+ DeployedFromChart bool

+ Error string

+ Latest TmplYaml

+ ReleaseName string

+ ServiceName string

+ func BatchPreviewService(args []*PreviewServiceArgs, logger *zap.SugaredLogger) ([]*SvcDiffResult, error)

+ func GetServiceDiff(envName, productName, serviceName string, log *zap.SugaredLogger) (*SvcDiffResult, error)

+ func PreviewHelmProductGlobalVariables(productName, envName, globalVariable string, log *zap.SugaredLogger) ([]*SvcDiffResult, error)

+ func PreviewProductGlobalVariables(productName, envName string, arg []*commontypes.GlobalVariableKV, ...) ([]*SvcDiffResult, error)

+ func PreviewProductGlobalVariablesWithRender(product *commonmodels.Product, args []*commontypes.GlobalVariableKV, ...) ([]*SvcDiffResult, error)

+ func PreviewService(args *PreviewServiceArgs, _ *zap.SugaredLogger) (*SvcDiffResult, error)

+ type SvcOptArgs struct

+ EnvName string

+ ProductName string

+ ServiceName string

+ ServiceRev *SvcRevision

+ ServiceType string

+ UpdateBy string

+ UpdateServiceTmpl bool

+ type SvcRevision struct

+ Containers []*commonmodels.Container

+ CurrentRevision int64

+ Deleted bool

+ DeployStrategy string

+ Error string

+ New bool

+ NextRevision int64

+ ServiceName string

+ Type string

+ Updatable bool

+ UpdateServiceTmpl bool

+ VariableKVs []*commontypes.RenderVariableKV

+ VariableYaml string

+ type SyncEnvResourceArg struct

+ EnvName string

+ Name string

+ ProductName string

+ Type string

+ type TmplConfig struct

+ Data []ConfigTmplData

+ type TmplYaml struct

+ Revision int64

+ UpdateBy string

+ Yaml string

+ type UpdateConfigMapArgs struct

+ ConfigName string

+ EnvName string

+ ProductName string

+ RestartAssociatedSvc bool

+ ServiceName string

+ Services []string

+ YamlData string

+ type UpdateContainerImageArgs struct

+ ContainerName string

+ EnvName string

+ Image string

+ Name string

+ ProductName string

+ ServiceName string

+ Type string

+ type UpdateEnv struct

+ EnvName string

+ Services []*UpdateServiceArg

+ type UpdateEnvRequest struct

+ Force bool

+ ProjectName string

+ Type string

+ type UpdateIngressArgs struct

+ EnvName string

+ IngressName string

+ ProductName string

+ RestartAssociatedSvc bool

+ YamlData string

+ type UpdateMultiHelmProductArg struct

+ ChartValues []*commonservice.HelmSvcRenderArg

+ DeletedServices []string

+ EnvNames []string

+ ProductName string

+ ReplacePolicy string

+ type UpdatePvcArgs struct

+ EnvName string

+ ProductName string

+ PvcName string

+ RestartAssociatedSvc bool

+ YamlData string

+ type UpdateServiceArg struct

+ DeployStrategy string

+ ServiceName string

+ VariableKVs []*commontypes.RenderVariableKV

+ type WorkloadCommonData struct

+ Ingresses []*resource.Ingress

+ Name string

+ Services []*resource.Service

+ WorkloadDetail *resource.Workload

+ func GetDeployWorkloadData(ns, name string, kc client.Client, cs *kubernetes.Clientset, ...) (*WorkloadCommonData, error)

+ func GetDsWorkloadData(ns, name string, kc client.Client, cs *kubernetes.Clientset, ...) (*WorkloadCommonData, error)

+ func GetJobData(ns, name string, kc client.Client, cs *kubernetes.Clientset, ...) (*WorkloadCommonData, error)

+ func GetStsWorkloadData(ns, name string, kc client.Client, cs *kubernetes.Clientset, ...) (*WorkloadCommonData, error)

+ type WorkloadCronJob struct

+ Active int

+ Age string

+ LastSchedule string

+ Schedule string

+ Suspend bool

+ type WorkloadDaemonSet struct

+ Available int

+ Current int

+ Desired int

+ Ready int

+ UpToDate int

+ type WorkloadDeploySts struct

+ Ready string

+ type WorkloadDetailResp struct

+ Images []resource.ContainerImage

+ Ingress []*resource.Ingress

+ Name string

+ Pods []*resource.Pod

+ Replicas int32

+ Services []*resource.Service

+ Type string

+ func GetWorkloadDetail(args *FetchResourceArgs, workloadType, workloadName string, ...) (*WorkloadDetailResp, error)

+ type WorkloadImage struct

+ Image string

+ Name string

+ type WorkloadImageTarget struct

+ ImageName string

+ Target string

+ func ListCustomWorkload(clusterID, namespace string, log *zap.SugaredLogger) ([]*WorkloadImageTarget, error)

+ type WorkloadInfo struct

+ ContainerName string

+ WorkloadName string

+ WorkloadType string

+ func ListWorkloadsInfo(clusterID, namespace string, log *zap.SugaredLogger) ([]*WorkloadInfo, error)

+ type WorkloadItem interface

+ GetName func() string

+ ImageInfos func() []string

+ type WorkloadJob struct

+ Age string

+ Completions string

+ Duration string

+ type YamlContentRequestArg struct

+ Branch string

+ CodehostID int

+ Namespace string

+ Owner string

+ Repo string

+ RepoLink string

+ ValuesPaths string

+ type YamlProductItem struct

+ BaseName string

+ DefaultValues string

+ GlobalVariables []*commontypes.GlobalVariableKV

+ NewName string

+ OldName string

+ Services []*commonservice.K8sSvcRenderArg

+ type YamlServiceWithKV struct

+ ServiceName string

+ VariableKvs []*commontypes.RenderVariableKV

v2.2.0-20240131

Feb 9, 2024

Other modules containing this package

github.com/koderover/zadig

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL