repo

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 18, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicImageColl 

type BasicImageColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewBasicImageColl 

func NewBasicImageColl() *BasicImageColl

func (*BasicImageColl) Create 

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

func (*BasicImageColl) Delete 

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

func (*BasicImageColl) EnsureIndex 

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

func (*BasicImageColl) Find 

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

func (*BasicImageColl) GetCollectionName 

func (c *BasicImageColl) GetCollectionName() string

func (*BasicImageColl) InitBasicImageData 

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

func (*BasicImageColl) List 

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

func (*BasicImageColl) Update 

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

type BasicImageOpt 

type BasicImageOpt struct {
	Value     string `bson:"value"`
	Label     string `bson:"label"`
	ImageFrom string `bson:"image_from"`
}

type BuildColl 

type BuildColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewBuildColl 

func NewBuildColl() *BuildColl

func (*BuildColl) Create 

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

func (*BuildColl) Delete 

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

func (*BuildColl) DistinctTargets 

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

DistinctTargets finds modules distinct service templates

func (*BuildColl) EnsureIndex 

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

func (*BuildColl) Find 

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

func (*BuildColl) GetCollectionName 

func (c *BuildColl) GetCollectionName() string

func (*BuildColl) List 

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

func (*BuildColl) Update 

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

func (*BuildColl) UpdateBuildParam 

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

func (*BuildColl) UpdateTargets 

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

type BuildFindOption 

type BuildFindOption struct {
	Name        string
	Version     string
	Targets     []string
	ServiceName string
	ProductName string
}

FindOption ...

type BuildItem 

type BuildItem struct {
	ProductName  string `bson:"product_name"       json:"product_name"`
	TotalSuccess int    `bson:"total_success"      json:"total_success"`
	TotalFailure int    `bson:"total_failure"      json:"total_failure"`
}

BuildItem ...

type BuildListOption 

type BuildListOption struct {
	Name         string
	Version      string
	Targets      []string
	ProductName  string
	ServiceName  string
	IsSort       bool
	BuildOS      string
	BasicImageID string
	PrivateKeyID string
}

type BuildPipeResp 

type BuildPipeResp struct {
	ID           BuildItem `bson:"_id"                    json:"_id"`
	TotalSuccess int       `bson:"total_success"          json:"total_success"`
	TotalFailure int       `bson:"total_failure"          json:"total_failure"`
}

BuildPipeResp ...

type BuildStatColl 

type BuildStatColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewBuildStatColl 

func NewBuildStatColl() *BuildStatColl

func (*BuildStatColl) Create 

func (c *BuildStatColl) Create(args *models.BuildStat) error

func (*BuildStatColl) EnsureIndex 

func (c *BuildStatColl) EnsureIndex(ctx context.Context) error

func (*BuildStatColl) FindCount 

func (c *BuildStatColl) FindCount() (int, error)

func (*BuildStatColl) GetBuildTotalAndSuccess 

func (c *BuildStatColl) GetBuildTotalAndSuccess() ([]*BuildItem, error)

func (*BuildStatColl) GetCollectionName 

func (c *BuildStatColl) GetCollectionName() string

func (*BuildStatColl) ListBuildStat 

func (c *BuildStatColl) ListBuildStat(option *BuildStatOption) ([]*models.BuildStat, error)

func (*BuildStatColl) Update 

func (c *BuildStatColl) Update(args *models.BuildStat) error

type BuildStatOption 

type BuildStatOption struct {
	StartDate    int64
	EndDate      int64
	Limit        int
	Skip         int
	IsAsc        bool
	ProductNames []string
}

type ConfigColl 

type ConfigColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewConfigColl 

func NewConfigColl() *ConfigColl

func (*ConfigColl) EnsureIndex 

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

func (*ConfigColl) Find 

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

Find 查询特定版本的配置模板 如果 Revision == 0 查询最大版本的配置模板

func (*ConfigColl) GetCollectionName 

func (c *ConfigColl) GetCollectionName() string

func (*ConfigColl) ListAllRevisions 

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

ListAllRevisions 列出历史所有的service

func (*ConfigColl) ListMaxRevisions 

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

ListMaxRevisions 查询最新版本的配置模板

type ConfigFindOption 

type ConfigFindOption struct {
	ConfigName  string
	ServiceName string
	ProductName string
	Revision    int64
}

type CountTaskOption 

type CountTaskOption struct {
	PipelineNames []string
	Status        config.TaskStatus
	Type          config.PipelineType
}

type CounterColl 

type CounterColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewCounterColl 

func NewCounterColl() *CounterColl

func (*CounterColl) Delete 

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

func (*CounterColl) EnsureIndex 

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

func (*CounterColl) Find 

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

func (*CounterColl) GetCollectionName 

func (c *CounterColl) GetCollectionName() string

