mongodb

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateData 

func CreateData(cName string, data interface{}) error

func DeleteByNamespace 

func DeleteByNamespace(cName, namespace string) error

func DeleteData 

func DeleteData(cName, name string) error

func GetAllData 

func GetAllData(cName string) ([]map[string]interface{}, error)

func GetCollection 

func GetCollection(dbName, cName string) *mongo.Collection

func GetData 

func GetData(cName, filterName string) (map[string]interface{}, error)

func GetDataByNamespace 

func GetDataByNamespace(cName, filterName string) ([]map[string]interface{}, error)

func GetFilteredData 

func GetFilteredData(cName string, opt model.GetOptions) ([]map[string]interface{}, error)

func MongoDBClient 

func MongoDBClient() *mongo.Client

func ToBson 

func ToBson(v interface{}) (doc *bson.D, err error)

func UpdateData 

func UpdateData(cName string, data interface{}, filterName string) error

Types

type MongoActivity 

type MongoActivity struct {
}

func NewMongoActivity 

func NewMongoActivity() *MongoActivity

func (*MongoActivity) GetActivityLog 

func (c *MongoActivity) GetActivityLog(namespace, objectName string, offset uint64, limit uint64) ([]map[string]interface{}, error)

type MongoCImetric 

type MongoCImetric struct {
}

func NewCImetric 

func NewCImetric() *MongoCImetric

func (*MongoCImetric) DeleteMetrics 

func (controller *MongoCImetric) DeleteMetrics(namespace string) error

func (*MongoCImetric) GetCiMetrics 

func (c *MongoCImetric) GetCiMetrics(namespace string) (map[string]interface{}, error)

func (*MongoCImetric) UpdateMetrics 

func (controller *MongoCImetric) UpdateMetrics(name string, metric string) error

UpdateMetrics updates the ci build job metrics to firestore ie. success count , Failure count etc.

type MongoCertificate 

type MongoCertificate struct {
}

func NewCertificate 

func NewCertificate() *MongoCertificate

func (*MongoCertificate) DeleteCertificateDetail 

func (c *MongoCertificate) DeleteCertificateDetail(namespace string) error

func (*MongoCertificate) GetCertificateDetail 

func (c *MongoCertificate) GetCertificateDetail(namespace string) ([]map[string]interface{}, error)

func (*MongoCertificate) StoreCertificateDetail 

func (c *MongoCertificate) StoreCertificateDetail(data map[string]interface{}) error

type MongoCiWorkflow 

type MongoCiWorkflow struct {
}

func NewMongoCiWorkflow 

func NewMongoCiWorkflow() *MongoCiWorkflow

func (*MongoCiWorkflow) DeleteCIPodData 

func (c *MongoCiWorkflow) DeleteCIPodData(namespace string) error

func (*MongoCiWorkflow) DeleteCIWorkflow 

func (c *MongoCiWorkflow) DeleteCIWorkflow(namespace string) error

func (*MongoCiWorkflow) DeleteWorkflow 

func (c *MongoCiWorkflow) DeleteWorkflow(namespace string, workflowId string) error

func (*MongoCiWorkflow) GetBuildImages 

func (c *MongoCiWorkflow) GetBuildImages(namespace string, offset int, limit int) ([]map[string]string, error)

func (*MongoCiWorkflow) GetLatestWorkflow 

func (c *MongoCiWorkflow) GetLatestWorkflow(namespace string) (*model.WorkflowMetadata, error)

func (*MongoCiWorkflow) GetWorkflow 

func (c *MongoCiWorkflow) GetWorkflow(name string) (map[string]interface{}, error)

func (*MongoCiWorkflow) GetWorkflowCount 

func (c *MongoCiWorkflow) GetWorkflowCount(namespace, startdate, enddate string) (int, error)

func (*MongoCiWorkflow) GetWorkflowDetail 

func (c *MongoCiWorkflow) GetWorkflowDetail(namespace string, offset int, limit int) ([]*model.WorkflowMetadata, error)

func (*MongoCiWorkflow) GetWorkflowLog 

func (c *MongoCiWorkflow) GetWorkflowLog(name string) (map[string]interface{}, error)

func (*MongoCiWorkflow) StoreEventData 

func (controller *MongoCiWorkflow) StoreEventData(data *corev1.Event) error

StoreEventData stores the event data to Firestore ie. Build success event or Failure envent etc.

func (*MongoCiWorkflow) StorePodData 

func (controller *MongoCiWorkflow) StorePodData(data model.PodLogsData) error

StorePodData stores the logs of every pod which are used in building the job

