Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

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 ContainerWithBuilds struct

+ BuildNames []string

+ func FillContainerBuilds(source []*commonmodels.Container) []*ContainerWithBuilds

type EnvServices

+ func BuildServiceInfoInEnv(productInfo *commonmodels.Product, templateSvcs []*commonmodels.Service, ...) (*EnvServices, error)

type Workload

+ Containers []*resource.ContainerImage

+ Selector *metav1.LabelSelector

v2.2.0

Feb 23, 2024

Changes in this version

+ const FavoriteTypeEnv

+ const InterceptCommitID

+ const SplitSymbol

+ func AddDeliveryVersion(taskID int, productName, workflowName string, pipelineTask *taskmodels.Task, ...) error

+ func CancelTask(userName, pipelineName string, taskID int64, typeString config.PipelineType, ...) error

+ func CancelTaskV2(userName, pipelineName string, taskID int64, typeString config.PipelineType, ...) error

+ func CancelWorkflowTaskV3(userName, pipelineName string, taskID int64, typeString config.PipelineType, ...) error

+ func CopyAndUploadService(projectName, serviceName, currentChartPath string, copies []string, ...) error

+ func CreateBuild(username string, build *commonmodels.Build, log *zap.SugaredLogger) error

+ func CreateDBInstance(args *commonmodels.DBInstance, log *zap.SugaredLogger) error

+ func CreateFavorite(favorite *models.Favorite) error

+ func Delete(name, productName string, log *zap.SugaredLogger) error

+ func DeleteClusterResource(selector labels.Selector, clusterID string, log *zap.SugaredLogger) error

+ func DeleteDBInstance(id string) error

+ func DeleteDeliveryInfos(productName string, log *zap.SugaredLogger) error

+ func DeleteFavorite(args *mongodb.FavoriteArgs) error

+ func DeleteManyFavorites(args *mongodb.FavoriteArgs) error

+ func DeleteNamespaceIfMatch(namespace string, selector labels.Selector, clusterID string, ...) error

+ func DeleteNamespacedResource(namespace string, selector labels.Selector, clusterID string, ...) error

+ func DeletePipeline(pipelineName, requestID string, isDeletingProductTmpl bool, ...) error

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

+ func DeleteServiceWebhookByName(serviceName, productName string, logger *zap.SugaredLogger)

+ func DeleteTestModule(name, productName, requestID string, log *zap.SugaredLogger) error

+ func DeleteWorkflow(workflowName, requestID string, isDeletingProductTmpl bool, ...) error

+ func DeleteWorkflowV3(workflowID, workflowName, requestID string, log *zap.SugaredLogger) error

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

+ func DeleteWorkflowV4(name string, logger *zap.SugaredLogger) error

+ func DeleteWorkflowV4sByProjectName(projectName string, log *zap.SugaredLogger) error

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

+ func DeleteZadigLabelFromNamespace(namespace string, clusterID string, log *zap.SugaredLogger) error

+ func DisableCronjobForWorkflow(workflow *models.Workflow) error

+ func DisableCronjobForWorkflowV4(workflow *commonmodels.WorkflowV4) error

+ func EncryptKeyVals(encryptedKey string, kvs []*commonmodels.KeyVal, logger *zap.SugaredLogger) error

+ func EncryptParams(encryptedKey string, params []*commonmodels.Param, logger *zap.SugaredLogger) error

+ func EnsureDefaultRegistrySecret(namespace string, registryId string, kubeClient client.Client, ...) error

+ func EnsureResp(build *commonmodels.Build)

+ func EnsureSecretEnvs(existedKVs []*commonmodels.KeyVal, newKVs []*commonmodels.KeyVal)

+ func ExtractImageRegistry(imageURI string) (string, error)

+ func ExtractImageTag(imageURI string) string

+ func ExtractRegistryNamespace(imageURI string) string

+ func FillGitNamespace(yamlData *templatemodels.CustomYaml) error

+ func FillProductTemplateValuesYamls(tmpl *templatemodels.Product, production bool, log *zap.SugaredLogger) error

+ func FillServiceCreationInfo(serviceTemplate *models.Service) error