func (*CounterColl) GetNextSeq 

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

func (*CounterColl) Rename 

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

func (*CounterColl) SetToNumber 

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

type CronjobColl 

type CronjobColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewCronjobColl 

func NewCronjobColl() *CronjobColl

func (*CronjobColl) Create 

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

func (*CronjobColl) Delete 

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

func (*CronjobColl) EnsureIndex 

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

func (*CronjobColl) GetCollectionName 

func (c *CronjobColl) GetCollectionName() string

func (*CronjobColl) List 

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

func (*CronjobColl) ListActiveJob 

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

func (*CronjobColl) Update 

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

type CronjobDeleteOption 

type CronjobDeleteOption struct {
	IDList     []string
	ParentName string
	ParentType string
}

type DeliveryActivityArgs 

type DeliveryActivityArgs struct {
	ArtifactID string `json:"artifact_id"`
	RepoName   string `json:"repo_name"`
	Branch     string `json:"branch"`
	PerPage    int    `json:"per_page"`
	Page       int    `json:"page"`
}

type DeliveryActivityColl 

type DeliveryActivityColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliveryActivityColl 

func NewDeliveryActivityColl() *DeliveryActivityColl

func (*DeliveryActivityColl) EnsureIndex 

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

func (*DeliveryActivityColl) GetCollectionName 

func (c *DeliveryActivityColl) GetCollectionName() string

func (*DeliveryActivityColl) Insert 

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

func (*DeliveryActivityColl) InsertWithID 

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

func (*DeliveryActivityColl) List 

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

type DeliveryArtifactArgs 

type DeliveryArtifactArgs struct {
	ID           string `json:"id"`
	Image        string `json:"image"`
	Name         string `json:"name"`
	Type         string `json:"type"`
	RepoName     string `json:"repo_name"`
	Branch       string `json:"branch"`
	Source       string `json:"source"`
	ImageHash    string `json:"image_hash"`
	ImageTag     string `json:"image_tag"`
	ImageDigest  string `json:"image_digest"`
	PerPage      int    `json:"per_page"`
	Page         int    `json:"page"`
	IsFuzzyQuery bool   `json:"is_fuzzy_query"`
}

type DeliveryArtifactColl 

type DeliveryArtifactColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliveryArtifactColl 

func NewDeliveryArtifactColl() *DeliveryArtifactColl

func (*DeliveryArtifactColl) EnsureIndex 

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

func (*DeliveryArtifactColl) Get 

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

func (*DeliveryArtifactColl) GetCollectionName 

func (c *DeliveryArtifactColl) GetCollectionName() string

func (*DeliveryArtifactColl) Insert 

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

func (*DeliveryArtifactColl) List 

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

func (*DeliveryArtifactColl) Update 

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

type DeliveryBuildArgs 

type DeliveryBuildArgs struct {
	ID          string `json:"id"`
	ReleaseID   string `json:"releaseId"`
	ServiceName string `json:"serviceName"`
}

type DeliveryBuildColl 

type DeliveryBuildColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliveryBuildColl 

func NewDeliveryBuildColl() *DeliveryBuildColl

func (*DeliveryBuildColl) Delete 

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

func (*DeliveryBuildColl) EnsureIndex 

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

func (*DeliveryBuildColl) Find 

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

func (*DeliveryBuildColl) GetCollectionName 

func (c *DeliveryBuildColl) GetCollectionName() string

func (*DeliveryBuildColl) Insert 

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

type DeliveryDeployArgs 

type DeliveryDeployArgs struct {
	ID          string `json:"id"`
	ReleaseID   string `json:"releaseId"`
	ServiceName string `json:"serviceName"`
}

type DeliveryDeployColl 

type DeliveryDeployColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliveryDeployColl 

func NewDeliveryDeployColl() *DeliveryDeployColl

func (*DeliveryDeployColl) Delete 

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

func (*DeliveryDeployColl) EnsureIndex 

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

func (*DeliveryDeployColl) Find 

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

func (*DeliveryDeployColl) GetCollectionName 

func (c *DeliveryDeployColl) GetCollectionName() string

func (*DeliveryDeployColl) Insert 

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

type DeliveryDistributeArgs 

type DeliveryDistributeArgs struct {
	ID             string                `json:"id"`
	ReleaseID      string                `json:"releaseId"`
	ServiceName    string                `json:"serviceName"`
	DistributeType config.DistributeType `json:"distributeType"`
}

type DeliveryDistributeColl 

type DeliveryDistributeColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliveryDistributeColl 

func NewDeliveryDistributeColl() *DeliveryDistributeColl

func (*DeliveryDistributeColl) Delete 

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

func (*DeliveryDistributeColl) EnsureIndex 

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

func (*DeliveryDistributeColl) Find 

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

func (*DeliveryDistributeColl) GetCollectionName 

