mongodb

package

Go to main page

Versions in this module

v1

v1.18.0

Aug 11, 2023

v1.17.0

Apr 3, 2023

v1.16.0

Dec 30, 2022

Changes in this version

type IMAppColl

+ func (c *IMAppColl) GetByAppID(ctx context.Context, appID string) (*models.IMApp, error)

v1.15.0

Sep 30, 2022

v1.14.0

Aug 18, 2022

v1.13.0

Jul 8, 2022

v1.12.0

May 31, 2022

Changes in this version

type ServiceColl

+ func (c *ServiceColl) ListMaxRevisionServicesByChartTemplate(templateName string) ([]*models.Service, error)

+ func (c *ServiceColl) ListMaxRevisionServicesByYamlTemplate(templateId string) ([]*models.Service, error)

v1.11.0

Apr 21, 2022

Changes in this version

+ type ConfigMapColl struct

+ func NewConfigMapColl() *ConfigMapColl

+ func (c *ConfigMapColl) Create(args *models.EnvConfigMap, isCreateTime bool) error

+ func (c *ConfigMapColl) EnsureIndex(ctx context.Context) error

+ func (c *ConfigMapColl) Find(opt *FindEnvCfgOption) (*models.EnvConfigMap, error)

+ func (c *ConfigMapColl) GetCollectionName() string

+ func (c *ConfigMapColl) List(opt *ListEnvCfgOption) ([]*models.EnvConfigMap, error)

+ func (c *ConfigMapColl) Update(id string, services []string) error

+ type FindEnvCfgOption struct

+ CreateTime string

+ EnvName string

+ Id string

+ Name string

+ Namespace string

+ ProductName string

+ type IngressColl struct

+ func NewIngressColl() *IngressColl

+ func (c *IngressColl) Create(args *models.EnvIngress, isCreateTime bool) error

+ func (c *IngressColl) EnsureIndex(ctx context.Context) error

+ func (c *IngressColl) GetCollectionName() string

+ func (c *IngressColl) List(opt *ListEnvCfgOption) ([]*models.EnvIngress, error)

+ type ListEnvCfgOption struct

+ EnvName string

+ IsSort bool

+ Name string

+ Namespace string

+ ProductName string

+ type PvcColl struct

+ func NewPvcColl() *PvcColl

+ func (c *PvcColl) Create(args *models.EnvPvc, isCreateTime bool) error

+ func (c *PvcColl) EnsureIndex(ctx context.Context) error

+ func (c *PvcColl) Find(opt *FindEnvCfgOption) (*models.EnvPvc, error)

+ func (c *PvcColl) GetCollectionName() string

+ func (c *PvcColl) List(opt *ListEnvCfgOption) ([]*models.EnvPvc, error)

+ func (c *PvcColl) Update(id string, services []string) error

+ type SecretColl struct

+ func NewSecretColl() *SecretColl

+ func (c *SecretColl) Create(args *models.EnvSecret, isCreateTime bool) error

+ func (c *SecretColl) EnsureIndex(ctx context.Context) error

+ func (c *SecretColl) Find(opt *FindEnvCfgOption) (*models.EnvSecret, error)

+ func (c *SecretColl) GetCollectionName() string

+ func (c *SecretColl) List(opt *ListEnvCfgOption) ([]*models.EnvSecret, error)

+ func (c *SecretColl) Update(id string, services []string) error

v1.10.0

Mar 8, 2022

Changes in this version

type RenderSetColl

+ func (c *RenderSetColl) ListByFindOpts(opt *RenderSetListOption) ([]models.RenderSet, error)

type RenderSetListOption

+ FindOpts []RenderSetFindOption

v1.9.9

Oct 24, 2023

Changes in this version

type BasicImageColl

+ func (c *BasicImageColl) FindByImageName(name string) (*models.BasicImage, error)

type BasicImageOpt

+ ImageType string

type BuildColl

+ func (c *BuildColl) GetBuildTemplateReference(templateID string) ([]*models.Build, error)

+ func (c *BuildColl) ListByCursor(opt *BuildListOption) (*mongo.Cursor, error)

+ func (c *BuildColl) ListByOptions(opt *BuildListOption) ([]*models.Build, int64, error)

type BuildListOption

+ PageNum int64

+ PageSize int64

+ TemplateID string

+ type BuildStage struct

+ SubTasks map[string]task.Build

+ type BuildTemplateColl struct

+ func NewBuildTemplateColl() *BuildTemplateColl

+ func (c *BuildTemplateColl) Create(obj *models.BuildTemplate) error

+ func (c *BuildTemplateColl) DeleteByID(idStr string) error

+ func (c *BuildTemplateColl) DeleteByName(name string) error

+ func (c *BuildTemplateColl) EnsureIndex(ctx context.Context) error

+ func (c *BuildTemplateColl) Find(opt *BuildTemplateQueryOption) (*models.BuildTemplate, error)

+ func (c *BuildTemplateColl) GetCollectionName() string

+ func (c *BuildTemplateColl) List(pageNum, pageSize int) ([]*models.BuildTemplate, int, error)

+ func (c *BuildTemplateColl) ListByCursor(opts *ListBuildTemplateOption) (*mongo.Cursor, error)

+ func (c *BuildTemplateColl) Update(idStr string, obj *models.BuildTemplate) error

+ type BuildTemplateQueryOption struct

+ ID string

+ Name string

+ type CodeInfo struct

+ AuthorName string

+ CommitId string

+ CommitMessage string

+ type ConfigOption struct

+ ItemKey string

+ Type string

+ type ConfigurationManagementColl struct

+ func NewConfigurationManagementColl() *ConfigurationManagementColl

+ func (c *ConfigurationManagementColl) Create(ctx context.Context, args *models.ConfigurationManagement) error

+ func (c *ConfigurationManagementColl) DeleteByID(ctx context.Context, idString string) error

+ func (c *ConfigurationManagementColl) EnsureIndex(ctx context.Context) error

+ func (c *ConfigurationManagementColl) GetApolloByID(ctx context.Context, idString string) (*models.ApolloConfig, error)

+ func (c *ConfigurationManagementColl) GetByID(ctx context.Context, idString string) (*models.ConfigurationManagement, error)

+ func (c *ConfigurationManagementColl) GetBySystemIdentity(systemIdentity string) (*models.ConfigurationManagement, error)

+ func (c *ConfigurationManagementColl) GetCollectionName() string

+ func (c *ConfigurationManagementColl) GetNacosByID(ctx context.Context, idString string) (*models.NacosConfig, error)

+ func (c *ConfigurationManagementColl) List(ctx context.Context, _type string) ([]*models.ConfigurationManagement, error)

+ func (c *ConfigurationManagementColl) Update(ctx context.Context, idString string, obj *models.ConfigurationManagement) error

type CountTaskOption

+ ServiceModule []string

type CounterColl

+ func (c *CounterColl) UpsertCounter(counterName string, number int64) error

type CronjobColl

+ func (c *CronjobColl) GetByID(id primitive.ObjectID) (*models.Cronjob, error)

+ func (c *CronjobColl) GetByName(name, cronType string) (*models.Cronjob, error)

+ func (c *CronjobColl) Upsert(args *models.Cronjob) error

+ type DBInstanceColl struct

+ func NewDBInstanceColl() *DBInstanceColl

+ func (c *DBInstanceColl) Create(args *models.DBInstance) error

+ func (c *DBInstanceColl) Delete(id string) error

+ func (c *DBInstanceColl) EnsureIndex(ctx context.Context) error

+ func (c *DBInstanceColl) Find(opt *DBInstanceCollFindOption) (*models.DBInstance, error)

+ func (c *DBInstanceColl) GetCollectionName() string

+ func (c *DBInstanceColl) List() ([]*models.DBInstance, error)

+ func (c *DBInstanceColl) ListByProject(projectName string) ([]*models.DBInstance, error)

+ func (c *DBInstanceColl) Update(id string, args *models.DBInstance) error

+ type DBInstanceCollFindOption struct

+ Id string

+ Name string

+ type DashboardConfigColl struct

+ func NewDashboardConfigColl() *DashboardConfigColl

+ func (c *DashboardConfigColl) CreateOrUpdate(args *models.DashboardConfig) error

+ func (c *DashboardConfigColl) EnsureIndex(ctx context.Context) error

+ func (c *DashboardConfigColl) GetByUser(userName, userID string) (*models.DashboardConfig, error)

+ func (c *DashboardConfigColl) GetCollectionName() string

+ type DeleteEnvSvcDependOption struct

+ CreateTime string

+ EnvName string

+ Id string

+ Namespace string

+ ProductName string

+ ServiceModule string

+ ServiceName string

type DeliveryArtifactArgs

+ OnlyCount bool

type DindCleanColl

+ func (c *DindCleanColl) UpdateStatusInfo(args *models.DindClean) error

type DockerfileTemplateColl

+ func (c *DockerfileTemplateColl) GetByName(name string) (*models.DockerfileTemplate, error)

+ type EnvResourceAggregateData struct

+ CreateTime int64

+ ID EnvResourceBaseData

+ type EnvResourceBaseData struct

+ EnvName string

+ Name string

+ ProductName string

+ Type string

+ type EnvResourceColl struct

+ func NewEnvResourceColl() *EnvResourceColl

+ func (c *EnvResourceColl) Create(args *models.EnvResource) error

+ func (c *EnvResourceColl) Delete(oid primitive.ObjectID) error

+ func (c *EnvResourceColl) EnsureIndex(ctx context.Context) error

+ func (c *EnvResourceColl) Find(opt *QueryEnvResourceOption) (*models.EnvResource, error)

+ func (c *EnvResourceColl) GetCollectionName() string

+ func (c *EnvResourceColl) List(opt *QueryEnvResourceOption) ([]*models.EnvResource, error)

+ func (c *EnvResourceColl) ListLatestResource(opt *QueryEnvResourceOption) ([]*EnvResourceAggregateData, error)

+ type EnvSvcDependColl struct

+ func NewEnvSvcDependColl() *EnvSvcDependColl

+ func (c *EnvSvcDependColl) Create(args *models.EnvSvcDepend) error

+ func (c *EnvSvcDependColl) CreateOrUpdate(envSvcDepend *models.EnvSvcDepend) error

+ func (c *EnvSvcDependColl) Delete(opt *DeleteEnvSvcDependOption) error

+ func (c *EnvSvcDependColl) EnsureIndex(ctx context.Context) error

+ func (c *EnvSvcDependColl) Find(opt *FindEnvSvcDependOption) (*models.EnvSvcDepend, error)

+ func (c *EnvSvcDependColl) GetCollectionName() string

+ func (c *EnvSvcDependColl) List(opt *ListEnvSvcDependOption) ([]*models.EnvSvcDepend, error)

+ func (c *EnvSvcDependColl) Update(id string, envSvcDepend *models.EnvSvcDepend) error

+ type EnvVersionColl struct

+ func NewEnvServiceVersionColl() *EnvVersionColl

+ func (c *EnvVersionColl) Create(args *models.EnvServiceVersion) error

+ func (c *EnvVersionColl) DeleteRevisions(productName, envName, serviceName string, isHelmChart, production bool, ...) error

+ func (c *EnvVersionColl) EnsureIndex(ctx context.Context) error

+ func (c *EnvVersionColl) Find(productName, envName, serviceName string, isHelmChart, production bool, ...) (*models.EnvServiceVersion, error)