+ func FillServiceModules2Jobs(args *commonmodels.WorkflowV4) (*commonmodels.WorkflowV4, bool, error)

+ func FilterWorkloadsByEnv(exist []commonmodels.Workload, productName, env string) []commonmodels.Workload

+ func FindDBInstance(id, name string) (*commonmodels.DBInstance, error)

+ func FindDefaultRegistry(getRealCredential bool, log *zap.SugaredLogger) (reg *models.RegistryNamespace, isSystemDefault bool, err error)

+ func FindRegistryById(registryId string, getRealCredential bool, log *zap.SugaredLogger) (reg *models.RegistryNamespace, isSystemDefault bool, err error)

+ func FindReposByTarget(projectName, serviceName, serviceModule string, build *commonmodels.Build) []*types.Repository

+ func FindServiceFromIngress(hostInfos []resource.HostInfo, currentWorkload *Workload, ...) []resource.HostInfo

+ func GetConfigPayload(codeHostID int) *models.ConfigPayload

+ func GetCreateFromChartTemplate(createFrom interface{}) (*models.CreateFromChartTemplate, error)

+ func GetDefaultLLMClient(ctx context.Context) (llm.ILLM, error)

+ func GetDeliveryVersion(args *commonrepo.DeliveryVersionArgs, log *zap.SugaredLogger) (*commonmodels.DeliveryVersion, error)

+ func GetDeploymentWorkloadResource(d *appsv1.Deployment, informer informers.SharedInformerFactory, ...) *internalresource.Workload

+ func GetDockerfileTemplateContent(id string) (string, error)

+ func GetEstimatedMergedVariables(services []*commonmodels.Service, product *template.Product) (map[string]string, map[string][]*commontypes.ServiceVariableKV)

+ func GetGitlabAddress(URL string) (string, error)

+ func GetHelmServiceName(prod *models.Product, resType, resName string, kubeClient client.Client, ...) (string, error)

+ func GetLLMClient(ctx context.Context, name string) (llm.ILLM, error)

+ func GetLocalTestSuite(pipelineName, serviceName, testType string, taskID int64, testName string, ...) (*commonmodels.TestReport, error)

+ func GetNacosClient(nacosID string) (*nacos.Client, error)

+ func GetPipelineInfo(pipelineName string, log *zap.SugaredLogger) (*commonmodels.Pipeline, error)

+ func GetProductEnvNamespace(envName, productName, namespace string) string

+ func GetProductTargetMap(prod *commonmodels.Product) (map[string][]commonmodels.DeployEnv, map[string]string)

+ func GetProductTemplate(productName string, log *zap.SugaredLogger) (*template.Product, error)

+ func GetProductionServiceTemplate(serviceName, serviceType, productName, excludeStatus string, revision int64, ...) (*commonmodels.Service, error)

+ func GetRSAKey() ([]byte, []byte, error)

+ func GetServiceTasks(log *zap.SugaredLogger) (map[string][]string, error)

+ func GetServiceTemplate(serviceName, serviceType, productName, excludeStatus string, revision int64, ...) (*commonmodels.Service, error)

+ func GetSubTaskContent(deliveryVersion *commonmodels.DeliveryVersion, pipelineTask *taskmodels.Task, ...)

+ func GetWorkflowTaskCallback(taskID int64, pipelineName string) (*commonmodels.CallbackRequest, error)

+ func GetWorkflowV4LocalTestSuite(workflowName, jobName string, taskID int64, log *zap.SugaredLogger) (*commonmodels.TestReport, error)

+ func HandleCallback(req *commonmodels.CallbackRequest) error

+ func InsertDeliveryTest(args *commonmodels.DeliveryTest, log *zap.SugaredLogger) error

+ func InsertDeliveryVersion(args *commonmodels.DeliveryVersion, log *zap.SugaredLogger) error

+ func List(log *zap.SugaredLogger) []*models.Queue

+ func ListDBInstances(encryptedKey string, log *zap.SugaredLogger) ([]*commonmodels.DBInstance, error)

+ func ListDBInstancesInfo(log *zap.SugaredLogger) ([]*commonmodels.DBInstance, error)