func (c *DeliveryDistributeColl) GetCollectionName() string

func (*DeliveryDistributeColl) Insert 

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

type DeliverySecurityArgs 

type DeliverySecurityArgs struct {
	ID        string `json:"id"`
	ImageID   string `json:"imageId"`
	ImageName string `json:"imageName"`
	Severity  string `json:"severity"`
}

type DeliverySecurityColl 

type DeliverySecurityColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliverySecurityColl 

func NewDeliverySecurityColl() *DeliverySecurityColl

func (*DeliverySecurityColl) EnsureIndex 

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

func (*DeliverySecurityColl) Find 

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

func (*DeliverySecurityColl) FindStatistics 

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

func (*DeliverySecurityColl) GetCollectionName 

func (c *DeliverySecurityColl) GetCollectionName() string

func (*DeliverySecurityColl) Insert 

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

type DeliveryTestArgs 

type DeliveryTestArgs struct {
	ID        string `json:"id"`
	ReleaseID string `json:"releaseId"`
}

type DeliveryTestColl 

type DeliveryTestColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliveryTestColl 

func NewDeliveryTestColl() *DeliveryTestColl

func (*DeliveryTestColl) Delete 

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

func (*DeliveryTestColl) EnsureIndex 

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

func (*DeliveryTestColl) Find 

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

func (*DeliveryTestColl) GetCollectionName 

func (c *DeliveryTestColl) GetCollectionName() string

func (*DeliveryTestColl) Insert 

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

type DeliveryVersionArgs 

type DeliveryVersionArgs struct {
	ID           string `json:"id"`
	OrgID        int    `json:"orgId"`
	ProductName  string `json:"productName"`
	WorkflowName string `json:"workflowName"`
	TaskID       int    `json:"taskId"`
	PerPage      int    `json:"perPage"`
	Page         int    `json:"page"`
}

type DeliveryVersionColl 

type DeliveryVersionColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeliveryVersionColl 

func NewDeliveryVersionColl() *DeliveryVersionColl

func (*DeliveryVersionColl) Delete 

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

func (*DeliveryVersionColl) EnsureIndex 

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

func (*DeliveryVersionColl) Find 

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

func (*DeliveryVersionColl) FindProducts 

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

func (*DeliveryVersionColl) Get 

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

func (*DeliveryVersionColl) GetCollectionName 

func (c *DeliveryVersionColl) GetCollectionName() string

func (*DeliveryVersionColl) Insert 

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

func (*DeliveryVersionColl) ListDeliveryVersions 

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

func (*DeliveryVersionColl) Update 

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

type DeployDailyItem 

type DeployDailyItem struct {
	Date         string `bson:"date"                      json:"date"`
	TotalSuccess int    `bson:"total_deploy_success"      json:"total_deploy_success"`
	TotalFailure int    `bson:"total_deploy_failure"      json:"total_deploy_failure"`
}

type DeployDailyPipeResp 

type DeployDailyPipeResp struct {
	ID           DeployDailyItem `bson:"_id"                             json:"_id"`
	TotalSuccess int             `bson:"total_deploy_success"            json:"total_deploy_success"`
	TotalFailure int             `bson:"total_deploy_failure"            json:"total_deploy_failure"`
}

type DeployFailurePipeInfo 

type DeployFailurePipeInfo struct {
	ProductName                 string `bson:"product_name"                      json:"productName"`
	MaxDeployFailureServiceName string `bson:"max_deploy_failure_service_name"   json:"maxDeployFailureServiceName"`
}

type DeployFailurePipeResp 

type DeployFailurePipeResp struct {
	ID                         DeployFailurePipeInfo `bson:"_id"                       json:"_id"`
	MaxDeployFailureServiceNum int                   `bson:"max_deploy_failure_service_num"    json:"maxDeployFailureServiceNum"`
}

type DeployPipeInfo 

type DeployPipeInfo struct {
	MaxDeployServiceName string `bson:"max_deploy_service_name"           json:"maxDeployServiceName"`
}

type DeployPipeResp 

type DeployPipeResp struct {
	ID                  DeployPipeInfo `bson:"_id"                       json:"_id"`
	MaxDeployServiceNum int            `bson:"max_deploy_service_num"            json:"maxDeployServiceNum"`
}

type DeployStatColl 

type DeployStatColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDeployStatColl 

func NewDeployStatColl() *DeployStatColl

func (*DeployStatColl) Create 

func (c *DeployStatColl) Create(args *models.DeployStat) error

func (*DeployStatColl) EnsureIndex 

func (c *DeployStatColl) EnsureIndex(ctx context.Context) error

func (*DeployStatColl) FindCount 

func (c *DeployStatColl) FindCount() (int, error)

func (*DeployStatColl) Get 

func (c *DeployStatColl) Get(args *DeployStatGetOption) (*models.DeployStat, error)