+ func (c *EnvVersionColl) GetCollectionName() string

+ func (c *EnvVersionColl) GetCountAndMaxRevision(productName, envName, serviceName string, isHelmChart, production bool) (int64, int64, error)

+ func (c *EnvVersionColl) ListServiceVersions(productName, envName, serviceName string, isHelmChart, production bool) ([]*models.EnvServiceVersion, error)

type FavoriteColl

+ func (c *FavoriteColl) DeleteManyByArgs(args *FavoriteArgs) error

+ type FindEnvSvcDependOption struct

+ CreateTime string

+ EnvName string

+ Id string

+ Namespace string

+ ProductName string

+ ServiceModule string

+ ServiceName string

type FindPrivateKeyOption

+ Labels []string

+ Status string

+ Token string

type HelmRepoColl

+ func (c *HelmRepoColl) ListByProject(projectName string) ([]*models.HelmRepo, error)

+ type IMAppColl struct

+ func NewIMAppColl() *IMAppColl

+ func (c *IMAppColl) Create(ctx context.Context, args *models.IMApp) (string, error)

+ func (c *IMAppColl) DeleteByID(ctx context.Context, idString string) error

+ func (c *IMAppColl) EnsureIndex(ctx context.Context) error

+ func (c *IMAppColl) GetByID(ctx context.Context, idString string) (*models.IMApp, error)

+ func (c *IMAppColl) GetCollectionName() string

+ func (c *IMAppColl) GetDingTalkByAppKey(ctx context.Context, appKey string) (*models.IMApp, error)

+ func (c *IMAppColl) GetLarkByAppID(ctx context.Context, appID string) (*models.IMApp, error)

+ func (c *IMAppColl) List(ctx context.Context, _type string) ([]*models.IMApp, error)

+ func (c *IMAppColl) Update(ctx context.Context, idString string, arg *models.IMApp) error

+ type ImageTagsColl struct

+ func NewImageTagsCollColl() *ImageTagsColl

+ func (c *ImageTagsColl) EnsureIndex(ctx context.Context) error

+ func (c *ImageTagsColl) Find(opt *ImageTagsFindOption) (*models.ImageTags, error)

+ func (c *ImageTagsColl) GetCollectionName() string

+ func (c *ImageTagsColl) Insert(args *models.ImageTags) error

+ func (c *ImageTagsColl) InsertOrUpdate(args *models.ImageTags) error

+ type ImageTagsFindOption struct

+ ImageName string

+ Namespace string

+ RegProvider string

+ RegistryID string

+ TagName string

type JenkinsIntegrationColl

+ func (c *JenkinsIntegrationColl) Get(id string) (*models.JenkinsIntegration, error)

+ type JobBuildTrendInfos struct

+ Documents []*models.JobInfo

+ ProjectName string

+ type JobInfoCoarseGrainedData struct

+ EndTime int64

+ MonthlyStat []*MonthlyJobInfo

+ StartTime int64

+ type JobInfoColl struct

+ func NewJobInfoColl() *JobInfoColl

+ func (c *JobInfoColl) Create(ctx context.Context, args *models.JobInfo) error

+ func (c *JobInfoColl) EnsureIndex(ctx context.Context) error

+ func (c *JobInfoColl) GetAllProjectNameByTypeName(startTime, endTime int64, typeName string) ([]string, error)

+ func (c *JobInfoColl) GetBuildJobs(startTime, endTime int64, projectName string) ([]*models.JobInfo, error)

+ func (c *JobInfoColl) GetBuildTrend(startTime, endTime int64, projectName []string) ([]*models.JobInfo, error)

+ func (c *JobInfoColl) GetCollectionName() string

+ func (c *JobInfoColl) GetDeployJobs(startTime, endTime int64, projectName string) ([]*models.JobInfo, error)

+ func (c *JobInfoColl) GetDeployTrend(startTime, endTime int64, projectName []string) ([]*models.JobInfo, error)

+ func (c *JobInfoColl) GetJobBuildTrendInfos(startTime, endTime int64, projectName []string) ([]*JobBuildTrendInfos, error)

+ func (c *JobInfoColl) GetJobInfos(startTime, endTime int64, projectName []string) ([]*models.JobInfo, error)

+ func (c *JobInfoColl) GetProductionDeployJobs(startTime, endTime int64, projectName string) ([]*models.JobInfo, error)

+ func (c *JobInfoColl) GetTestJobs(startTime, endTime int64, projectName string) ([]*models.JobInfo, error)

+ func (c *JobInfoColl) GetTestTrend(startTime, endTime int64, projectName []string) ([]*models.JobInfo, error)

type K8SClusterColl

+ func (c *K8SClusterColl) FindActiveClusters() ([]*models.K8SCluster, error)

+ func (c *K8SClusterColl) FindByID(ID string) (*models.K8SCluster, error)

+ func (c *K8SClusterColl) UpdateScheduleStrategy(cluster *models.K8SCluster) error

+ func (c *K8SClusterColl) UpdateUpgradeAgentInfo(id, updateHubagentErrorMsg string) error

+ type LLMIntegrationColl struct

+ func NewLLMIntegrationColl() *LLMIntegrationColl

+ func (c *LLMIntegrationColl) Count(ctx context.Context) (int64, error)

+ func (c *LLMIntegrationColl) Create(ctx context.Context, args *models.LLMIntegration) error

+ func (c *LLMIntegrationColl) Delete(ctx context.Context, id string) error

+ func (c *LLMIntegrationColl) EnsureIndex(ctx context.Context) error

+ func (c *LLMIntegrationColl) FindAll(ctx context.Context) ([]*models.LLMIntegration, error)

+ func (c *LLMIntegrationColl) FindByID(ctx context.Context, id string) (*models.LLMIntegration, error)

+ func (c *LLMIntegrationColl) FindByName(ctx context.Context, name string) (*models.LLMIntegration, error)

+ func (c *LLMIntegrationColl) GetCollectionName() string

+ func (c *LLMIntegrationColl) Update(ctx context.Context, id string, args *models.LLMIntegration) error

+ type ListBuildTemplateOption struct

+ Infrastructure string

+ type ListEnvSvcDependOption struct

+ EnvName string

+ IsSort bool

+ Namespace string

+ ProductName string

+ ServiceModule string

+ ServiceName string

+ type ListMsgQueueCommonOption struct

+ QueueType string

+ type ListMsgQueuePipelineTaskOption struct

+ QueueType string

+ SortQueueID bool

+ type ListProductOpt struct

+ Products []Product

+ type ListReleasePlanLogOption struct

+ IsSort bool

+ PlanID string

+ type ListReleasePlanOption struct

+ ExcludedFields []string

+ IsSort bool

+ PageNum int64

+ PageSize int64

+ Status config.ReleasePlanStatus

type ListTaskOption

+ ForWorkflowTaskList bool

+ ServiceModule []string

type ListTestOption

+ ProductNames []string

+ TestNames []string

+ type ListWorfklowQueueOption struct

+ Status config.Status

+ WorkflowName string

+ type ListWorkflowOpt struct

+ Workflows []Workflow

type ListWorkflowOption

+ DisplayName string

+ Ids []string

+ Names []string

+ type ListWorkflowTaskV4Option struct

+ BeforeCreatTime bool

+ CreateTime int64

+ IsSort bool

+ Limit int

+ ProjectName string

+ ProjectNames []string

+ Skip int

+ WorkflowName string

+ WorkflowNames []string

+ type ListWorkflowV4Opt struct

+ Workflows []WorkflowV4

+ type ListWorkflowV4Option struct

+ Category setting.WorkflowCategory

+ DisplayName string

+ Infrastructure string

+ JobTypes []config.JobType

+ Names []string

+ ProjectName string

+ type ListWorkflowV4TemplateOption struct

+ Category setting.WorkflowCategory

+ Names []string

+ type MonthlyJobInfo struct

+ BuildCount int

+ DeployCount int

+ Month int

+ TestCount int

+ type MsgQueueCommonColl struct

+ func NewMsgQueueCommonColl() *MsgQueueCommonColl

+ func (c *MsgQueueCommonColl) Create(args *msg_queue.MsgQueueCommon) error

+ func (c *MsgQueueCommonColl) Delete(id primitive.ObjectID) error

+ func (c *MsgQueueCommonColl) DeleteByQueueType(_type string) error

+ func (c *MsgQueueCommonColl) EnsureIndex(ctx context.Context) error

+ func (c *MsgQueueCommonColl) GetCollectionName() string

+ func (c *MsgQueueCommonColl) List(opt *ListMsgQueueCommonOption) ([]*msg_queue.MsgQueueCommon, error)

+ type MsgQueuePipelineTaskColl struct

+ func NewMsgQueuePipelineTaskColl() *MsgQueuePipelineTaskColl

+ func (c *MsgQueuePipelineTaskColl) Create(args *msg_queue.MsgQueuePipelineTask) error

+ func (c *MsgQueuePipelineTaskColl) Delete(id primitive.ObjectID) error

+ func (c *MsgQueuePipelineTaskColl) EnsureIndex(ctx context.Context) error

+ func (c *MsgQueuePipelineTaskColl) GetCollectionName() string

+ func (c *MsgQueuePipelineTaskColl) List(opt *ListMsgQueuePipelineTaskOption) ([]*msg_queue.MsgQueuePipelineTask, error)

+ type ObservabilityColl struct

+ func NewObservabilityColl() *ObservabilityColl

+ func (c *ObservabilityColl) Create(ctx context.Context, args *models.Observability) error

+ func (c *ObservabilityColl) DeleteByID(ctx context.Context, idString string) error

+ func (c *ObservabilityColl) EnsureIndex(ctx context.Context) error

+ func (c *ObservabilityColl) GetByID(ctx context.Context, idString string) (*models.Observability, error)

+ func (c *ObservabilityColl) GetCollectionName() string

+ func (c *ObservabilityColl) List(ctx context.Context, _type string) ([]*models.Observability, error)

+ func (c *ObservabilityColl) Update(ctx context.Context, idString string, args *models.Observability) error

+ type PluginRepoColl struct

+ func NewPluginRepoColl() *PluginRepoColl

+ func (c *PluginRepoColl) Delete(id string) error

+ func (c *PluginRepoColl) EnsureIndex(ctx context.Context) error

+ func (c *PluginRepoColl) GetCollectionName() string

+ func (c *PluginRepoColl) List(offical *bool) ([]*models.PluginRepo, error)

+ func (c *PluginRepoColl) Upsert(pluginRepo *models.PluginRepo) error

type PrivateKeyArgs

+ ProjectName string

+ SystemOnly bool

type PrivateKeyColl

+ func (c *PrivateKeyColl) BulkDelete(projectName string) error

+ type Product struct

+ Name string

+ ProjectName string

type ProductColl

+ func (c *ProductColl) ListByProducts(opt ListProductOpt) ([]*models.Product, error)

+ func (c *ProductColl) ListExistedNamespace(clusterID string) ([]string, error)

+ func (c *ProductColl) ListProductionNamespace(clusterID string) ([]string, error)

+ func (c *ProductColl) UpdateConfigs(envName, productName string, analysisConfig *models.AnalysisConfig, ...) error

+ func (c *ProductColl) UpdateDeployStrategy(envName, productName string, deployStrategy map[string]string) error

