Versions in this module Expand all Collapse all v1 v1.0.0 Apr 2, 2026 Changes in this version + func CreateData(cName string, data interface{}) error + func DeleteByNamespace(cName, namespace string) error + func DeleteData(cName, name string) error + func GetAllData(cName string) ([]map[string]interface{}, error) + func GetCollection(dbName, cName string) *mongo.Collection + func GetData(cName, filterName string) (map[string]interface{}, error) + func GetDataByNamespace(cName, filterName string) ([]map[string]interface{}, error) + func GetFilteredData(cName string, opt model.GetOptions) ([]map[string]interface{}, error) + func MongoDBClient() *mongo.Client + func ToBson(v interface{}) (doc *bson.D, err error) + func UpdateData(cName string, data interface{}, filterName string) error + type MongoActivity struct + func NewMongoActivity() *MongoActivity + func (c *MongoActivity) GetActivityLog(namespace, objectName string, offset uint64, limit uint64) ([]map[string]interface{}, error) + type MongoCImetric struct + func NewCImetric() *MongoCImetric + func (c *MongoCImetric) GetCiMetrics(namespace string) (map[string]interface{}, error) + func (controller *MongoCImetric) DeleteMetrics(namespace string) error + func (controller *MongoCImetric) UpdateMetrics(name string, metric string) error + type MongoCertificate struct + func NewCertificate() *MongoCertificate + func (c *MongoCertificate) DeleteCertificateDetail(namespace string) error + func (c *MongoCertificate) GetCertificateDetail(namespace string) ([]map[string]interface{}, error) + func (c *MongoCertificate) StoreCertificateDetail(data map[string]interface{}) error + type MongoCiWorkflow struct + func NewMongoCiWorkflow() *MongoCiWorkflow + func (c *MongoCiWorkflow) DeleteCIPodData(namespace string) error + func (c *MongoCiWorkflow) DeleteCIWorkflow(namespace string) error + func (c *MongoCiWorkflow) DeleteWorkflow(namespace string, workflowId string) error + func (c *MongoCiWorkflow) GetBuildImages(namespace string, offset int, limit int) ([]map[string]string, error) + func (c *MongoCiWorkflow) GetLatestWorkflow(namespace string) (*model.WorkflowMetadata, error) + func (c *MongoCiWorkflow) GetWorkflow(name string) (map[string]interface{}, error) + func (c *MongoCiWorkflow) GetWorkflowCount(namespace, startdate, enddate string) (int, error) + func (c *MongoCiWorkflow) GetWorkflowDetail(namespace string, offset int, limit int) ([]*model.WorkflowMetadata, error) + func (c *MongoCiWorkflow) GetWorkflowLog(name string) (map[string]interface{}, error) + func (controller *MongoCiWorkflow) StoreEventData(data *corev1.Event) error + func (controller *MongoCiWorkflow) StorePodData(data model.PodLogsData) error + func (controller *MongoCiWorkflow) StoreWorkflow(data model.PublishDataCi) error + func (controller *MongoCiWorkflow) UpdateWorkflow(data model.PublishDataCi) error + type MongoClusterWorkflow struct + func NewMongoClusterWorkflow() *MongoClusterWorkflow + func (c *MongoClusterWorkflow) GetClusterWorkflowDetail(namespace string, offset int, limit int) ([]*model.ClusterWorkflowMetadata, error) + func (c *MongoClusterWorkflow) GetCreateClusterWorkflow(name string) (*model.ClusterWorkflowMetadata, error) + func (c *MongoClusterWorkflow) GetCreateClusterWorkflowLog(name string) (map[string]interface{}, error) + func (controller *MongoClusterWorkflow) DeleteWorkflowByNamespace(namespace string) error + func (controller *MongoClusterWorkflow) DeleteWorkflowLogsByNamespace(namespace string) error + func (controller *MongoClusterWorkflow) StoreWorkflow(data model.PublishData) + func (controller *MongoClusterWorkflow) UpdateWorkflow(data model.PublishData) + type MongoCronjob struct + func NewMongoCronjob() *MongoCronjob + func (c *MongoCronjob) DeleteCronJob(namespace string, id uint) error + func (c *MongoCronjob) DeleteCronJobByNamespace(namespace string) error + func (c *MongoCronjob) DeleteCronJobLogs(namespace string, name string) error + func (c *MongoCronjob) DeleteCronJobLogsByNamespace(namespace string) error + func (c *MongoCronjob) GetCronJobLogs(namespace string, name string, page int, limit int) ([]map[string]interface{}, error) + func (c *MongoCronjob) GetCronJobStatus(namespace string) ([]map[string]interface{}, error) + func (c *MongoCronjob) StoreCronJob(job model.CronJobPublish) error + func (c *MongoCronjob) StoreCronJobLogs(data model.JobLog) error + func (c *MongoCronjob) StoreJob(job model.JobPublish) error + type MongoEnvironmentLog struct + func NewMongoEnvironmentLog() *MongoEnvironmentLog + func (c *MongoEnvironmentLog) DeleteEnvironmentLogs(namespace string) error + func (c *MongoEnvironmentLog) StoreEnvironmentLogs(data model.EnvironmentLog) error + type MongoEvent struct + func NewEvent() *MongoEvent + func (c *MongoEvent) DeleteEventData(namespace string) error + func (c *MongoEvent) StoreEventData(data *v1.Event) error + func (c *MongoEvent) StoreEventError(data *metav1.Status) error + type MongoLoadbalancer struct + func NewMongoLoadbalancer() *MongoLoadbalancer + func (c *MongoLoadbalancer) DeleteLoadbalancer(namespace string) error + func (c *MongoLoadbalancer) GetLoadbalancerStatus(namespace string) (map[string]interface{}, error) + func (c *MongoLoadbalancer) StoreLoadBalancerStatus(ns string, data map[string]interface{}) error + type MongoPodState struct + func NewMongoPodState() *MongoPodState + func (c *MongoPodState) DeletePodData(namespace string) error + func (c *MongoPodState) DeletePodState(namespace string) []map[string]interface{} + func (c *MongoPodState) GetAddOnState(namespace string) ([]map[string]interface{}, error) + func (c *MongoPodState) GetEnvironmentState(namespace string) ([]map[string]interface{}, string, bool, error) + func (c *MongoPodState) GetPodStatus(namespace string) ([]map[string]interface{}, error) + func (c *MongoPodState) StorePodEventData(i int, data *model.PodEvent) error + func (c *MongoPodState) StorePodState(i int, data *model.EnvironmentState) error + func (controller *MongoPodState) StorePodData(data model.PodLogsData) + type MongoReleaseInfo struct + func NewMongoReleaseInfo() *MongoReleaseInfo + func (c *MongoReleaseInfo) DeleteReleaseMeta(releaseId string) error + func (c *MongoReleaseInfo) DeleteRevison(namespace string) error + func (c *MongoReleaseInfo) GetData(releaseId string) (*model.K8sRelease, error) + func (c *MongoReleaseInfo) GetRevisonData(releaseId string) (*model.RevisionHistory, error) + func (c *MongoReleaseInfo) StoreRelease(releaseId string, data *model.HelmRelease, valuesString string, cname string) error + func (c *MongoReleaseInfo) StoreRevison(tag string, result *model.HelmRelease) error + type MongoService struct + func NewService() *MongoService + func (c *MongoService) DeleteServiceData(namespace string) error + func (c *MongoService) StoreServiceData(data *corev1.ServiceList, namespace string) error + type MongoStorage struct + func NewStorage() *MongoStorage + func (c *MongoStorage) DeleteStorageData(namespace string) error + func (c *MongoStorage) DeleteStorageDataAll(namespace string) error + func (c *MongoStorage) DeleteStorageDataById(namespace string, id uint) error + func (c *MongoStorage) GetStorageState(namespace string) ([]map[string]interface{}, error) + func (c *MongoStorage) SetStorageData(namespace string, data *corev1.PersistentVolumeClaimList) + func (c *MongoStorage) StorageData(data model.StoragePublish) error