func (*DeployStatColl) GetCollectionName 

func (c *DeployStatColl) GetCollectionName() string

func (*DeployStatColl) GetDeployDailyTotal 

func (c *DeployStatColl) GetDeployDailyTotal(args *DeployStatOption) ([]*DeployDailyItem, error)

func (*DeployStatColl) GetDeployTotalAndSuccess 

func (c *DeployStatColl) GetDeployTotalAndSuccess() ([]*DeployTotalItem, error)

func (*DeployStatColl) ListDeployStat 

func (c *DeployStatColl) ListDeployStat(option *DeployStatOption) ([]*models.DeployStat, error)

func (*DeployStatColl) Update 

func (c *DeployStatColl) Update(args *models.DeployStat) error

type DeployStatGetOption 

type DeployStatGetOption struct {
	MaxDeployServiceNum int
	ServiceName         string
}

type DeployStatOption 

type DeployStatOption struct {
	StartDate    int64
	EndDate      int64
	Limit        int
	Skip         int
	IsAsc        bool
	IsMaxDeploy  bool
	ProductNames []string
}

type DeployTotalItem 

type DeployTotalItem struct {
	ProductName  string `bson:"product_name"              json:"product_name"`
	TotalSuccess int    `bson:"total_deploy_success"      json:"total_deploy_success"`
	TotalFailure int    `bson:"total_deploy_failure"      json:"total_deploy_failure"`
}

type DeployTotalPipeResp 

type DeployTotalPipeResp struct {
	ID           DeployTotalItem `bson:"_id"                      json:"_id"`
	TotalSuccess int             `bson:"total_deploy_success"     json:"total_deploy_success"`
	TotalFailure int             `bson:"total_deploy_failure"     json:"total_deploy_failure"`
}

type DiffNoteColl 

type DiffNoteColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDiffNoteColl 

func NewDiffNoteColl() *DiffNoteColl

func (*DiffNoteColl) Create 

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

func (*DiffNoteColl) EnsureIndex 

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

func (*DiffNoteColl) Find 

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

func (*DiffNoteColl) GetCollectionName 

func (c *DiffNoteColl) GetCollectionName() string

func (*DiffNoteColl) Update 

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

type DiffNoteFindOpt 

type DiffNoteFindOpt struct {
	CodehostID     int
	ProjectID      string
	MergeRequestID int
}

type DindCleanColl 

type DindCleanColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewDindCleanColl 

func NewDindCleanColl() *DindCleanColl

func (*DindCleanColl) EnsureIndex 

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

func (*DindCleanColl) GetCollectionName 

func (c *DindCleanColl) GetCollectionName() string

func (*DindCleanColl) List 

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

func (*DindCleanColl) Upsert 

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

type FavoriteArgs 

type FavoriteArgs struct {
	UserID      int
	ProductName string
	Name        string
	Type        string
}

type FavoriteColl 

type FavoriteColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewFavoriteColl 

func NewFavoriteColl() *FavoriteColl

func (*FavoriteColl) Create 

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

func (*FavoriteColl) Delete 

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

func (*FavoriteColl) EnsureIndex 

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

func (*FavoriteColl) Find 

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

func (*FavoriteColl) GetCollectionName 

func (c *FavoriteColl) GetCollectionName() string

func (*FavoriteColl) List 

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

type FindRegOps 

type FindRegOps struct {
	ID          string `json:"id"`
	OrgID       int    `json:"org_id"`
	RegAddr     string `json:"reg_addr"`
	RegType     string `json:"reg_type"`
	RegProvider string `json:"reg_provider"`
	IsDefault   bool   `json:"is_default"`
	Namespace   string `json:"namespace"`
}

type GithubAppColl 

type GithubAppColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewGithubAppColl 

func NewGithubAppColl() *GithubAppColl

func (*GithubAppColl) Create 

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

func (*GithubAppColl) Delete 

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

func (*GithubAppColl) EnsureIndex 

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

func (*GithubAppColl) Find 

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

func (*GithubAppColl) GetCollectionName 

func (c *GithubAppColl) GetCollectionName() string

func (*GithubAppColl) Upsert 

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

type HelmRepoColl 

type HelmRepoColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewHelmRepoColl 

func NewHelmRepoColl() *HelmRepoColl

func (*HelmRepoColl) Create 

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

func (*HelmRepoColl) Delete 

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

func (*HelmRepoColl) EnsureIndex 

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

func (*HelmRepoColl) GetCollectionName 

func (c *HelmRepoColl) GetCollectionName() string

func (*HelmRepoColl) List 

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

func (*HelmRepoColl) Update 

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

type InstallColl 

type InstallColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewInstallColl 

func NewInstallColl() *InstallColl

func (*InstallColl) Create 

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

func (*InstallColl) Delete 

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

func (*InstallColl) EnsureIndex 

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