func (*MongoCiWorkflow) StoreWorkflow 

func (controller *MongoCiWorkflow) StoreWorkflow(data model.PublishDataCi) error

StoreWorkflow stores the workflow to the firestore

func (*MongoCiWorkflow) UpdateWorkflow 

func (controller *MongoCiWorkflow) UpdateWorkflow(data model.PublishDataCi) error

UpdateWorkflow updates workflow in the firestore after some changes happens in the workflow object

type MongoClusterWorkflow 

type MongoClusterWorkflow struct {
}

func NewMongoClusterWorkflow 

func NewMongoClusterWorkflow() *MongoClusterWorkflow

func (*MongoClusterWorkflow) DeleteWorkflowByNamespace 

func (controller *MongoClusterWorkflow) DeleteWorkflowByNamespace(namespace string) error

func (*MongoClusterWorkflow) DeleteWorkflowLogsByNamespace 

func (controller *MongoClusterWorkflow) DeleteWorkflowLogsByNamespace(namespace string) error

func (*MongoClusterWorkflow) GetClusterWorkflowDetail 

func (c *MongoClusterWorkflow) GetClusterWorkflowDetail(namespace string, offset int, limit int) ([]*model.ClusterWorkflowMetadata, error)

func (*MongoClusterWorkflow) GetCreateClusterWorkflow 

func (c *MongoClusterWorkflow) GetCreateClusterWorkflow(name string) (*model.ClusterWorkflowMetadata, error)

func (*MongoClusterWorkflow) GetCreateClusterWorkflowLog 

func (c *MongoClusterWorkflow) GetCreateClusterWorkflowLog(name string) (map[string]interface{}, error)

func (*MongoClusterWorkflow) StoreWorkflow 

func (controller *MongoClusterWorkflow) StoreWorkflow(data model.PublishData)

func (*MongoClusterWorkflow) UpdateWorkflow 

func (controller *MongoClusterWorkflow) UpdateWorkflow(data model.PublishData)

UpdateWorkflow updates create-cluster in the firestore after some changes happens in the create-cluster object

type MongoCronjob 

type MongoCronjob struct {
}

func NewMongoCronjob 

func NewMongoCronjob() *MongoCronjob

func (*MongoCronjob) DeleteCronJob 

func (c *MongoCronjob) DeleteCronJob(namespace string, id uint) error

func (*MongoCronjob) DeleteCronJobByNamespace 

func (c *MongoCronjob) DeleteCronJobByNamespace(namespace string) error

func (*MongoCronjob) DeleteCronJobLogs 

func (c *MongoCronjob) DeleteCronJobLogs(namespace string, name string) error

func (*MongoCronjob) DeleteCronJobLogsByNamespace 

func (c *MongoCronjob) DeleteCronJobLogsByNamespace(namespace string) error

func (*MongoCronjob) GetCronJobLogs 

func (c *MongoCronjob) GetCronJobLogs(namespace string, name string, page int, limit int) ([]map[string]interface{}, error)

func (*MongoCronjob) GetCronJobStatus 

func (c *MongoCronjob) GetCronJobStatus(namespace string) ([]map[string]interface{}, error)

func (*MongoCronjob) StoreCronJob 

func (c *MongoCronjob) StoreCronJob(job model.CronJobPublish) error

func (*MongoCronjob) StoreCronJobLogs 

func (c *MongoCronjob) StoreCronJobLogs(data model.JobLog) error

func (*MongoCronjob) StoreJob 

func (c *MongoCronjob) StoreJob(job model.JobPublish) error

type MongoEnvironmentLog 

type MongoEnvironmentLog struct {
}

func NewMongoEnvironmentLog 

func NewMongoEnvironmentLog() *MongoEnvironmentLog

func (*MongoEnvironmentLog) DeleteEnvironmentLogs 

func (c *MongoEnvironmentLog) DeleteEnvironmentLogs(namespace string) error

func (*MongoEnvironmentLog) StoreEnvironmentLogs 

func (c *MongoEnvironmentLog) StoreEnvironmentLogs(data model.EnvironmentLog) error

type MongoEvent 

type MongoEvent struct{}

func NewEvent 

func NewEvent() *MongoEvent

func (*MongoEvent) DeleteEventData 

func (c *MongoEvent) DeleteEventData(namespace string) error

func (*MongoEvent) StoreEventData 

func (c *MongoEvent) StoreEventData(data *v1.Event) error

func (*MongoEvent) StoreEventError 

func (c *MongoEvent) StoreEventError(data *metav1.Status) error