+ func ListDBInstancesInfoByProject(projectName string, log *zap.SugaredLogger) ([]*commonmodels.DBInstance, error)

+ func ListFavorites(args *mongodb.FavoriteArgs) ([]*models.Favorite, error)

+ func ListHelmRepos(encryptedKey string, log *zap.SugaredLogger) ([]*commonmodels.HelmRepo, error)

+ func ListHelmReposByProject(projectName string, log *zap.SugaredLogger) ([]*commonmodels.HelmRepo, error)

+ func ListHelmReposPublic() ([]*commonmodels.HelmRepo, error)

+ func ListNacosConfig(nacosID, namespaceID string, log *zap.SugaredLogger) ([]*types.NacosConfig, error)

+ func ListNacosNamespace(nacosID string, log *zap.SugaredLogger) ([]*types.NacosNamespace, error)

+ func ListRegistryByProject(projectName string, log *zap.SugaredLogger) ([]*models.RegistryNamespace, error)

+ func ListRegistryNamespaces(encryptedKey string, getRealCredential bool, log *zap.SugaredLogger) ([]*models.RegistryNamespace, error)

+ func LogProductStats(user, event, prodName, requestID string, startTime int64, ...)

+ func MergeBuildEnvs(templateEnvs []*commonmodels.KeyVal, customEnvs []*commonmodels.KeyVal) []*commonmodels.KeyVal

+ func MergeParams(templateEnvs []*commonmodels.Param, customEnvs []*commonmodels.Param) []*commonmodels.Param

+ func ProcessServiceWebhook(updated, current *commonmodels.Service, serviceName string, ...)

+ func ProcessWebhook(updatedHooks, currentHooks interface{}, name string, logger *zap.SugaredLogger) error

+ func ReleaseCandidate(builds []*types.Repository, taskID int64, ...) string

+ func Remove(task *models.Queue, log *zap.SugaredLogger) error

+ func ReplaceRuleVariable(rule string, replaceValue *Variable) string

+ func SaveAndUploadService(projectName, serviceName string, copies []string, fileTree fs.FS, ...) error

+ func UnMarshalSourceDetail(source interface{}) (*models.CreateFromRepo, error)

+ func UpdateBuild(username string, build *commonmodels.Build, log *zap.SugaredLogger) error

+ func UpdateDBInstance(id string, args *commonmodels.DBInstance, log *zap.SugaredLogger) error

+ func UpdatePmServiceTemplate(username string, args *ServiceTmplBuildObject, log *zap.SugaredLogger) error

+ func ValidateDBInstance(args *commonmodels.DBInstance) error

+ type ConvertVaraibleKVAndYamlActionType string

+ const ConvertVaraibleKVAndYamlActionTypeToKV

+ const ConvertVaraibleKVAndYamlActionTypeToYaml

+ type ConvertVaraibleKVAndYamlArgs struct

+ Action ConvertVaraibleKVAndYamlActionType

+ KVs []*commontypes.ServiceVariableKV

+ Yaml string

+ func ConvertVaraibleKVAndYaml(args *ConvertVaraibleKVAndYamlArgs) (*ConvertVaraibleKVAndYamlArgs, error)

+ type CronjobPayload struct

+ Action string

+ DeleteList []string

+ JobList []*models.Schedule

+ JobType string

+ Name string

+ ProductName string

+ type Empty struct

+ type EnvService struct

+ Deployed bool

+ LatestVariableKVs []*commontypes.RenderVariableKV

+ LatestVariableYaml string

+ ServiceModules []*commonmodels.Container

+ ServiceName string

+ Updatable bool

+ VariableKVs []*commontypes.RenderVariableKV

+ VariableYaml string

+ type EnvServices struct

+ EnvName string

+ ProductName string

+ Services []*EnvService

+ func ListServicesInEnv(envName, productName string, ...) (*EnvServices, error)

+ type Features struct

+ Features []string

+ type FilterFunc func(services []*Workload) []*Workload

+ func BuildWorkloadFilterFunc(productInfo *models.Product, projectInfo *templatemodels.Product, ...) ([]FilterFunc, error)

+ type GetAesKeyFromEncryptedKeyResp struct

+ PlainText string