+ func (c *ProductColl) UpdateDeployStrategyAndGlobalVariable(envName, productName string, deployStrategy map[string]string, ...) error

+ func (c *ProductColl) UpdateGlobalVariable(args *models.Product) error

+ func (c *ProductColl) UpdateProductAlias(envName, productName, alias string) error

+ func (c *ProductColl) UpdateProductVariables(product *models.Product) error

+ func (c *ProductColl) UpdateStatusAndError(envName, projectName, status, errorMsg string) error

type ProductFindOptions

+ IgnoreNotFoundErr bool

+ Production *bool

type ProductListOptions

+ InIDs []string

+ Namespace string

+ Production *bool

+ ShareEnvBaseEnv *string

+ ShareEnvEnable *bool

+ ShareEnvIsBase *bool

+ type ProductionServiceColl struct

+ func NewProductionServiceColl() *ProductionServiceColl

+ func (c *ProductionServiceColl) Create(args *models.Service) error

+ func (c *ProductionServiceColl) Delete(serviceName, productName, status string, revision int64) error

+ func (c *ProductionServiceColl) DeleteByOptions(opts ProductionServiceDeleteOption) error

+ func (c *ProductionServiceColl) DeleteByProject(productName string) error

+ func (c *ProductionServiceColl) EnsureIndex(ctx context.Context) error

+ func (c *ProductionServiceColl) Find(opt *ServiceFindOption) (*models.Service, error)

+ func (c *ProductionServiceColl) GetChartTemplateReference(templateName string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) GetCollectionName() string

+ func (c *ProductionServiceColl) GetYamlTemplateLatestReference(templateID string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) GetYamlTemplateReference(templateID string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) ListMaxRevisions(opt *ServiceListOption) ([]*models.Service, error)

+ func (c *ProductionServiceColl) ListMaxRevisionsByProduct(productName string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) ListMaxRevisionsByProject(productName, serviceType string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) ListServiceAllRevisions(productName, serviceName string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) ListServiceAllRevisionsAndStatus(serviceName, productName string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) ListServicesWithSRevision(opt *SvcRevisionListOption) ([]*models.Service, error)

+ func (c *ProductionServiceColl) SearchMaxRevisionsByService(serviceName string) ([]*models.Service, error)

+ func (c *ProductionServiceColl) Update(args *models.Service) error

+ func (c *ProductionServiceColl) UpdateServiceContainers(args *models.Service) error

+ func (c *ProductionServiceColl) UpdateServiceVariables(args *models.Service) error

+ func (c *ProductionServiceColl) UpdateStatus(serviceName, productName, status string) error

+ type ProductionServiceDeleteOption struct

+ ProductName string

+ Revision int64

+ ServiceName string

+ Status string

+ Type string

+ type ProductionServiceOption struct

+ ExcludeStatus string

+ ProductName string

+ type ProjectGroupColl struct

+ func NewProjectGroupColl() *ProjectGroupColl

+ func (c *ProjectGroupColl) Create(args *models.ProjectGroup) error

+ func (c *ProjectGroupColl) Delete(name string) error

+ func (c *ProjectGroupColl) EnsureIndex(ctx context.Context) error

+ func (c *ProjectGroupColl) Find(opts ProjectGroupOpts) (*models.ProjectGroup, error)

+ func (c *ProjectGroupColl) GetCollectionName() string

+ func (c *ProjectGroupColl) List() ([]*models.ProjectGroup, error)

+ func (c *ProjectGroupColl) ListGroupNames() ([]string, error)

+ func (c *ProjectGroupColl) Update(args *models.ProjectGroup) error

+ type ProjectGroupOpts struct

+ ID string

+ Name string

+ type ProjectManagementColl struct

+ func NewProjectManagementColl() *ProjectManagementColl

+ func (c *ProjectManagementColl) Create(pm *models.ProjectManagement) error

+ func (c *ProjectManagementColl) DeleteByID(idHex string) error

+ func (c *ProjectManagementColl) EnsureIndex(ctx context.Context) error

+ func (c *ProjectManagementColl) GetByID(idHex string) (*models.ProjectManagement, error)

+ func (c *ProjectManagementColl) GetBySystemIdentity(systemIdentity string) (*models.ProjectManagement, error)

+ func (c *ProjectManagementColl) GetCollectionName() string

+ func (c *ProjectManagementColl) GetJira() (*models.ProjectManagement, error)

+ func (c *ProjectManagementColl) GetJiraByID(idHex string) (*models.ProjectManagement, error)

+ func (c *ProjectManagementColl) GetMeego() (*models.ProjectManagement, error)

+ func (c *ProjectManagementColl) GetMeegoByID(idHex string) (*models.ProjectManagement, error)

+ func (c *ProjectManagementColl) List() ([]*models.ProjectManagement, error)

+ func (c *ProjectManagementColl) UpdateByID(idHex string, pm *models.ProjectManagement) error

+ type QueryEnvResourceOption struct

+ Active bool

+ AutoSync bool

+ CreateTime string

+ EnvName string

+ Id string

+ IgnoreNotFound bool

+ IsSort bool

+ Name string

+ Namespace string

+ ProductName string

+ Type string

type RegistryNamespaceColl

+ func (r *RegistryNamespaceColl) FindByProject(projectName string) ([]*models.RegistryNamespace, error)

+ type ReleasePlanColl struct

+ func NewReleasePlanColl() *ReleasePlanColl

+ func (c *ReleasePlanColl) Create(args *models.ReleasePlan) (string, error)

+ func (c *ReleasePlanColl) DeleteByID(ctx context.Context, idString string) error

+ func (c *ReleasePlanColl) EnsureIndex(ctx context.Context) error

+ func (c *ReleasePlanColl) GetByID(ctx context.Context, idString string) (*models.ReleasePlan, error)

+ func (c *ReleasePlanColl) GetCollectionName() string

+ func (c *ReleasePlanColl) ListByOptions(opt *ListReleasePlanOption) ([]*models.ReleasePlan, int64, error)

+ func (c *ReleasePlanColl) UpdateByID(ctx context.Context, idString string, args *models.ReleasePlan) error

+ type ReleasePlanLogColl struct

+ func NewReleasePlanLogColl() *ReleasePlanLogColl

+ func (c *ReleasePlanLogColl) Create(args *models.ReleasePlanLog) error

+ func (c *ReleasePlanLogColl) EnsureIndex(ctx context.Context) error

+ func (c *ReleasePlanLogColl) GetCollectionName() string

+ func (c *ReleasePlanLogColl) ListByOptions(opt *ListReleasePlanLogOption) ([]*models.ReleasePlanLog, error)

type RenderSetFindOption

+ EnvName string

+ IsDefault bool

+ ProductTmpl string

+ YamlVariableSetID string

type S3StorageColl

+ func (c *S3StorageColl) FindByProject(projectName string) ([]*models.S3Storage, error)

+ func (c *S3StorageColl) InitData() error

+ type ScanningColl struct

+ func NewScanningColl() *ScanningColl

+ func (c *ScanningColl) Create(scanning *models.Scanning) error

+ func (c *ScanningColl) DeleteByID(idstring string) error

+ func (c *ScanningColl) EnsureIndex(ctx context.Context) error

+ func (c *ScanningColl) Find(projectName, name string) (*models.Scanning, error)

+ func (c *ScanningColl) GetByID(idstring string) (*models.Scanning, error)

+ func (c *ScanningColl) GetCollectionName() string

+ func (c *ScanningColl) List(listOption *ScanningListOption, pageNum, pageSize int64) ([]*models.Scanning, int64, error)

+ func (c *ScanningColl) Update(idString string, scanning *models.Scanning) error

+ type ScanningListOption struct

+ ProjectName string

+ ScanningNames []string

type ServiceColl

+ func (c *ServiceColl) GetChartTemplateReference(templateName string) ([]*models.Service, error)

+ func (c *ServiceColl) GetYamlTemplateLatestReference(templateID string) ([]*models.Service, error)

+ func (c *ServiceColl) GetYamlTemplateReference(templateID string) ([]*models.Service, error)

+ func (c *ServiceColl) ListMaxRevisionsAllSvcByProduct(productName string) ([]*models.Service, error)

+ func (c *ServiceColl) ListServiceAllRevisionsAndStatus(serviceName, productName string) ([]*models.Service, error)

+ func (c *ServiceColl) ListServicesWithSRevision(opt *SvcRevisionListOption) ([]*models.Service, error)

+ func (c *ServiceColl) SearchMaxRevisionsByService(serviceName string) ([]*models.Service, error)

+ func (c *ServiceColl) TransferServiceSource(productName, serviceName, source, newSource, username, yaml string) error

+ func (c *ServiceColl) UpdateServiceContainers(args *models.Service) error

+ func (c *ServiceColl) UpdateServiceVariables(args *models.Service) error

type ServiceFindOption

+ IgnoreNoDocumentErr bool

+ type ServiceModule struct

+ CodeInfo []*types.Repository

+ ServiceModule string

+ ServiceName string

+ type ServiceRevision struct

+ Revision int64

+ ServiceName string

+ type SetCustomFieldsOptions struct

+ ProjectName string

+ WorkflowName string

+ type SonarIntegrationColl struct

+ func NewSonarIntegrationColl() *SonarIntegrationColl

+ func (c *SonarIntegrationColl) Create(ctx context.Context, args *models.SonarIntegration) error

+ func (c *SonarIntegrationColl) DeleteByID(ctx context.Context, idstring string) error

+ func (c *SonarIntegrationColl) EnsureIndex(ctx context.Context) error

+ func (c *SonarIntegrationColl) GetByID(ctx context.Context, idstring string) (*models.SonarIntegration, error)

+ func (c *SonarIntegrationColl) GetBySystemIdentity(systemIdentity string) (*models.SonarIntegration, error)

+ func (c *SonarIntegrationColl) GetCollectionName() string

+ func (c *SonarIntegrationColl) List(ctx context.Context, pageNum, pageSize int64) ([]*models.SonarIntegration, int64, error)

+ func (c *SonarIntegrationColl) Update(ctx context.Context, idString string, obj *models.SonarIntegration) error

+ type StatDashboardConfigColl struct

+ func NewStatDashboardConfigColl() *StatDashboardConfigColl

+ func (c *StatDashboardConfigColl) BulkCreate(ctx context.Context, args []*models.StatDashboardConfig) error

+ func (c *StatDashboardConfigColl) Create(ctx context.Context, args *models.StatDashboardConfig) error

+ func (c *StatDashboardConfigColl) Delete(ctx context.Context, key string) error

+ func (c *StatDashboardConfigColl) EnsureIndex(ctx context.Context) error

+ func (c *StatDashboardConfigColl) FindByOptions(opts *ConfigOption) (*models.StatDashboardConfig, error)

+ func (c *StatDashboardConfigColl) GetCollectionName() string

+ func (c *StatDashboardConfigColl) List() ([]*models.StatDashboardConfig, error)

+ func (c *StatDashboardConfigColl) Update(ctx context.Context, key string, args *models.StatDashboardConfig) error

+ type SvcRevisionListOption struct

+ ProductName string

+ ServiceRevisions []*ServiceRevision

+ type SystemSettingColl struct

+ func NewSystemSettingColl() *SystemSettingColl

+ func (c *SystemSettingColl) CreateOrUpdate(id string, args *models.SystemSetting) error

+ func (c *SystemSettingColl) EnsureIndex(ctx context.Context) error