func (*InstallColl) Find 

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

func (*InstallColl) GetCollectionName 

func (c *InstallColl) GetCollectionName() string

func (*InstallColl) InitInstallData 

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

func (*InstallColl) List 

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

func (*InstallColl) Update 

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

func (*InstallColl) UpdateSystemDefault 

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

type ItReportColl 

type ItReportColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewItReportColl 

func NewItReportColl() *ItReportColl

func (*ItReportColl) EnsureIndex 

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

func (*ItReportColl) GetCollectionName 

func (c *ItReportColl) GetCollectionName() string

func (*ItReportColl) Upsert 

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

type JenkinsIntegrationColl 

type JenkinsIntegrationColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewJenkinsIntegrationColl 

func NewJenkinsIntegrationColl() *JenkinsIntegrationColl

func (*JenkinsIntegrationColl) Create 

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

func (*JenkinsIntegrationColl) Delete 

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

func (*JenkinsIntegrationColl) EnsureIndex 

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

func (*JenkinsIntegrationColl) GetCollectionName 

func (c *JenkinsIntegrationColl) GetCollectionName() string

func (*JenkinsIntegrationColl) List 

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

func (*JenkinsIntegrationColl) Update 

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

type K8SClusterColl 

type K8SClusterColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewK8SClusterColl 

func NewK8SClusterColl() *K8SClusterColl

func (*K8SClusterColl) Create 

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

func (*K8SClusterColl) Delete 

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

func (*K8SClusterColl) EnsureIndex 

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

func (*K8SClusterColl) Find 

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

func (*K8SClusterColl) FindByName 

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

func (*K8SClusterColl) FindConnectedClusters 

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

func (*K8SClusterColl) Get 

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

Get ...

func (*K8SClusterColl) GetByToken 

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

func (*K8SClusterColl) GetCollectionName 

func (c *K8SClusterColl) GetCollectionName() string

func (*K8SClusterColl) HasDuplicateName 

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

func (*K8SClusterColl) Update 

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

Update ...

func (*K8SClusterColl) UpdateConnectState 

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

func (*K8SClusterColl) UpdateMutableFields 

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

func (*K8SClusterColl) UpdateStatus 

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

type ListAllTaskOption 

type ListAllTaskOption struct {
	ProductNames    []string
	ProductName     string
	PipelineName    string
	Type            config.PipelineType
	CreateTime      int64
	BeforeCreatTime bool
	Limit           int
	Skip            int
}

type ListCronjobParam 

type ListCronjobParam struct {
	ParentName string
	ParentType string
}

type ListQueueOption 

type ListQueueOption struct {
	PipelineName   string
	Status         config.Status
	MergeRequestID string
}

type ListStatsOption 

type ListStatsOption struct {
	ProductName string
	Event       string
	Limit       int
}

type ListTaskOption 

type ListTaskOption struct {
	PipelineName   string
	Status         config.Status
	Team           string
	TeamID         int
	Limit          int
	Skip           int
	Detail         bool
	Type           config.PipelineType
	CreateTime     int64
	TaskCreator    string
	Source         string
	MergeRequestID string
	NeedTriggerBy  bool
	NeedAllData    bool
}

type ListTestOption 

type ListTestOption struct {
	ProductName  string
	TestType     string
	IsSort       bool
	BuildOS      string
	BasicImageID string
}

type ListWorkflowOption 

type ListWorkflowOption struct {
	ProductName string
	IsSort      bool
	TestName    string
}

type NotificationColl 

type NotificationColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewNotificationColl 

func NewNotificationColl() *NotificationColl

func (*NotificationColl) Create 

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

func (*NotificationColl) EnsureIndex 

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

func (*NotificationColl) Find 

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

func (*NotificationColl) GetCollectionName 

func (c *NotificationColl) GetCollectionName() string

func (*NotificationColl) Upsert 

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

type NotifyColl 

type NotifyColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewNotifyColl 

func NewNotifyColl() *NotifyColl

func (*NotifyColl) Create 

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

func (*NotifyColl) DeleteByID 

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

func (*NotifyColl) DeleteByTime 

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

func (*NotifyColl) EnsureIndex 

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

func (*NotifyColl) GetCollectionName 

func (c *NotifyColl) GetCollectionName() string

func (*NotifyColl) List 

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

func (*NotifyColl) Read 

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

func (*NotifyColl) Update 

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

type OperationLogArgs 

type OperationLogArgs struct {
	Username    string `json:"username"`
	ProductName string `json:"product_name"`
	Function    string `json:"function"`
	Status      int    `json:"status"`
	PerPage     int    `json:"per_page"`
	Page        int    `json:"page"`
}

type OperationLogColl 

type OperationLogColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewOperationLogColl 

func NewOperationLogColl() *OperationLogColl