+ func GetAesKeyFromEncryptedKey(encryptedKey string, log *zap.SugaredLogger) (*GetAesKeyFromEncryptedKeyResp, error)

+ type GetRSAPublicKeyRes struct

+ PublicKey string

+ func GetRSAPublicKey() (*GetRSAPublicKeyRes, error)

+ type GetSvcRenderArg struct

+ IsHelmChartDeploy bool

+ ServiceOrReleaseName string

+ type GetSvcRenderRequest struct

+ GetSvcRendersArgs []*GetSvcRenderArg

+ type HelmSvcRenderArg struct

+ ChartName string

+ ChartRepo string

+ ChartVersion string

+ DeployStrategy string

+ EnvName string

+ IsChartDeploy bool

+ OverrideValues []*KVPair

+ OverrideYaml string

+ ReleaseName string

+ ServiceName string

+ ValuesData *ValuesDataArgs

+ VariableYaml string

+ YamlData *templatemodels.CustomYaml

+ func GetSvcRenderArgs(productName, envName string, getSvcRendersArgs []*GetSvcRenderArg, ...) ([]*HelmSvcRenderArg, *models.RenderSet, error)

+ func (args *HelmSvcRenderArg) DiffValues(target *HelmSvcRenderArg) RenderChartDiffResult

+ func (args *HelmSvcRenderArg) FillRenderChartModel(chart *templatemodels.ServiceRender, version string)

+ func (args *HelmSvcRenderArg) GetUniqueKvMap() map[string]interface{}

+ func (args *HelmSvcRenderArg) LoadFromRenderChartModel(chart *templatemodels.ServiceRender)

+ func (args *HelmSvcRenderArg) ToOverrideValueString() string

+ type HookSet map[hookUniqueID]hookItem

+ func NewHookSet(items ...hookItem) HookSet

+ func (s HookSet) Difference(s2 HookSet) HookSet

+ func (s HookSet) Has(item hookItem) bool

+ func (s HookSet) Insert(items ...hookItem) HookSet

+ func (s HookSet) Len() int

+ type IngressInfo struct

+ HostInfo []resource.HostInfo

+ type IstioGatewayInfo struct

+ Servers []IstioGatewayServer

+ type IstioGatewayServer struct

+ Host string

+ PortNumber uint32

+ PortProtocol string

+ func FindServiceFromIstioGateway(gwObjs *v1alpha3.GatewayList, serviceName string) []IstioGatewayServer

+ type K8sSvcRenderArg struct

+ DeployStrategy string

+ EnvName string

+ LatestVariableKVs []*commontypes.RenderVariableKV

+ LatestVariableYaml string

+ ServiceName string

+ VariableKVs []*commontypes.RenderVariableKV

+ VariableYaml string

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

+ func GetK8sSvcRenderArgs(productName, envName, serviceName string, production bool, ...) ([]*K8sSvcRenderArg, *models.RenderSet, error)

+ type KVPair struct

+ Key string

+ Value interface{}

+ type PipelineResource struct

+ Kind string

+ Version string

+ type RenderChartDiffResult string

+ const Different

+ const LogicSame

+ const Same

+ type RepoConfig struct

+ Branch string

+ CodehostID int

+ Namespace string

+ Owner string

+ Repo string

+ ValuesPaths []string

+ type ServiceProductMap struct

+ AutoSync bool

+ BranchName string

+ CodehostID int

+ Containers []*commonmodels.Container

+ CreateFrom interface{}

+ EstimatedMergedVariable string

+ EstimatedMergedVariableKVs []*commontypes.ServiceVariableKV

+ GerritRemoteName string

+ LoadFromDir bool

+ LoadPath string

+ Product []string

+ ProductName string

+ RepoName string

+ RepoNamespace string

+ RepoOwner string

+ RepoUUID string

+ Service string

+ Source string

+ Type string

+ type ServiceResp struct

+ DeployStrategy string

+ EnvConfigs []*models.EnvConfig

+ EnvName string

+ EnvStatuses []*models.EnvStatus

+ Error string

+ Images []string

+ Ingress *IngressInfo

+ IsHelmChartDeploy bool

+ IstioGateway *IstioGatewayInfo