+ func (c *SystemSettingColl) Get() (*models.SystemSetting, error)

+ func (c *SystemSettingColl) GetCollectionName() string

+ func (c *SystemSettingColl) InitSystemSettings() error

+ func (c *SystemSettingColl) UpdateConcurrencySetting(workflowConcurrency, buildConcurrency int64) error

+ func (c *SystemSettingColl) UpdateDefaultLoginSetting(defaultLogin string) error

+ func (c *SystemSettingColl) UpdatePrivacySetting(improvementPlan bool) error

+ func (c *SystemSettingColl) UpdateSecuritySetting(tokenExpirationTime int64) error

+ func (c *SystemSettingColl) UpdateTheme(theme *models.Theme) error

type TaskColl

+ func (c *TaskColl) ListByCursor(option *ListAllTaskOption) (*mongo.Cursor, error)

+ func (c *TaskColl) ListPreview(pipelineNames []string) (ret []*TaskPreview, err error)

type TaskPreview

+ ServiceModules []*ServiceModule

type TestTaskStatColl

+ func (c *TestTaskStatColl) GetTestTasks(startTime, endTime int64) ([]*models.TestTaskStat, error)

+ type VariableSetColl struct

+ func NewVariableSetColl() *VariableSetColl

+ func (c *VariableSetColl) Create(args *models.VariableSet) error

+ func (c *VariableSetColl) Delete(id string) error

+ func (c *VariableSetColl) EnsureIndex(ctx context.Context) error

+ func (c *VariableSetColl) Find(opt *VariableSetFindOption) (*models.VariableSet, error)

+ func (c *VariableSetColl) GetCollectionName() string

+ func (c *VariableSetColl) List(option *VariableSetFindOption) (int64, []*models.VariableSet, error)

+ func (c *VariableSetColl) Update(id string, args *models.VariableSet) error

+ type VariableSetFindOption struct

+ ID string

+ Page int

+ PerPage int

+ ProjectName string

+ type WorkFlowOptions struct

+ ProjectName string

+ WorkflowName string

+ type WorkFlowTaskFilter struct

+ Creator []string

+ EndTime int64

+ Env []string

+ JobName string

+ ProjectName string

+ Service []string

+ StartTime int64

+ Status []string

+ WorkflowName string

+ type Workflow struct

+ Name string

+ ProjectName string

type WorkflowColl

+ func (c *WorkflowColl) BulkCreate(args []*models.Workflow) error

+ func (c *WorkflowColl) ListByCursor(opt *ListWorkflowOption) (*mongo.Cursor, error)

+ func (c *WorkflowColl) ListByWorkflows(opt ListWorkflowOpt) ([]*models.Workflow, error)

+ type WorkflowQueueColl struct

+ func NewWorkflowQueueColl() *WorkflowQueueColl

+ func (c *WorkflowQueueColl) Create(args *models.WorkflowQueue) error

+ func (c *WorkflowQueueColl) Delete(args *models.WorkflowQueue) error

+ func (c *WorkflowQueueColl) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowQueueColl) GetCollectionName() string

+ func (c *WorkflowQueueColl) List(opt *ListWorfklowQueueOption) ([]*models.WorkflowQueue, error)

+ func (c *WorkflowQueueColl) Update(args *models.WorkflowQueue) error

+ type WorkflowTaskv4Coll struct

+ func NewworkflowTaskv4Coll() *WorkflowTaskv4Coll

+ func (c *WorkflowTaskv4Coll) ArchiveHistoryWorkflowTask(workflowName string, remain, remainDays int) error

+ func (c *WorkflowTaskv4Coll) Create(obj *models.WorkflowTask) (string, error)

+ func (c *WorkflowTaskv4Coll) DeleteByWorkflowName(workflowName string) error

+ func (c *WorkflowTaskv4Coll) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowTaskv4Coll) Find(workflowName string, taskID int64) (*models.WorkflowTask, error)

+ func (c *WorkflowTaskv4Coll) FindPreviousTask(workflowName, username string) (*models.WorkflowTask, error)

+ func (c *WorkflowTaskv4Coll) FindTodoTasksByWorkflowName(workflowName string) ([]*models.WorkflowTask, error)

+ func (c *WorkflowTaskv4Coll) GetByID(idstring string) (*models.WorkflowTask, error)

+ func (c *WorkflowTaskv4Coll) GetCollectionName() string

+ func (c *WorkflowTaskv4Coll) GetLatest(workflowName string) (*models.WorkflowTask, error)

+ func (c *WorkflowTaskv4Coll) InCompletedTasks() ([]*models.WorkflowTask, error)

+ func (c *WorkflowTaskv4Coll) List(opt *ListWorkflowTaskV4Option) ([]*models.WorkflowTask, int64, error)

+ func (c *WorkflowTaskv4Coll) ListByCursor(opt *ListWorkflowTaskV4Option) (*mongo.Cursor, error)

+ func (c *WorkflowTaskv4Coll) ListByFilter(filter *WorkFlowTaskFilter, pageNum, pageSize int64) ([]*models.WorkflowTask, int64, error)

+ func (c *WorkflowTaskv4Coll) ListCreator(projectName, name string) ([]string, error)

+ func (c *WorkflowTaskv4Coll) Update(idString string, obj *models.WorkflowTask) error

+ type WorkflowTemplateListOption struct

+ Category string

+ CreatedBy string

+ ExcludeBuildIn bool

+ type WorkflowTemplateQueryOption struct

+ ID string

+ Name string

+ type WorkflowV4 struct

+ Name string

+ ProjectName string

+ type WorkflowV4Coll struct

+ func NewWorkflowV4Coll() *WorkflowV4Coll

+ func (c *WorkflowV4Coll) BulkCreate(args []*models.WorkflowV4) error

+ func (c *WorkflowV4Coll) Count() (int64, error)

+ func (c *WorkflowV4Coll) Create(obj *models.WorkflowV4) (string, error)

+ func (c *WorkflowV4Coll) DeleteByID(idString string) error

+ func (c *WorkflowV4Coll) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowV4Coll) Find(name string) (*models.WorkflowV4, error)

+ func (c *WorkflowV4Coll) FindByOptions(opts WorkFlowOptions) (*models.WorkflowV4, error)

+ func (c *WorkflowV4Coll) GetByID(idstring string) (*models.WorkflowV4, error)

+ func (c *WorkflowV4Coll) GetCollectionName() string

+ func (c *WorkflowV4Coll) GetJobNameList(projectName, workflowName, jobType string) ([]string, error)

+ func (c *WorkflowV4Coll) List(opt *ListWorkflowV4Option, pageNum, pageSize int64) ([]*models.WorkflowV4, int64, error)

+ func (c *WorkflowV4Coll) ListByCursor(opt *ListWorkflowV4Option) (*mongo.Cursor, error)

+ func (c *WorkflowV4Coll) ListByProjectNames(projects []string) ([]*models.WorkflowV4, error)

+ func (c *WorkflowV4Coll) ListByWorkflows(opt ListWorkflowV4Opt) ([]*models.WorkflowV4, error)

+ func (c *WorkflowV4Coll) SetCustomFields(opts SetCustomFieldsOptions, args *models.CustomField) error

+ func (c *WorkflowV4Coll) Update(idString string, obj *models.WorkflowV4) error

+ type WorkflowV4TemplateColl struct

+ func NewWorkflowV4TemplateColl() *WorkflowV4TemplateColl

+ func (c *WorkflowV4TemplateColl) Create(obj *models.WorkflowV4Template) error

+ func (c *WorkflowV4TemplateColl) DeleteByID(idStr string) error

+ func (c *WorkflowV4TemplateColl) DeleteInternalByName(name string) error

+ func (c *WorkflowV4TemplateColl) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowV4TemplateColl) Find(opt *WorkflowTemplateQueryOption) (*models.WorkflowV4Template, error)

+ func (c *WorkflowV4TemplateColl) GetCollectionName() string

+ func (c *WorkflowV4TemplateColl) List(option *WorkflowTemplateListOption) ([]*models.WorkflowV4Template, error)

+ func (c *WorkflowV4TemplateColl) ListByCursor(opt *ListWorkflowV4TemplateOption) (*mongo.Cursor, error)

+ func (c *WorkflowV4TemplateColl) Update(obj *models.WorkflowV4Template) error

+ func (c *WorkflowV4TemplateColl) UpsertByName(obj *models.WorkflowV4Template) error

+ type WorkflowViewColl struct

+ func NewWorkflowViewColl() *WorkflowViewColl

+ func (c *WorkflowViewColl) Create(args *models.WorkflowView) error

+ func (c *WorkflowViewColl) DeleteByID(idString string) error

+ func (c *WorkflowViewColl) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowViewColl) Find(projectName, viewName string) (*models.WorkflowView, error)

+ func (c *WorkflowViewColl) FindByID(idString string) (*models.WorkflowView, error)

+ func (c *WorkflowViewColl) GetCollectionName() string

+ func (c *WorkflowViewColl) ListByProject(projectName string) ([]*models.WorkflowView, error)

+ func (c *WorkflowViewColl) ListNamesByProject(projectName string) ([]string, error)

+ func (c *WorkflowViewColl) Update(args *models.WorkflowView) error

type YamlTemplateColl

+ func (c *YamlTemplateColl) GetByName(name string) (*models.YamlTemplate, error)

+ func (c *YamlTemplateColl) UpdateVariable(idString string, variable string, ...) error

v1.9.0

Jan 27, 2022

Changes in this version

type CountTaskOption

+ Committers []string

+ Statuses []string

+ TaskCreators []string

type K8SClusterColl

+ func (c *K8SClusterColl) Count() (int64, error)

type ListTaskOption

+ Committers []string

+ Statuses []string

+ TaskCreators []string

type ProductColl

+ func (c *ProductColl) EnvCount() (int64, error)

+ type ServiceAggregateResult struct

+ ServiceID primitive.ObjectID

type ServiceColl

+ func (c *ServiceColl) ListMaxRevisionsByProject(serviceName, serviceType string) ([]*models.Service, error)

type TaskColl

+ func (c *TaskColl) DistinctFieldsPipelineTask(fieldName, projectName, pipelineName string, typeString config.PipelineType, ...) ([]interface{}, error)

type WorkflowColl

+ func (c *WorkflowColl) Count() (int64, error)

v1.8.0

Jan 7, 2022

Changes in this version

+ func IsErrNoDocuments(err error) bool

+ type CallbackFindOption struct

+ PipelineName string

+ ProjectName string

+ TaskID int64

+ type CallbackRequestColl struct

+ func NewCallbackRequestColl() *CallbackRequestColl

+ func (c *CallbackRequestColl) Create(req *models.CallbackRequest) error

+ func (c *CallbackRequestColl) EnsureIndex(ctx context.Context) error

+ func (c *CallbackRequestColl) Find(req *CallbackFindOption) (*models.CallbackRequest, error)

+ func (c *CallbackRequestColl) GetCollectionName() string

+ type ChartColl struct

+ func NewChartColl() *ChartColl

+ func (c *ChartColl) Create(obj *models.Chart) error

+ func (c *ChartColl) Delete(name string) error

+ func (c *ChartColl) EnsureIndex(ctx context.Context) error

+ func (c *ChartColl) Exist(name string) bool

+ func (c *ChartColl) Get(name string) (*models.Chart, error)