func (*OperationLogColl) EnsureIndex 

func (c *OperationLogColl) EnsureIndex(_ context.Context) error

func (*OperationLogColl) Find 

func (c *OperationLogColl) Find(args *OperationLogArgs) ([]*models.OperationLog, int, error)

func (*OperationLogColl) GetCollectionName 

func (c *OperationLogColl) GetCollectionName() string

func (*OperationLogColl) Insert 

func (c *OperationLogColl) Insert(args *models.OperationLog) error

func (*OperationLogColl) Update 

func (c *OperationLogColl) Update(id string, status int) error

type PipelineColl 

type PipelineColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewPipelineColl 

func NewPipelineColl() *PipelineColl

func (*PipelineColl) Delete 

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

func (*PipelineColl) EnsureIndex 

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

func (*PipelineColl) Find 

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

func (*PipelineColl) GetCollectionName 

func (c *PipelineColl) GetCollectionName() string

func (*PipelineColl) List 

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

func (*PipelineColl) Rename 

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

func (*PipelineColl) Upsert 

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

type PipelineFindOption 

type PipelineFindOption struct {
	Name      string
	IsDeleted bool
}

type PipelineListOption 

type PipelineListOption struct {
	Teams          []string
	TeamName       []string
	IsDeleted      bool
	IsPreview      bool
	Targets        []string
	BuildModuleVer string
	ProductName    string
}

type ProductColl 

type ProductColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewProductColl 

func NewProductColl() *ProductColl

func (*ProductColl) Create 

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

func (*ProductColl) Delete 

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

func (*ProductColl) EnsureIndex 

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

func (*ProductColl) Find 

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

func (*ProductColl) FindEnv 

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

func (*ProductColl) GetCollectionName 

func (c *ProductColl) GetCollectionName() string

func (*ProductColl) List 

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

func (*ProductColl) Update 

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

Update Cannot update owner & product name

func (*ProductColl) UpdateErrors 

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

func (*ProductColl) UpdateGroup 

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

func (*ProductColl) UpdateIsPublic 

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

func (*ProductColl) UpdateStatus 

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

type ProductEnvFindOptions 

type ProductEnvFindOptions struct {
	Name      string
	Namespace string
}

type ProductFindOptions 

type ProductFindOptions struct {
	Name    string
	EnvName string
}

type ProductListOptions 

type ProductListOptions struct {
	EnvName       string
	Name          string
	IsPublic      bool
	ClusterID     string
	IsSort        bool
	ExcludeStatus string
	ExcludeSource string
	Source        string
}

ClusterId is a primitive.ObjectID{}.Hex()

type ProxyArgs 

type ProxyArgs struct {
	Type string
}

type ProxyColl 

type ProxyColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewProxyColl 

func NewProxyColl() *ProxyColl

func (*ProxyColl) Create 

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

func (*ProxyColl) Delete 

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

func (*ProxyColl) EnsureIndex 

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

func (*ProxyColl) Find 

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

func (*ProxyColl) GetCollectionName 

func (c *ProxyColl) GetCollectionName() string

func (*ProxyColl) List 

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

func (*ProxyColl) Update 

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

type QueueColl 

type QueueColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewQueueColl 

func NewQueueColl() *QueueColl

func (*QueueColl) Create 

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

func (*QueueColl) Delete 

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

func (*QueueColl) EnsureIndex 

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

func (*QueueColl) GetCollectionName 

func (c *QueueColl) GetCollectionName() string

func (*QueueColl) List 

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

func (*QueueColl) Update 

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

func (*QueueColl) UpdateAgent 

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

type RegistryNamespaceColl 

type RegistryNamespaceColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewRegistryNamespaceColl 

func NewRegistryNamespaceColl() *RegistryNamespaceColl

func (*RegistryNamespaceColl) Create 

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

func (*RegistryNamespaceColl) Delete 

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

func (*RegistryNamespaceColl) EnsureIndex 

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

func (*RegistryNamespaceColl) Find 

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

func (*RegistryNamespaceColl) FindAll 

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

func (*RegistryNamespaceColl) GetCollectionName 

func (r *RegistryNamespaceColl) GetCollectionName() string

func (*RegistryNamespaceColl) List 

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

func (*RegistryNamespaceColl) Update 

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

type RenderSetColl 

type RenderSetColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewRenderSetColl 

func NewRenderSetColl() *RenderSetColl

func (*RenderSetColl) Create 

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

func (*RenderSetColl) Delete 

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

Delete 根据项目名称删除renderset

func (*RenderSetColl) EnsureIndex 

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

func (*RenderSetColl) Find 

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

func (*RenderSetColl) FindRenderSet 

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

func (*RenderSetColl) GetCollectionName 

func (c *RenderSetColl) GetCollectionName() string

func (*RenderSetColl) List 

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