+ ProductName string

+ Ready string

+ ReleaseName string

+ Revision int64

+ ServiceDisplayName string

+ ServiceName string

+ Status string

+ Type string

+ Updatable bool

+ WorkLoadType string

+ ZadigXReleaseTag string

+ ZadigXReleaseType string

+ func ListWorkloadDetails(envName, clusterID, namespace, productName string, perPage, page int, ...) (int, []*ServiceResp, error)

+ func ListWorkloadDetailsInEnv(envName, productName, filter string, perPage, page int, log *zap.SugaredLogger) (int, []*ServiceResp, error)

+ type ServiceTmplBuildObject struct

+ Build *commonmodels.Build

+ ServiceTmplObject *ServiceTmplObject

+ type ServiceTmplObject struct

+ EnvConfigs []*commonmodels.EnvConfig

+ EnvName string

+ EnvStatuses []*commonmodels.EnvStatus

+ From string

+ HealthChecks []*commonmodels.PmHealthCheck

+ ProductName string

+ Revision int64

+ ServiceName string

+ ServiceVariableKVs []*commontypes.ServiceVariableKV

+ Type string

+ Username string

+ VariableYaml string

+ Visibility string

+ type ServiceTmplResp struct

+ Data []*ServiceProductMap

+ Total int

+ func ListServiceTemplate(productName string, log *zap.SugaredLogger) (*ServiceTmplResp, error)

+ func ListWorkloadTemplate(productName, envName string, log *zap.SugaredLogger) (*ServiceTmplResp, error)

+ type SvcResources struct

+ Kind string

+ Name string

+ func GeneSvcStructure(svcTemplate *models.Service) []*SvcResources

+ type SvcResp struct

+ CronJobs []*internalresource.CronJob

+ EnvName string

+ GroupName string

+ Ingress []*internalresource.Ingress

+ Namespace string

+ ProductName string

+ Scales []*internalresource.Workload

+ ServiceName string

+ Services []*internalresource.Service

+ Workloads []*Workload

+ func GetServiceImpl(serviceName string, serviceTmpl *commonmodels.Service, workLoadType string, ...) (ret *SvcResp, err error)

+ type TemplateSvcResp struct

+ Resources []*SvcResources

+ func GetServiceTemplateWithStructure(serviceName, serviceType, productName, excludeStatus string, revision int64, ...) (*TemplateSvcResp, error)

+ type ValuesDataArgs struct

+ AutoSync bool

+ GitRepoConfig *RepoConfig

+ SourceID string

+ YamlSource string

+ type ValuesResp struct

+ ValuesYaml string

+ func GetChartValues(projectName, envName, serviceName string, isHelmChartDeploy bool, ...) (*ValuesResp, error)

+ type Variable struct

+ ENV_NAME string

+ IMAGE_NAME string

+ PROJECT string

+ REPO_BRANCH string

+ REPO_COMMIT_ID string

+ REPO_PR string

+ REPO_TAG string

+ SERVICE string

+ TASK_ID string

+ TIMESTAMP string

+ type Workload struct

+ Annotation map[string]string

+ ChartName string

+ DeployedFromZadig bool

+ EnvName string

+ Images []string

+ Name string

+ ProductName string

+ Ready bool

+ ReleaseName string

+ Replicas int32

+ ServiceName string

+ Spec corev1.PodTemplateSpec

+ Status string

+ Type string

+ func ListWorkloads(envName, productName string, perPage, page int, ...) (int, []*Workload, error)

+ func ListWorkloadsInEnv(envName, productName, filter string, perPage, page int, log *zap.SugaredLogger) (int, []*Workload, error)

+ func ToDeploymentWorkload(v *appsv1.Deployment) *Workload

+ type ZadigServiceStatusResp struct

+ Images []string

+ Ingress []*resource.Ingress

+ PodStatus string

+ Ready string

+ ServiceName string

+ Workloads []*Workload

+ func QueryPodsStatus(productInfo *commonmodels.Product, serviceTmpl *commonmodels.Service, ...) *ZadigServiceStatusResp

v2.2.0-20240131

Feb 9, 2024

Other modules containing this package

github.com/koderover/zadig