+ func (c *ChartColl) GetCollectionName() string

+ func (c *ChartColl) List() ([]*models.Chart, error)

+ func (c *ChartColl) Update(obj *models.Chart) error

type DeliveryDistributeArgs

+ ChartName string

type DeliveryVersionArgs

+ Version string

type DeliveryVersionColl

+ func (c *DeliveryVersionColl) UpdateStatusByName(versionName, projectName, status, errorStr string) error

+ func (c *DeliveryVersionColl) UpdateTaskID(versionName, projectName string, taskID int32) error

+ type DockerfileTemplateColl struct

+ func NewDockerfileTemplateColl() *DockerfileTemplateColl

+ func (c *DockerfileTemplateColl) Create(obj *models.DockerfileTemplate) error

+ func (c *DockerfileTemplateColl) DeleteByID(idstring string) error

+ func (c *DockerfileTemplateColl) EnsureIndex(ctx context.Context) error

+ func (c *DockerfileTemplateColl) GetById(idstring string) (*models.DockerfileTemplate, error)

+ func (c *DockerfileTemplateColl) GetCollectionName() string

+ func (c *DockerfileTemplateColl) List(pageNum, pageSize int) ([]*models.DockerfileTemplate, int, error)

+ func (c *DockerfileTemplateColl) Update(idString string, obj *models.DockerfileTemplate) error

+ type ExternalSystemColl struct

+ func NewExternalSystemColl() *ExternalSystemColl

+ func (c *ExternalSystemColl) Create(args *models.ExternalSystem) error

+ func (c *ExternalSystemColl) DeleteByID(idstring string) error

+ func (c *ExternalSystemColl) EnsureIndex(ctx context.Context) error

+ func (c *ExternalSystemColl) GetByID(idstring string) (*models.ExternalSystem, error)

+ func (c *ExternalSystemColl) GetCollectionName() string

+ func (c *ExternalSystemColl) List(pageNum, pageSize int64) ([]*models.ExternalSystem, int64, error)

+ func (c *ExternalSystemColl) Update(idString string, obj *models.ExternalSystem) error

type HelmRepoColl

+ func (c *HelmRepoColl) Find(opt *HelmRepoFindOption) (*models.HelmRepo, error)

+ type HelmRepoFindOption struct

+ Id string

+ RepoName string

+ type ListWorkflowV3Option struct

+ ProjectName string

type ProductColl

+ func (c *ProductColl) UpdateRegistry(envName, productName, registryId string) error

type ProductFindOptions

+ Namespace string

+ type ProjectClusterRelationColl struct

+ func NewProjectClusterRelationColl() *ProjectClusterRelationColl

+ func (c *ProjectClusterRelationColl) Create(args *models.ProjectClusterRelation) error

+ func (c *ProjectClusterRelationColl) Delete(opt *ProjectClusterRelationOption) error

+ func (c *ProjectClusterRelationColl) EnsureIndex(ctx context.Context) error

+ func (c *ProjectClusterRelationColl) GetCollectionName() string

+ func (c *ProjectClusterRelationColl) List(opt *ProjectClusterRelationOption) ([]*models.ProjectClusterRelation, error)

+ type ProjectClusterRelationOption struct

+ ClusterID string

+ ProjectName string

type RenderSetColl

+ func (c *RenderSetColl) ListRendersets(opt *RenderSetListOption) ([]*models.RenderSet, error)

type RenderSetListOption

+ RendersetName string

+ Revisions []int64

type ServiceColl

+ func (c *ServiceColl) UpdateServiceHealthCheckStatus(args *models.Service) error

+ type WorkflowV3Coll struct

+ func NewWorkflowV3Coll() *WorkflowV3Coll

+ func (c *WorkflowV3Coll) Create(obj *models.WorkflowV3) (string, error)

+ func (c *WorkflowV3Coll) DeleteByID(idString string) error

+ func (c *WorkflowV3Coll) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowV3Coll) Find(name string) (*models.WorkflowV3, error)

+ func (c *WorkflowV3Coll) GetByID(idstring string) (*models.WorkflowV3, error)

+ func (c *WorkflowV3Coll) GetCollectionName() string

+ func (c *WorkflowV3Coll) List(opt *ListWorkflowV3Option, pageNum, pageSize int64) ([]*models.WorkflowV3, int64, error)

+ func (c *WorkflowV3Coll) Update(idString string, obj *models.WorkflowV3) error

v1.7.1

Dec 8, 2021

Changes in this version

+ type ClusterListOpts struct

+ IDs []string

type K8SClusterColl

+ func (c *K8SClusterColl) List(opts *ClusterListOpts) ([]*models.K8SCluster, error)

type ListTaskOption

+ PipelineNames []string

type ListWorkflowOption

+ Projects []string

type ProductListOptions

+ InEnvs []string

type TaskColl

+ func (c *TaskColl) ListRecentTasks(args *ListTaskOption) ([]*TaskInfo, error)

+ type TaskInfo struct

+ ID taskGrouped

+ PipelineName string

+ Status string

+ TaskID int64

type WorkflowStatArgs

+ Names []string

v1.7.0

Nov 16, 2021

Changes in this version

+ type ExternalLinkColl struct

+ func NewExternalLinkColl() *ExternalLinkColl

+ func (c *ExternalLinkColl) Create(args *models.ExternalLink) error

+ func (c *ExternalLinkColl) Delete(id string) error

+ func (c *ExternalLinkColl) EnsureIndex(ctx context.Context) error

+ func (c *ExternalLinkColl) GetCollectionName() string

+ func (c *ExternalLinkColl) List() ([]*models.ExternalLink, error)

+ func (c *ExternalLinkColl) Update(id string, args *models.ExternalLink) error

type ProductColl

+ func (c *ProductColl) ListProjectsInNames(names []string) ([]*projectEnvs, error)

type ProductListOptions

+ IsSortByProductName bool

+ IsSortByUpdateTime bool

type ServiceColl

+ func (c *ServiceColl) UpdateExternalServiceEnvName(serviceName, productName, envName string) error

type WebHookColl

+ func (c *WebHookColl) List() ([]*models.WebHook, error)

type WorkflowColl

+ func (c *WorkflowColl) ListWorkflowsByProjects(projects []string) ([]*models.Workflow, error)

v1.6.0

Nov 5, 2021

Changes in this version

type BuildColl

+ func (c *BuildColl) GetDockerfileTemplateReference(templateID string) ([]*models.Build, error)

type DeliveryArtifactArgs

+ PackageStorageURI string

type DeliveryArtifactColl

+ func (c *DeliveryArtifactColl) ListTars(args *DeliveryArtifactArgs) ([]*models.DeliveryArtifact, error)

+ type ListHostIPArgs struct

+ IDs []string

+ Labels []string

type PrivateKeyColl

+ func (c *PrivateKeyColl) DeleteAll() error

+ func (c *PrivateKeyColl) DistinctLabels() ([]string, error)

+ func (c *PrivateKeyColl) ListHostIPByArgs(args *ListHostIPArgs) ([]*models.PrivateKey, error)

type ServiceColl

+ func (c *ServiceColl) BatchUpdateExternalServicesStatus(productName, envName, status string, serviceNames []string) error

+ func (c *ServiceColl) GetTemplateReference(templateID string) ([]*models.Service, error)

+ type ServicesInExternalEnvArgs struct

+ ClusterID string

+ EnvName string

+ ExcludeEnvName string

+ Namespace string

+ ProductName string

+ ServiceName string

+ type ServicesInExternalEnvColl struct

+ func NewServicesInExternalEnvColl() *ServicesInExternalEnvColl

+ func (c *ServicesInExternalEnvColl) Create(args *models.ServicesInExternalEnv) error

+ func (c *ServicesInExternalEnvColl) Delete(args *ServicesInExternalEnvArgs) error

+ func (c *ServicesInExternalEnvColl) EnsureIndex(ctx context.Context) error

+ func (c *ServicesInExternalEnvColl) GetCollectionName() string

+ func (c *ServicesInExternalEnvColl) List(args *ServicesInExternalEnvArgs) ([]*models.ServicesInExternalEnv, error)

+ type YamlTemplateColl struct

+ func NewYamlTemplateColl() *YamlTemplateColl

+ func (c *YamlTemplateColl) Create(obj *models.YamlTemplate) error

+ func (c *YamlTemplateColl) DeleteByID(idstring string) error

+ func (c *YamlTemplateColl) EnsureIndex(ctx context.Context) error

+ func (c *YamlTemplateColl) GetById(idstring string) (*models.YamlTemplate, error)

+ func (c *YamlTemplateColl) GetCollectionName() string

+ func (c *YamlTemplateColl) List(pageNum, pageSize int) ([]*models.YamlTemplate, int, error)

+ func (c *YamlTemplateColl) Update(idString string, obj *models.YamlTemplate) error

v1.5.0

Sep 29, 2021

Changes in this version

type ProductColl

+ func (c *ProductColl) ListProjects() ([]*projectEnvs, error)

type ServiceColl

+ func (c *ServiceColl) ListExternalWorkloadsBy(productName, envName string) ([]*models.Service, error)

+ func (c *ServiceColl) UpdateExternalServicesStatus(serviceName, productName, status, envName string) error

+ type WorkLoadsStatColl struct

+ func NewWorkLoadsStatColl() *WorkLoadsStatColl

+ func (c *WorkLoadsStatColl) Create(args *models.WorkloadStat) error

+ func (c *WorkLoadsStatColl) EnsureIndex(ctx context.Context) error

+ func (c *WorkLoadsStatColl) Find(clusterID string, namespace string) (*models.WorkloadStat, error)

+ func (c *WorkLoadsStatColl) FindByProductName(productName string) ([]*models.WorkloadStat, error)

+ func (c *WorkLoadsStatColl) GetCollectionName() string

+ func (c *WorkLoadsStatColl) UpdateWorkloads(args *models.WorkloadStat) error

v1.4.0

Sep 9, 2021

Changes in this version

+ type FindPrivateKeyOption struct

+ Address string

+ ID string

type ProductListOptions

+ InProjects []string

v1.3.1

Aug 13, 2021

Changes in this version

type ProductColl

+ func (c *ProductColl) Count(productName string) (int, error)

+ func (c *ProductColl) UpdateAll(envs []*models.Product) error

type ServiceColl

+ func (c *ServiceColl) Count(productName string) (int, error)

type ServiceListOption

+ ExcludeProject string

+ InServices []*templatemodels.ServiceInfo

+ NotInServices []*templatemodels.ServiceInfo

+ Source string

+ Type string

+ Visibility string

v1.3.0

Jul 29, 2021

Changes in this version

type ProductColl

+ func (c *ProductColl) UpdateRender(envName, productName string, render *models.RenderInfo) error

type RenderSetColl

+ func (c *RenderSetColl) DeleteRenderSet(productName, name string, revision int64) error

type ServiceColl

+ func (c *ServiceColl) ListMaxRevisionsByProduct(productName string) ([]*models.Service, error)

type WebHookColl

+ func (c *WebHookColl) Find(owner, repo, address string) (*models.WebHook, error)

+ func (c *WebHookColl) Update(owner, repo, address, hookID string) error

v1.2.0

Jul 6, 2021

Changes in this version

+ type BasicImageColl struct

+ func NewBasicImageColl() *BasicImageColl

+ func (c *BasicImageColl) Create(args *models.BasicImage) error

