mongodb

package
v2.3.1 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 13 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) CreateZadigSonarImage 

func (c *BasicImageColl) CreateZadigSonarImage() error

func (*BasicImageColl) FindXenialAndFocalBasicImage 

func (c *BasicImageColl) FindXenialAndFocalBasicImage() (*models.BasicImage, *models.BasicImage, error)

func (*BasicImageColl) GetSonarTypeImage 

func (c *BasicImageColl) GetSonarTypeImage() ([]*models.BasicImage, error)

func (*BasicImageColl) RemoveXenial 

func (c *BasicImageColl) RemoveXenial() error

type BasicImageOpt 

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

type BuildColl 

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

func NewBuildColl 

func NewBuildColl() *BuildColl

func (*BuildColl) List 

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

func (*BuildColl) Update 

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

type BuildListOption 

type BuildListOption struct {
}

type CodehostColl 

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

func NewCodehostColl 

func NewCodehostColl() *CodehostColl

func (*CodehostColl) ChangeType 

func (c *CodehostColl) ChangeType(ID int, sourceType string) error

func (*CodehostColl) GetByID 

func (c *CodehostColl) GetByID(id int) (*models.CodeHost, error)

func (*CodehostColl) List 

func (c *CodehostColl) List() ([]*models.CodeHost, error)

func (*CodehostColl) RollbackType 

func (c *CodehostColl) RollbackType(ID int, sourceType string) error

type ConfigMapColl 

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

func NewConfigMapColl 

func NewConfigMapColl() *ConfigMapColl

func (*ConfigMapColl) GetCollectionName 

func (c *ConfigMapColl) GetCollectionName() string

func (*ConfigMapColl) List 

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

type EmailHostColl 

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

func NewEmailHostColl 

func NewEmailHostColl() *EmailHostColl

func (*EmailHostColl) ChangeType 

func (c *EmailHostColl) ChangeType(ID primitive.ObjectID, isTLS string) error

func (*EmailHostColl) List 

func (c *EmailHostColl) List() ([]*models.EmailHost, error)

func (*EmailHostColl) RollbackType 

func (c *EmailHostColl) RollbackType(ID primitive.ObjectID, isTLS bool) error

type EnvResourceColl 

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

func NewEnvResourceColl 

func NewEnvResourceColl() *EnvResourceColl

func (*EnvResourceColl) BatchInsert 

func (c *EnvResourceColl) BatchInsert(resources []*models.EnvResource) error

type FindRegOps 