func (*RenderSetColl) ListAllRenders 

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

func (*RenderSetColl) SetDefault 

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

func (*RenderSetColl) Update 

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

type RenderSetFindOption 

type RenderSetFindOption struct {
	// if Revision == 0 then search max revision of RenderSet
	Revision int64
	Name     string
}

RenderSetFindOption ...

type RenderSetListOption 

type RenderSetListOption struct {
	// if Revision == 0 then search max revision of RenderSet
	Revision    int64
	ProductTmpl string
}

type RenderSetPipeResp 

type RenderSetPipeResp struct {
	RenderSet struct {
		Name        string `bson:"name"                     json:"name"`
		ProductTmpl string `bson:"product_tmpl"             json:"product_tmpl"`
	} `bson:"_id"      json:"render_set"`
	Revision int64 `bson:"revision"     json:"revision"`
}

type S3StorageColl 

type S3StorageColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewS3StorageColl 

func NewS3StorageColl() *S3StorageColl

func (*S3StorageColl) Create 

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

Create if the crated storage is default, all other default storage will be set as not default

func (*S3StorageColl) Delete 

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

func (*S3StorageColl) EnsureIndex 

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

func (*S3StorageColl) Find 

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

func (*S3StorageColl) FindAll 

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

func (*S3StorageColl) FindDefault 

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

func (*S3StorageColl) GetCollectionName 

func (c *S3StorageColl) GetCollectionName() string

func (*S3StorageColl) GetS3Storage 

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

func (*S3StorageColl) Update 

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

Upsert if the updated storage is default, all other default storage will be set as not default

type ServiceColl 

type ServiceColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewServiceColl 

func NewServiceColl() *ServiceColl

func (*ServiceColl) Create 

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

func (*ServiceColl) Delete 

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

func (*ServiceColl) DistinctServices 

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

DistinctServices returns distinct service templates with service_name + type Could be filtered with team, "all" means all teams

func (*ServiceColl) EnsureIndex 

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

func (*ServiceColl) Find 

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

Find 根据service_name和type查询特定版本的配置模板 如果 Revision == 0 查询最大版本的配置模板

func (*ServiceColl) GetCollectionName 

func (c *ServiceColl) GetCollectionName() string

func (*ServiceColl) List 

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

func (*ServiceColl) ListAllRevisions 

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

ListAllRevisions 列出历史所有的service TODO 返回k8s所有service

func (*ServiceColl) ListMaxRevisions 

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

func (*ServiceColl) ListMaxRevisionsForServices 

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

func (*ServiceColl) Update 

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

func (*ServiceColl) UpdateStatus 

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

type ServiceFindOption 

type ServiceFindOption struct {
	ServiceName   string
	Revision      int64
	Type          string
	Source        string
	ProductName   string
	ExcludeStatus string
	CodehostID    int
	RepoName      string
	BranchName    string
}

ServiceFindOption ...

type ServiceListOption 

type ServiceListOption struct {
	ProductName   string
	ServiceName   string
	IsSort        bool
	ExcludeStatus string
	BuildName     string
}

type StatsColl 

type StatsColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewStatsColl 

func NewStatsColl() *StatsColl

func (*StatsColl) Create 

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

Create ...

func (*StatsColl) EnsureIndex 

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

func (*StatsColl) GetCollectionName 

func (c *StatsColl) GetCollectionName() string

func (*StatsColl) List 

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

List ...

type SubscriptionColl 

type SubscriptionColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewSubscriptionColl 

func NewSubscriptionColl() *SubscriptionColl

func (*SubscriptionColl) Delete 

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

func (*SubscriptionColl) EnsureIndex 

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

func (*SubscriptionColl) GetCollectionName 

func (c *SubscriptionColl) GetCollectionName() string

func (*SubscriptionColl) List 

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

func (*SubscriptionColl) Update 

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

func (*SubscriptionColl) Upsert 

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

type TaskColl 

type TaskColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewTaskColl 

func NewTaskColl() *TaskColl

func (*TaskColl) ArchiveHistoryPipelineTask 

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

func (*TaskColl) Count 

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

func (*TaskColl) Create 

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

func (*TaskColl) DeleteByPipelineNameAndType 

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

func (*TaskColl) EnsureIndex 

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

func (*TaskColl) Find 

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

func (*TaskColl) FindTask 

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

func (*TaskColl) FindTodoTasks 

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

func (*TaskColl) GetCollectionName 

func (c *TaskColl) GetCollectionName() string

func (*TaskColl) InCompletedTasks 

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

func (*TaskColl) List 

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

func (*TaskColl) ListAllTasks 

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

func (*TaskColl) ListTasks 

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

func (*TaskColl) Rename 

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

func (*TaskColl) Update 

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

func (*TaskColl) UpdateStatus 

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

func (*TaskColl) UpdateUnfinishedTask 

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