+ func (c *BasicImageColl) Delete(id string) error

+ func (c *BasicImageColl) EnsureIndex(ctx context.Context) error

+ func (c *BasicImageColl) Find(id string) (*models.BasicImage, error)

+ func (c *BasicImageColl) GetCollectionName() string

+ func (c *BasicImageColl) InitBasicImageData(basicImageInfos []*models.BasicImage)

+ func (c *BasicImageColl) List(opt *BasicImageOpt) ([]*models.BasicImage, error)

+ func (c *BasicImageColl) Update(id string, args *models.BasicImage) error

+ type BasicImageOpt struct

+ ImageFrom string

+ Label string

+ Value string

+ type BuildColl struct

+ func NewBuildColl() *BuildColl

+ func (c *BuildColl) Create(build *models.Build) error

+ func (c *BuildColl) Delete(name, version, productName string) error

+ func (c *BuildColl) DistinctTargets(excludeModule []string, productName string) (map[string]bool, error)

+ func (c *BuildColl) EnsureIndex(ctx context.Context) error

+ func (c *BuildColl) Find(opt *BuildFindOption) (*models.Build, error)

+ func (c *BuildColl) GetCollectionName() string

+ func (c *BuildColl) List(opt *BuildListOption) ([]*models.Build, error)

+ func (c *BuildColl) Update(build *models.Build) error

+ func (c *BuildColl) UpdateBuildParam(name, version, productName string, params []*models.Parameter) error

+ func (c *BuildColl) UpdateTargets(name, productName string, targets []*models.ServiceModuleTarget) error

+ type BuildFindOption struct

+ Name string

+ ProductName string

+ ServiceName string

+ Targets []string

+ Version string

+ type BuildListOption struct

+ BasicImageID string

+ BuildOS string

+ IsSort bool

+ Name string

+ PrivateKeyID string

+ ProductName string

+ ServiceName string

+ Targets []string

+ Version string

+ type ConfigColl struct

+ func NewConfigColl() *ConfigColl

+ func (c *ConfigColl) EnsureIndex(ctx context.Context) error

+ func (c *ConfigColl) Find(opt *ConfigFindOption) (*models.Config, error)

+ func (c *ConfigColl) GetCollectionName() string

+ func (c *ConfigColl) ListAllRevisions() ([]*models.Config, error)

+ func (c *ConfigColl) ListMaxRevisions(productName string) ([]*models.Config, error)

+ type ConfigFindOption struct

+ ConfigName string

+ ProductName string

+ Revision int64

+ ServiceName string

+ type CountTaskOption struct

+ PipelineNames []string

+ Status config.TaskStatus

+ Type config.PipelineType

+ type CounterColl struct

+ func NewCounterColl() *CounterColl

+ func (c *CounterColl) Delete(counterName string) error

+ func (c *CounterColl) EnsureIndex(_ context.Context) error

+ func (c *CounterColl) Find(name string) (*models.Counter, error)

+ func (c *CounterColl) GetCollectionName() string

+ func (c *CounterColl) GetNextSeq(counterName string) (int64, error)

+ func (c *CounterColl) Rename(oldName, newName string) error

+ func (c *CounterColl) SetToNumber(counterName string, number int64) error

+ type CronjobColl struct

+ func NewCronjobColl() *CronjobColl

+ func (c *CronjobColl) Create(args *models.Cronjob) error

+ func (c *CronjobColl) Delete(param *CronjobDeleteOption) error

+ func (c *CronjobColl) EnsureIndex(ctx context.Context) error

+ func (c *CronjobColl) GetCollectionName() string

+ func (c *CronjobColl) List(param *ListCronjobParam) ([]*models.Cronjob, error)

+ func (c *CronjobColl) ListActiveJob() ([]*models.Cronjob, error)

+ func (c *CronjobColl) Update(job *models.Cronjob) error

+ type CronjobDeleteOption struct

+ IDList []string

+ ParentName string

+ ParentType string

+ type DeliveryActivityArgs struct

+ ArtifactID string

+ Branch string

+ Page int

+ PerPage int

+ RepoName string

+ type DeliveryActivityColl struct

+ func NewDeliveryActivityColl() *DeliveryActivityColl

+ func (c *DeliveryActivityColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliveryActivityColl) GetCollectionName() string

+ func (c *DeliveryActivityColl) Insert(args *models.DeliveryActivity) error

+ func (c *DeliveryActivityColl) InsertWithID(id string, args *models.DeliveryActivity) error

+ func (c *DeliveryActivityColl) List(args *DeliveryActivityArgs) ([]*models.DeliveryActivity, int, error)

+ type DeliveryArtifactArgs struct

+ Branch string

+ ID string

+ Image string

+ ImageDigest string

+ ImageHash string

+ ImageTag string

+ IsFuzzyQuery bool

+ Name string

+ Page int

+ PerPage int

+ RepoName string

+ Source string

+ Type string

+ type DeliveryArtifactColl struct

+ func NewDeliveryArtifactColl() *DeliveryArtifactColl

+ func (c *DeliveryArtifactColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliveryArtifactColl) Get(args *DeliveryArtifactArgs) (*models.DeliveryArtifact, error)

+ func (c *DeliveryArtifactColl) GetCollectionName() string

+ func (c *DeliveryArtifactColl) Insert(args *models.DeliveryArtifact) error

+ func (c *DeliveryArtifactColl) List(args *DeliveryArtifactArgs) ([]*models.DeliveryArtifact, int, error)

+ func (c *DeliveryArtifactColl) Update(args *DeliveryArtifactArgs) error

+ type DeliveryBuildArgs struct

+ ID string

+ ReleaseID string

+ ServiceName string

+ type DeliveryBuildColl struct

+ func NewDeliveryBuildColl() *DeliveryBuildColl

+ func (c *DeliveryBuildColl) Delete(releaseID string) error

+ func (c *DeliveryBuildColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliveryBuildColl) Find(args *DeliveryBuildArgs) ([]*models.DeliveryBuild, error)

+ func (c *DeliveryBuildColl) GetCollectionName() string

+ func (c *DeliveryBuildColl) Insert(args *models.DeliveryBuild) error

+ type DeliveryDeployArgs struct

+ ID string

+ ReleaseID string

+ ServiceName string

+ type DeliveryDeployColl struct

+ func NewDeliveryDeployColl() *DeliveryDeployColl

+ func (c *DeliveryDeployColl) Delete(releaseID string) error

+ func (c *DeliveryDeployColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliveryDeployColl) Find(args *DeliveryDeployArgs) ([]*models.DeliveryDeploy, error)

+ func (c *DeliveryDeployColl) GetCollectionName() string

+ func (c *DeliveryDeployColl) Insert(args *models.DeliveryDeploy) error

+ type DeliveryDistributeArgs struct

+ DistributeType config.DistributeType

+ ID string

+ ReleaseID string

+ ServiceName string

+ type DeliveryDistributeColl struct

+ func NewDeliveryDistributeColl() *DeliveryDistributeColl

+ func (c *DeliveryDistributeColl) Delete(releaseID string) error

+ func (c *DeliveryDistributeColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliveryDistributeColl) Find(args *DeliveryDistributeArgs) ([]*models.DeliveryDistribute, error)

+ func (c *DeliveryDistributeColl) GetCollectionName() string

+ func (c *DeliveryDistributeColl) Insert(args *models.DeliveryDistribute) error

+ type DeliverySecurityArgs struct

+ ID string

+ ImageID string

+ ImageName string

+ Severity string

+ type DeliverySecurityColl struct

+ func NewDeliverySecurityColl() *DeliverySecurityColl

+ func (c *DeliverySecurityColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliverySecurityColl) Find(args *DeliverySecurityArgs) ([]*models.DeliverySecurity, error)

+ func (c *DeliverySecurityColl) FindStatistics(imageID string) (map[string]int, error)

+ func (c *DeliverySecurityColl) GetCollectionName() string

+ func (c *DeliverySecurityColl) Insert(args *models.DeliverySecurity) error

+ type DeliveryTestArgs struct

+ ID string

+ ReleaseID string

+ type DeliveryTestColl struct

+ func NewDeliveryTestColl() *DeliveryTestColl

+ func (c *DeliveryTestColl) Delete(releaseID string) error

+ func (c *DeliveryTestColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliveryTestColl) Find(args *DeliveryTestArgs) ([]*models.DeliveryTest, error)

+ func (c *DeliveryTestColl) GetCollectionName() string

+ func (c *DeliveryTestColl) Insert(args *models.DeliveryTest) error

+ type DeliveryVersionArgs struct

+ ID string

+ OrgID int

+ Page int

+ PerPage int

+ ProductName string

+ TaskID int

+ WorkflowName string

+ type DeliveryVersionColl struct

+ func NewDeliveryVersionColl() *DeliveryVersionColl

+ func (c *DeliveryVersionColl) Delete(id string) error

+ func (c *DeliveryVersionColl) EnsureIndex(ctx context.Context) error

+ func (c *DeliveryVersionColl) Find(args *DeliveryVersionArgs) ([]*models.DeliveryVersion, error)

+ func (c *DeliveryVersionColl) FindProducts(orgID int) ([]string, error)

+ func (c *DeliveryVersionColl) Get(args *DeliveryVersionArgs) (*models.DeliveryVersion, error)

+ func (c *DeliveryVersionColl) GetCollectionName() string

+ func (c *DeliveryVersionColl) Insert(args *models.DeliveryVersion) error

+ func (c *DeliveryVersionColl) ListDeliveryVersions(productName string, orgID int) ([]*models.DeliveryVersion, error)

+ func (c *DeliveryVersionColl) Update(args *models.DeliveryVersion) error

+ type DiffNoteColl struct

+ func NewDiffNoteColl() *DiffNoteColl

+ func (c *DiffNoteColl) Create(args *models.DiffNote) error

+ func (c *DiffNoteColl) EnsureIndex(ctx context.Context) error

+ func (c *DiffNoteColl) Find(opt *DiffNoteFindOpt) (*models.DiffNote, error)

+ func (c *DiffNoteColl) GetCollectionName() string

+ func (c *DiffNoteColl) Update(id, commitID, body string, resolved bool) error

+ type DiffNoteFindOpt struct

+ CodehostID int

+ MergeRequestID int

+ ProjectID string

+ type DindCleanColl struct

+ func NewDindCleanColl() *DindCleanColl

+ func (c *DindCleanColl) EnsureIndex(ctx context.Context) error

+ func (c *DindCleanColl) GetCollectionName() string

+ func (c *DindCleanColl) List() ([]*models.DindClean, error)

+ func (c *DindCleanColl) Upsert(args *models.DindClean) error

+ type FavoriteArgs struct

+ Name string

+ ProductName string

+ Type string

+ UserID int

+ type FavoriteColl struct

+ func NewFavoriteColl() *FavoriteColl

+ func (c *FavoriteColl) Create(args *models.Favorite) error

+ func (c *FavoriteColl) Delete(args *FavoriteArgs) error

+ func (c *FavoriteColl) EnsureIndex(ctx context.Context) error

+ func (c *FavoriteColl) Find(userID int, name, Type string) (*models.Favorite, error)

+ func (c *FavoriteColl) GetCollectionName() string

+ func (c *FavoriteColl) List(args *FavoriteArgs) ([]*models.Favorite, error)

+ type FindRegOps struct

+ ID string