type FindRegOps struct {
	ID          string `json:"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 IngressColl 

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

func NewIngressColl 

func NewIngressColl() *IngressColl

func (*IngressColl) GetCollectionName 

func (c *IngressColl) GetCollectionName() string

func (*IngressColl) List 

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

type JenkinsIntegrationColl 

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

func NewJenkinsIntegrationColl 

func NewJenkinsIntegrationColl() *JenkinsIntegrationColl

func (*JenkinsIntegrationColl) List 

func (c *JenkinsIntegrationColl) List() ([]*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, id string) error

func (*K8SClusterColl) Get 

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

func (*K8SClusterColl) GetCollectionName 

func (c *K8SClusterColl) GetCollectionName() string

func (*K8SClusterColl) List 

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

type ListArgs 

type ListArgs struct {
	Owner   string
	Address string
	Source  string
}

type ListTestOption 

type ListTestOption struct {
}

type ListWorkflowOption 

type ListWorkflowOption struct {
	IsSort   bool
	Projects []string
	Names    []string
	Ids      []string
}

type ListWorkflowTaskV4Option 

type ListWorkflowTaskV4Option struct {
}

type MigrationColl 

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

func NewMigrationColl 

func NewMigrationColl() *MigrationColl

func (*MigrationColl) GetMigrationInfo 

func (c *MigrationColl) GetMigrationInfo() (*models.Migration, error)

func (*MigrationColl) InitializeMigrationInfo 

func (c *MigrationColl) InitializeMigrationInfo() error

func (*MigrationColl) UpdateMigrationStatus 

func (c *MigrationColl) UpdateMigrationStatus(id primitive.ObjectID, kvs map[string]interface{}) error

type OrganizationColl 

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

func NewOrganizationColl 

func NewOrganizationColl() *OrganizationColl

func (*OrganizationColl) Get 

func (c *OrganizationColl) Get(id int) (*models.Organization, bool, error)

type ProductColl 

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

func NewProductColl 

func NewProductColl() *ProductColl

func (*ProductColl) GetCollectionName 

func (c *ProductColl) GetCollectionName() string

func (*ProductColl) List 

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

func (*ProductColl) UpdateAllRegistry 

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

func (*ProductColl) UpdateProductRender 

func (c *ProductColl) UpdateProductRender(product *models.Product) error

func (*ProductColl) UpdateRender 

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

type ProductFindOptions 

type ProductFindOptions struct {
	Name      string
	EnvName   string
	Namespace string
}

type ProductListOptions 

type ProductListOptions struct {
	EnvName             string
	Name                string
	IsPublic            bool
	ClusterID           string
	IsSortByUpdateTime  bool
	IsSortByProductName bool
	ExcludeStatus       string
	ExcludeSource       string
	Source              string
	InProjects          []string
	InEnvs              []string
}

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

type ProjectClusterRelationColl 

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

func NewProjectClusterRelationColl 

func NewProjectClusterRelationColl() *ProjectClusterRelationColl

func (*ProjectClusterRelationColl) Create 

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

func (*ProjectClusterRelationColl) GetCollectionName 

func (c *ProjectClusterRelationColl) GetCollectionName() string

type ProjectColl 

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

func NewProjectColl 

func NewProjectColl() *ProjectColl

func (*ProjectColl) GetCollectionName 

func (c *ProjectColl) GetCollectionName() string

func (*ProjectColl) List 

func (c *ProjectColl) List() ([]*models.Project, error)

type PvcColl 

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

func NewPvcColl 

func NewPvcColl() *PvcColl

func (*PvcColl) GetCollectionName 

func (c *PvcColl) GetCollectionName() string

func (*PvcColl) List 

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

type RegistryNamespaceColl 

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

func NewRegistryNamespaceColl 

func NewRegistryNamespaceColl() *RegistryNamespaceColl

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

type RenderSetColl 

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

func NewRenderSetColl 

func NewRenderSetColl() *RenderSetColl

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) Update 

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

func (*RenderSetColl) UpdateDefaultValues 

func (c *RenderSetColl) UpdateDefaultValues(renderSet *models.RenderSet) error

type RenderSetFindOption 

type RenderSetFindOption struct {
	// if Revision == 0 then search max revision of RenderSet
	ProductTmpl       string
	EnvName           string
	IsDefault         bool
	Revision          int64
	Name              string
	YamlVariableSetID string
}

RenderSetFindOption ...

type RenderSetListOption 

type RenderSetListOption struct {
	// if Revision == 0 then search max revision of RenderSet
	ProductTmpl   string
	Revisions     []int64
	RendersetName string
	FindOpts      []RenderSetFindOption
}

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 ScanningColl 

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

func NewScanningColl 

func NewScanningColl() *ScanningColl

func (*ScanningColl) List 

func (c *ScanningColl) List(opt *ScanningListOption) ([]*models.Scanning, error)

func (*ScanningColl) Update 

func (c *ScanningColl) Update(id primitive.ObjectID, update *models.Scanning) error

type ScanningListOption 

type ScanningListOption struct {
	Type string
}

type SecretColl 

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

func NewSecretColl 

func NewSecretColl() *SecretColl

func (*SecretColl) GetCollectionName 

func (c *SecretColl) GetCollectionName() string

func (*SecretColl) List 

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

type TestingColl 

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

func NewTestingColl 

func NewTestingColl() *TestingColl

func (*TestingColl) GetCollectionName 

func (c *TestingColl) GetCollectionName() string

func (*TestingColl) List 

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

type WorkflowColl 

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

func NewWorkflowColl 

func NewWorkflowColl() *WorkflowColl

func (*WorkflowColl) GetCollectionName 

func (c *WorkflowColl) GetCollectionName() string

func (*WorkflowColl) List 

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

type WorkflowTaskV4Coll 

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

func NewWorkflowTaskV4Coll 

func NewWorkflowTaskV4Coll() *WorkflowTaskV4Coll

func (*WorkflowTaskV4Coll) GetCollectionName 

func (c *WorkflowTaskV4Coll) GetCollectionName() string

func (*WorkflowTaskV4Coll) List 

func (c *WorkflowTaskV4Coll) List() ([]*models.WorkflowTask, error)

Source Files

View all Source files

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.