type TaskPreview 

type TaskPreview struct {
	TaskID       int64                     `bson:"task_id"               json:"task_id"`
	TaskCreator  string                    `bson:"task_creator"          json:"task_creator"`
	ProductName  string                    `bson:"product_name"          json:"product_name"`
	PipelineName string                    `bson:"pipeline_name"         json:"pipeline_name"`
	Namespace    string                    `bson:"namespace"             json:"namespace"`
	ServiceName  string                    `bson:"service_name"          json:"service_name"`
	Status       config.Status             `bson:"status"                json:"status"`
	CreateTime   int64                     `bson:"create_time"           json:"create_time,omitempty"`
	StartTime    int64                     `bson:"start_time"            json:"start_time,omitempty"`
	EndTime      int64                     `bson:"end_time"              json:"end_time,omitempty"`
	SubTasks     []*map[string]interface{} `bson:"sub_tasks,omitempty"   json:"sub_tasks,omitempty"`
	TaskArgs     *models.TaskArgs          `bson:"task_args"             json:"task_args"`
	WorkflowArgs *models.WorkflowTaskArgs  `bson:"workflow_args"         json:"workflow_args"`
	TestReports  map[string]interface{}    `bson:"test_reports,omitempty" json:"test_reports,omitempty"`
	Type         config.PipelineType       `bson:"type"                  json:"type"`
	Stages       []*models.Stage           `bson:"stages"                json:"stages,omitempty"`
	// 服务名称，用于任务列表的展示
	BuildServices []string          `bson:"-"                     json:"build_services"`
	TriggerBy     *models.TriggerBy `bson:"trigger_by,omitempty"  json:"trigger_by,omitempty"`
}

type TestTaskStatColl 

type TestTaskStatColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewTestTaskStatColl 

func NewTestTaskStatColl() *TestTaskStatColl

func (*TestTaskStatColl) Create 

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

func (*TestTaskStatColl) Delete 

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

func (*TestTaskStatColl) EnsureIndex 

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

func (*TestTaskStatColl) FindTestTaskStat 

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

func (*TestTaskStatColl) GetCollectionName 

func (c *TestTaskStatColl) GetCollectionName() string

func (*TestTaskStatColl) ListTestTask 

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

func (*TestTaskStatColl) Update 

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

type TestTaskStatOption 

type TestTaskStatOption struct {
	Name string
}

type TestingColl 

type TestingColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewTestingColl 

func NewTestingColl() *TestingColl

func (*TestingColl) Create 

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

func (*TestingColl) Delete 

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

func (*TestingColl) EnsureIndex 

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

func (*TestingColl) Find 

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

func (*TestingColl) GetCollectionName 

func (c *TestingColl) GetCollectionName() string

func (*TestingColl) List 

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

func (*TestingColl) ListWithScheduleEnabled 

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

func (*TestingColl) Update 

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

type WebHookUserColl 

type WebHookUserColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewWebHookUserColl 

func NewWebHookUserColl() *WebHookUserColl

func (*WebHookUserColl) Create 

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

func (*WebHookUserColl) EnsureIndex 

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

func (*WebHookUserColl) FindWebHookUserCount 

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

func (*WebHookUserColl) GetCollectionName 

func (c *WebHookUserColl) GetCollectionName() string

func (*WebHookUserColl) List 

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

func (*WebHookUserColl) Upsert 

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

func (*WebHookUserColl) UserExists 

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

type WebHookUserOption 

type WebHookUserOption struct {
	Email    string
	UserName string
}

type WorkflowColl 

type WorkflowColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewWorkflowColl 

func NewWorkflowColl() *WorkflowColl

func (*WorkflowColl) Create 

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

func (*WorkflowColl) Delete 

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

func (*WorkflowColl) EnsureIndex 

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

func (*WorkflowColl) Find 

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

func (*WorkflowColl) GetCollectionName 

func (c *WorkflowColl) GetCollectionName() string

func (*WorkflowColl) List 

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

func (*WorkflowColl) ListByTestName 

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

func (*WorkflowColl) ListWithScheduleEnabled 

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

func (*WorkflowColl) Replace 

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

type WorkflowStatArgs 

type WorkflowStatArgs struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type WorkflowStatColl 

type WorkflowStatColl struct {
	*mongo.Collection
	// contains filtered or unexported fields
}

func NewWorkflowStatColl 

func NewWorkflowStatColl() *WorkflowStatColl

func (*WorkflowStatColl) Create 

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

func (*WorkflowStatColl) Delete 

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

func (*WorkflowStatColl) EnsureIndex 

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

func (*WorkflowStatColl) FindWorkflowStat 

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

func (*WorkflowStatColl) GetCollectionName 

func (c *WorkflowStatColl) GetCollectionName() string

func (*WorkflowStatColl) Upsert 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.