+ IsDefault bool

+ Namespace string

+ OrgID int

+ RegAddr string

+ RegProvider string

+ RegType string

+ type FindTaskOption struct

+ PipelineName string

+ Status config.Status

+ Type config.PipelineType

+ type GithubAppColl struct

+ func NewGithubAppColl() *GithubAppColl

+ func (c *GithubAppColl) Create(args *models.GithubApp) error

+ func (c *GithubAppColl) Delete(id string) error

+ func (c *GithubAppColl) EnsureIndex(ctx context.Context) error

+ func (c *GithubAppColl) Find() ([]*models.GithubApp, error)

+ func (c *GithubAppColl) GetCollectionName() string

+ func (c *GithubAppColl) Upsert(args *models.GithubApp) error

+ type HelmRepoColl struct

+ func NewHelmRepoColl() *HelmRepoColl

+ func (c *HelmRepoColl) Create(args *models.HelmRepo) error

+ func (c *HelmRepoColl) Delete(id string) error

+ func (c *HelmRepoColl) EnsureIndex(ctx context.Context) error

+ func (c *HelmRepoColl) GetCollectionName() string

+ func (c *HelmRepoColl) List() ([]*models.HelmRepo, error)

+ func (c *HelmRepoColl) Update(id string, args *models.HelmRepo) error

+ type InstallColl struct

+ func NewInstallColl() *InstallColl

+ func (c *InstallColl) Create(args *models.Install) error

+ func (c *InstallColl) Delete(name, version string) error

+ func (c *InstallColl) EnsureIndex(ctx context.Context) error

+ func (c *InstallColl) Find(name, version string) (*models.Install, error)

+ func (c *InstallColl) GetCollectionName() string

+ func (c *InstallColl) InitInstallData(installInfoPreset map[string]*models.Install) error

+ func (c *InstallColl) List() ([]*models.Install, error)

+ func (c *InstallColl) Update(name, version string, args *models.Install) error

+ func (c *InstallColl) UpdateSystemDefault(name, version string, installInfoPreset map[string]*models.Install) error

+ type ItReportColl struct

+ func NewItReportColl() *ItReportColl

+ func (c *ItReportColl) EnsureIndex(ctx context.Context) error

+ func (c *ItReportColl) GetCollectionName() string

+ func (c *ItReportColl) Upsert(args *models.ItReport) error

+ type JenkinsIntegrationColl struct

+ func NewJenkinsIntegrationColl() *JenkinsIntegrationColl

+ func (c *JenkinsIntegrationColl) Create(args *models.JenkinsIntegration) error

+ func (c *JenkinsIntegrationColl) Delete(ID string) error

+ func (c *JenkinsIntegrationColl) EnsureIndex(ctx context.Context) error

+ func (c *JenkinsIntegrationColl) GetCollectionName() string

+ func (c *JenkinsIntegrationColl) List() ([]*models.JenkinsIntegration, error)

+ func (c *JenkinsIntegrationColl) Update(ID string, args *models.JenkinsIntegration) error

+ type K8SClusterColl struct

+ func NewK8SClusterColl() *K8SClusterColl

+ func (c *K8SClusterColl) Create(cluster *models.K8SCluster) error

+ func (c *K8SClusterColl) Delete(id string) error

+ func (c *K8SClusterColl) EnsureIndex(_ context.Context) error

+ func (c *K8SClusterColl) Find(clusterType string) ([]*models.K8SCluster, error)

+ func (c *K8SClusterColl) FindByName(name string) (*models.K8SCluster, error)

+ func (c *K8SClusterColl) FindConnectedClusters() ([]*models.K8SCluster, error)

+ func (c *K8SClusterColl) Get(id string) (*models.K8SCluster, error)

+ func (c *K8SClusterColl) GetByToken(token string) (*models.K8SCluster, error)

+ func (c *K8SClusterColl) GetCollectionName() string

+ func (c *K8SClusterColl) HasDuplicateName(id, name string) (bool, error)

+ func (c *K8SClusterColl) Update(cluster *models.K8SCluster) error

+ func (c *K8SClusterColl) UpdateConnectState(id string, disconnected bool) error

+ func (c *K8SClusterColl) UpdateMutableFields(cluster *models.K8SCluster) error

+ func (c *K8SClusterColl) UpdateStatus(cluster *models.K8SCluster) error

+ type ListAllTaskOption struct

+ BeforeCreatTime bool

+ CreateTime int64

+ Limit int

+ PipelineName string

+ ProductName string

+ ProductNames []string

+ Skip int

+ Type config.PipelineType

+ type ListCronjobParam struct

+ ParentName string

+ ParentType string

+ type ListQueueOption struct

+ MergeRequestID string

+ PipelineName string

+ Status config.Status

+ type ListStatsOption struct

+ Event string

+ Limit int

+ ProductName string

+ type ListTaskOption struct

+ CreateTime int64

+ Detail bool

+ Limit int

+ MergeRequestID string

+ NeedAllData bool

+ NeedTriggerBy bool

+ PipelineName string

+ Skip int

+ Source string

+ Status config.Status

+ TaskCreator string

+ Team string

+ TeamID int

+ Type config.PipelineType

+ type ListTestOption struct

+ BasicImageID string

+ BuildOS string

+ IsSort bool

+ ProductName string

+ TestType string

+ type ListWorkflowOption struct

+ IsSort bool

+ ProductName string

+ TestName string

+ type NotificationColl struct

+ func NewNotificationColl() *NotificationColl

+ func (c *NotificationColl) Create(args *models.Notification) error

+ func (c *NotificationColl) EnsureIndex(_ context.Context) error

+ func (c *NotificationColl) Find(id string) (*models.Notification, error)

+ func (c *NotificationColl) GetCollectionName() string

+ func (c *NotificationColl) Upsert(args *models.Notification) error

+ type NotifyColl struct

+ func NewNotifyColl() *NotifyColl

+ func (c *NotifyColl) Create(args *models.Notify) error

+ func (c *NotifyColl) DeleteByID(id string) error

+ func (c *NotifyColl) DeleteByTime(expireTime int64) error

+ func (c *NotifyColl) EnsureIndex(_ context.Context) error

+ func (c *NotifyColl) GetCollectionName() string

+ func (c *NotifyColl) List(receiver string) ([]*models.Notify, error)

+ func (c *NotifyColl) Read(id string) error

+ func (c *NotifyColl) Update(id string, args *models.Notify) error

+ type PipelineColl struct

+ func NewPipelineColl() *PipelineColl

+ func (c *PipelineColl) Delete(name string) error

+ func (c *PipelineColl) EnsureIndex(ctx context.Context) error

+ func (c *PipelineColl) Find(opt *PipelineFindOption) (*models.Pipeline, error)

+ func (c *PipelineColl) GetCollectionName() string

+ func (c *PipelineColl) List(opt *PipelineListOption) ([]*models.Pipeline, error)

+ func (c *PipelineColl) Rename(oldName, newName string) error

+ func (c *PipelineColl) Upsert(args *models.Pipeline) error

+ type PipelineFindOption struct

+ IsDeleted bool

+ Name string

+ type PipelineListOption struct

+ BuildModuleVer string

+ IsDeleted bool

+ IsPreview bool

+ ProductName string

+ Targets []string

+ TeamName []string

+ Teams []string

+ type PrivateKeyArgs struct

+ Name string

+ type PrivateKeyColl struct

+ func NewPrivateKeyColl() *PrivateKeyColl

+ func (c *PrivateKeyColl) Create(args *models.PrivateKey) error

+ func (c *PrivateKeyColl) Delete(id string) error

+ func (c *PrivateKeyColl) EnsureIndex(ctx context.Context) error

+ func (c *PrivateKeyColl) Find(id string) (*models.PrivateKey, error)

+ func (c *PrivateKeyColl) GetCollectionName() string

+ func (c *PrivateKeyColl) List(args *PrivateKeyArgs) ([]*models.PrivateKey, error)

+ func (c *PrivateKeyColl) Update(id string, args *models.PrivateKey) error

+ type ProductColl struct

+ func NewProductColl() *ProductColl

+ func (c *ProductColl) Create(args *models.Product) error

+ func (c *ProductColl) Delete(owner, productName string) error

+ func (c *ProductColl) EnsureIndex(ctx context.Context) error

+ func (c *ProductColl) Find(opt *ProductFindOptions) (*models.Product, error)

+ func (c *ProductColl) FindEnv(opt *ProductEnvFindOptions) (*models.Product, error)

+ func (c *ProductColl) GetCollectionName() string

+ func (c *ProductColl) List(opt *ProductListOptions) ([]*models.Product, error)

+ func (c *ProductColl) Update(args *models.Product) error

+ func (c *ProductColl) UpdateErrors(owner, productName, errorMsg string) error

+ func (c *ProductColl) UpdateGroup(envName, productName string, groupIndex int, group []*models.ProductService) error

+ func (c *ProductColl) UpdateIsPublic(envName, productName string, isPublic bool) error

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

+ func (c *ProductColl) UpdateStatus(owner, productName, status string) error

+ type ProductEnvFindOptions struct

+ Name string

+ Namespace string

+ type ProductFindOptions struct

+ EnvName string

+ Name string

+ type ProductListOptions struct

+ ClusterID string

+ EnvName string

+ ExcludeSource string

+ ExcludeStatus string

+ IsPublic bool

+ IsSort bool

+ Name string

+ Source string

+ type ProxyArgs struct

+ Type string

+ type ProxyColl struct

+ func NewProxyColl() *ProxyColl

+ func (c *ProxyColl) Create(args *models.Proxy) error

+ func (c *ProxyColl) Delete(id string) error

+ func (c *ProxyColl) EnsureIndex(ctx context.Context) error

+ func (c *ProxyColl) Find(id string) (*models.Proxy, error)

+ func (c *ProxyColl) GetCollectionName() string

+ func (c *ProxyColl) List(args *ProxyArgs) ([]*models.Proxy, error)

+ func (c *ProxyColl) Update(id string, args *models.Proxy) error

+ type QueueColl struct

+ func NewQueueColl() *QueueColl

+ func (c *QueueColl) Create(args *models.Queue) error

+ func (c *QueueColl) Delete(args *models.Queue) error

+ func (c *QueueColl) EnsureIndex(ctx context.Context) error

+ func (c *QueueColl) GetCollectionName() string

+ func (c *QueueColl) List(opt *ListQueueOption) ([]*models.Queue, error)

+ func (c *QueueColl) Update(args *models.Queue) error

+ func (c *QueueColl) UpdateAgent(taskID int64, pipelineName string, createTime int64, agentID string) error

+ type RegistryNamespaceColl struct

+ func NewRegistryNamespaceColl() *RegistryNamespaceColl

+ func (r *RegistryNamespaceColl) Create(args *models.RegistryNamespace) error

+ func (r *RegistryNamespaceColl) Delete(id string) error

+ func (r *RegistryNamespaceColl) EnsureIndex(ctx context.Context) error

+ func (r *RegistryNamespaceColl) Find(opt *FindRegOps) (*models.RegistryNamespace, error)

+ func (r *RegistryNamespaceColl) FindAll(opt *FindRegOps) ([]*models.RegistryNamespace, error)

+ func (r *RegistryNamespaceColl) GetCollectionName() string

+ func (r *RegistryNamespaceColl) List(orgID int, regType string) ([]*models.RegistryNamespace, error)