type MongoLoadbalancer 

type MongoLoadbalancer struct {
}

func NewMongoLoadbalancer 

func NewMongoLoadbalancer() *MongoLoadbalancer

func (*MongoLoadbalancer) DeleteLoadbalancer 

func (c *MongoLoadbalancer) DeleteLoadbalancer(namespace string) error

func (*MongoLoadbalancer) GetLoadbalancerStatus 

func (c *MongoLoadbalancer) GetLoadbalancerStatus(namespace string) (map[string]interface{}, error)

func (*MongoLoadbalancer) StoreLoadBalancerStatus 

func (c *MongoLoadbalancer) StoreLoadBalancerStatus(ns string, data map[string]interface{}) error

type MongoPodState 

type MongoPodState struct{}

func NewMongoPodState 

func NewMongoPodState() *MongoPodState

func (*MongoPodState) DeletePodData 

func (c *MongoPodState) DeletePodData(namespace string) error

func (*MongoPodState) DeletePodState 

func (c *MongoPodState) DeletePodState(namespace string) []map[string]interface{}

func (*MongoPodState) GetAddOnState 

func (c *MongoPodState) GetAddOnState(namespace string) ([]map[string]interface{}, error)

func (*MongoPodState) GetEnvironmentState 

func (c *MongoPodState) GetEnvironmentState(namespace string) ([]map[string]interface{}, string, bool, error)

func (*MongoPodState) GetPodStatus 

func (c *MongoPodState) GetPodStatus(namespace string) ([]map[string]interface{}, error)

func (*MongoPodState) StorePodData 

func (controller *MongoPodState) StorePodData(data model.PodLogsData)

func (*MongoPodState) StorePodEventData 

func (c *MongoPodState) StorePodEventData(i int, data *model.PodEvent) error

func (*MongoPodState) StorePodState 

func (c *MongoPodState) StorePodState(i int, data *model.EnvironmentState) error

type MongoReleaseInfo 

type MongoReleaseInfo struct{}

func NewMongoReleaseInfo 

func NewMongoReleaseInfo() *MongoReleaseInfo

func (*MongoReleaseInfo) DeleteReleaseMeta 

func (c *MongoReleaseInfo) DeleteReleaseMeta(releaseId string) error

func (*MongoReleaseInfo) DeleteRevison 

func (c *MongoReleaseInfo) DeleteRevison(namespace string) error

func (*MongoReleaseInfo) GetData 

func (c *MongoReleaseInfo) GetData(releaseId string) (*model.K8sRelease, error)

func (*MongoReleaseInfo) GetRevisonData 

func (c *MongoReleaseInfo) GetRevisonData(releaseId string) (*model.RevisionHistory, error)

func (*MongoReleaseInfo) StoreRelease 

func (c *MongoReleaseInfo) StoreRelease(releaseId string, data *model.HelmRelease, valuesString string, cname string) error

func (*MongoReleaseInfo) StoreRevison 

func (c *MongoReleaseInfo) StoreRevison(tag string, result *model.HelmRelease) error

type MongoService 

type MongoService struct{}

func NewService 

func NewService() *MongoService

func (*MongoService) DeleteServiceData 

func (c *MongoService) DeleteServiceData(namespace string) error

func (*MongoService) StoreServiceData 

func (c *MongoService) StoreServiceData(data *corev1.ServiceList, namespace string) error

type MongoStorage 

type MongoStorage struct{}

func NewStorage 

func NewStorage() *MongoStorage

func (*MongoStorage) DeleteStorageData 

func (c *MongoStorage) DeleteStorageData(namespace string) error

DeleteStorageData implements store.StorageInterface

func (*MongoStorage) DeleteStorageDataAll 

func (c *MongoStorage) DeleteStorageDataAll(namespace string) error

DeleteStorageDataAll implements store.StorageInterface

func (*MongoStorage) DeleteStorageDataById 

func (c *MongoStorage) DeleteStorageDataById(namespace string, id uint) error

DeleteStorageDataById implements store.StorageInterface

func (*MongoStorage) GetStorageState 

func (c *MongoStorage) GetStorageState(namespace string) ([]map[string]interface{}, error)

GetStorageState implements store.StorageInterface

func (*MongoStorage) SetStorageData 

func (c *MongoStorage) SetStorageData(namespace string, data *corev1.PersistentVolumeClaimList)

SetStorageData implements store.StorageInterface

func (*MongoStorage) StorageData 

func (c *MongoStorage) StorageData(data model.StoragePublish) error

StorageData implements store.StorageInterface

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.