+ func (r *RegistryNamespaceColl) Update(id string, args *models.RegistryNamespace) error

+ type RenderSetColl struct

+ func NewRenderSetColl() *RenderSetColl

+ func (c *RenderSetColl) Create(args *models.RenderSet) error

+ func (c *RenderSetColl) Delete(productName string) error

+ func (c *RenderSetColl) EnsureIndex(ctx context.Context) error

+ func (c *RenderSetColl) Find(opt *RenderSetFindOption) (*models.RenderSet, error)

+ func (c *RenderSetColl) FindRenderSet(opt *RenderSetFindOption) (*models.RenderSet, bool, error)

+ func (c *RenderSetColl) GetCollectionName() string

+ func (c *RenderSetColl) List(opt *RenderSetListOption) ([]*models.RenderSet, error)

+ func (c *RenderSetColl) ListAllRenders() ([]*models.RenderSet, error)

+ func (c *RenderSetColl) SetDefault(renderTmplName, productTmplName string) error

+ func (c *RenderSetColl) Update(args *models.RenderSet) error

+ type RenderSetFindOption struct

+ Name string

+ Revision int64

+ type RenderSetListOption struct

+ ProductTmpl string

+ Revision int64

+ type RenderSetPipeResp struct

+ RenderSet struct{ ... }

+ Revision int64

+ type S3StorageColl struct

+ func NewS3StorageColl() *S3StorageColl

+ func (c *S3StorageColl) Create(args *models.S3Storage) error

+ func (c *S3StorageColl) Delete(id string) error

+ func (c *S3StorageColl) EnsureIndex(ctx context.Context) error

+ func (c *S3StorageColl) Find(id string) (*models.S3Storage, error)

+ func (c *S3StorageColl) FindAll() ([]*models.S3Storage, error)

+ func (c *S3StorageColl) FindDefault() (*models.S3Storage, error)

+ func (c *S3StorageColl) GetCollectionName() string

+ func (c *S3StorageColl) GetS3Storage() (*models.S3Storage, error)

+ func (c *S3StorageColl) Update(id string, args *models.S3Storage) error

+ type ServiceColl struct

+ func NewServiceColl() *ServiceColl

+ func (c *ServiceColl) Create(args *models.Service) error

+ func (c *ServiceColl) Delete(serviceName, serviceType, productName, status string, revision int64) error

+ func (c *ServiceColl) DistinctServices(opt *ServiceListOption) ([]models.ServiceTmplRevision, error)

+ func (c *ServiceColl) EnsureIndex(ctx context.Context) error

+ func (c *ServiceColl) Find(opt *ServiceFindOption) (*models.Service, error)

+ func (c *ServiceColl) GetCollectionName() string

+ func (c *ServiceColl) List(opt *ServiceFindOption) ([]*models.Service, error)

+ func (c *ServiceColl) ListAllRevisions() ([]*models.Service, error)

+ func (c *ServiceColl) ListMaxRevisions() ([]*models.Service, error)

+ func (c *ServiceColl) ListMaxRevisionsForServices(serviceNames []string, serviceType string) ([]*models.Service, error)

+ func (c *ServiceColl) Update(args *models.Service) error

+ func (c *ServiceColl) UpdateStatus(serviceName, serviceType, productName, status string) error

+ type ServiceFindOption struct

+ BranchName string

+ CodehostID int

+ ExcludeStatus string

+ ProductName string

+ RepoName string

+ Revision int64

+ ServiceName string

+ Source string

+ Type string

+ type ServiceListOption struct

+ BuildName string

+ ExcludeStatus string

+ IsSort bool

+ ProductName string

+ ServiceName string

+ type StatsColl struct

+ func NewStatsColl() *StatsColl

+ func (c *StatsColl) Create(args *models.Stats) error

+ func (c *StatsColl) EnsureIndex(ctx context.Context) error

+ func (c *StatsColl) GetCollectionName() string

+ func (c *StatsColl) List(option ListStatsOption) ([]*models.Stats, error)

+ type StrategyColl struct

+ func NewStrategyColl() *StrategyColl

+ func (c *StrategyColl) EnsureIndex(ctx context.Context) error

+ func (c *StrategyColl) GetByTarget(target models.CapacityTarget) (*models.CapacityStrategy, error)

+ func (c *StrategyColl) GetCollectionName() string

+ func (c *StrategyColl) Upsert(strategy *models.CapacityStrategy) error

+ type SubscriptionColl struct

+ func NewSubscriptionColl() *SubscriptionColl

+ func (c *SubscriptionColl) Delete(subscriber string, notifyType int) error

+ func (c *SubscriptionColl) EnsureIndex(ctx context.Context) error

+ func (c *SubscriptionColl) GetCollectionName() string

+ func (c *SubscriptionColl) List(subscriber string) ([]*models.Subscription, error)

+ func (c *SubscriptionColl) Update(subscriber string, notifyType int, args *models.Subscription) error

+ func (c *SubscriptionColl) Upsert(args *models.Subscription) error

+ type TaskColl struct

+ func NewTaskColl() *TaskColl

+ func (c *TaskColl) ArchiveHistoryPipelineTask(pipelineName string, taskType config.PipelineType, remain int) error

+ func (c *TaskColl) Count(option *CountTaskOption) (ret int, err error)

+ func (c *TaskColl) Create(args *task.Task) error

+ func (c *TaskColl) DeleteByPipelineNameAndType(pipelineName string, typeString config.PipelineType) error

+ func (c *TaskColl) EnsureIndex(ctx context.Context) error

+ func (c *TaskColl) Find(id int64, pipelineName string, typeString config.PipelineType) (*task.Task, error)

+ func (c *TaskColl) FindLatestTask(args *FindTaskOption) (*task.Task, error)

+ func (c *TaskColl) FindTask(pipelineName string, typeString config.PipelineType) (*task.Task, error)

+ func (c *TaskColl) FindTodoTasks() ([]*task.Task, error)

+ func (c *TaskColl) GetCollectionName() string

+ func (c *TaskColl) InCompletedTasks() ([]*task.Task, error)

+ func (c *TaskColl) List(option *ListTaskOption) (ret []*TaskPreview, err error)

+ func (c *TaskColl) ListAllTasks(option *ListAllTaskOption) ([]*task.Task, error)

+ func (c *TaskColl) ListTasks(option *ListAllTaskOption) ([]*task.Task, error)

+ func (c *TaskColl) Rename(oldName, newName string, taskType config.PipelineType) error

+ func (c *TaskColl) Update(args *task.Task) error

+ func (c *TaskColl) UpdateStatus(taskID int64, pipelineName, userName string, status config.Status) error

+ func (c *TaskColl) UpdateUnfinishedTask(args *task.Task) error

+ type TaskPreview struct

+ BuildServices []string

+ CreateTime int64

+ EndTime int64

+ Namespace string

+ PipelineName string

+ ProductName string

+ ServiceName string

+ Stages []*models.Stage

+ StartTime int64

+ Status config.Status

+ SubTasks []*map[string]interface{}

+ TaskArgs *models.TaskArgs

+ TaskCreator string

+ TaskID int64

+ TestReports map[string]interface{}

+ TriggerBy *models.TriggerBy

+ Type config.PipelineType

+ WorkflowArgs *models.WorkflowTaskArgs

+ type TestTaskStatColl struct

+ func NewTestTaskStatColl() *TestTaskStatColl

+ func (c *TestTaskStatColl) Create(args *models.TestTaskStat) error

+ func (c *TestTaskStatColl) Delete(name string) error

+ func (c *TestTaskStatColl) EnsureIndex(ctx context.Context) error

+ func (c *TestTaskStatColl) FindTestTaskStat(option *TestTaskStatOption) (*models.TestTaskStat, error)

+ func (c *TestTaskStatColl) GetCollectionName() string

+ func (c *TestTaskStatColl) ListTestTask() ([]*models.TestTaskStat, error)

+ func (c *TestTaskStatColl) Update(args *models.TestTaskStat) error

+ type TestTaskStatOption struct

+ Name string

+ type TestingColl struct

+ func NewTestingColl() *TestingColl

+ func (c *TestingColl) Create(testing *models.Testing) error

+ func (c *TestingColl) Delete(name, productName string) error

+ func (c *TestingColl) EnsureIndex(ctx context.Context) error

+ func (c *TestingColl) Find(name, productName string) (*models.Testing, error)

+ func (c *TestingColl) GetCollectionName() string

+ func (c *TestingColl) List(opt *ListTestOption) ([]*models.Testing, error)

+ func (c *TestingColl) ListWithScheduleEnabled() ([]*models.Testing, error)

+ func (c *TestingColl) Update(testing *models.Testing) error

+ type WebHookColl struct

+ func NewWebHookColl() *WebHookColl

+ func (c *WebHookColl) AddReferenceOrCreate(owner, repo, address, ref string) (bool, error)

+ func (c *WebHookColl) Delete(owner, repo, address string) error

+ func (c *WebHookColl) EnsureIndex(ctx context.Context) error

+ func (c *WebHookColl) GetCollectionName() string

+ func (c *WebHookColl) RemoveReference(owner, repo, address, ref string) (*models.WebHook, error)

+ type WebHookUserColl struct

+ func NewWebHookUserColl() *WebHookUserColl

+ func (c *WebHookUserColl) Create(args *models.WebHookUser) error

+ func (c *WebHookUserColl) EnsureIndex(ctx context.Context) error

+ func (c *WebHookUserColl) FindWebHookUserCount() (int, error)

+ func (c *WebHookUserColl) GetCollectionName() string

+ func (c *WebHookUserColl) List() ([]*models.WebHookUser, error)

+ func (c *WebHookUserColl) Upsert(args *models.WebHookUser) error

+ func (c *WebHookUserColl) UserExists(args *WebHookUserOption) (int, error)

+ type WebHookUserOption struct

+ Email string

+ UserName string

+ type WorkflowColl struct

+ func NewWorkflowColl() *WorkflowColl

+ func (c *WorkflowColl) Create(args *models.Workflow) error

+ func (c *WorkflowColl) Delete(name string) error

+ func (c *WorkflowColl) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowColl) Find(name string) (*models.Workflow, error)

+ func (c *WorkflowColl) GetCollectionName() string

+ func (c *WorkflowColl) List(opt *ListWorkflowOption) ([]*models.Workflow, error)

+ func (c *WorkflowColl) ListByTestName(testName string) ([]*models.Workflow, error)

+ func (c *WorkflowColl) ListWithScheduleEnabled() ([]*models.Workflow, error)

+ func (c *WorkflowColl) Replace(args *models.Workflow) error

+ type WorkflowStatArgs struct

+ Name string

+ Type string

+ type WorkflowStatColl struct

+ func NewWorkflowStatColl() *WorkflowStatColl

+ func (c *WorkflowStatColl) Create(args *models.WorkflowStat) error

+ func (c *WorkflowStatColl) Delete(name, workflowType string) error

+ func (c *WorkflowStatColl) EnsureIndex(ctx context.Context) error

+ func (c *WorkflowStatColl) FindWorkflowStat(args *WorkflowStatArgs) ([]*models.WorkflowStat, error)

+ func (c *WorkflowStatColl) GetCollectionName() string

+ func (c *WorkflowStatColl) Upsert(args *models.WorkflowStat) error

Other modules containing this package

github.com/koderover/zadig/v2

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