repository

Oct 2, 2024

Changes in this version

type CiArtifactRepository

+ IfArtifactExistByImage func(imageName string, pipelineId int) (exist bool, err error)

+ IfArtifactExistByImageDigest func(imageDigest string, imageName string, pipelineId int) (exist bool, err error)

type CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) IfArtifactExistByImage(imageName string, pipelineId int) (exist bool, err error)

+ func (impl CiArtifactRepositoryImpl) IfArtifactExistByImageDigest(imageDigest string, imageName string, pipelineId int) (exist bool, err error)

type ImageTagRepository

+ GetImagePathsByIds func(ids []int) ([]*ImagePathReservation, error)

type ImageTagRepositoryImpl

+ func (impl *ImageTagRepositoryImpl) GetImagePathsByIds(ids []int) ([]*ImagePathReservation, error)

Aug 26, 2024

Changes in this version

type GitHost

+ DisplayName string

type GitOpsConfig

+ CaCert string

+ EnableTLSVerification bool

+ TlsCert string

+ TlsKey string

type GitProvider

+ CaCert string

+ EnableTLSVerification bool

+ TlsCert string

+ TlsKey string

type ImageTagRepository

+ FetchActiveCustomTagDataList func(entityValues []string) ([]*CustomTag, error)

type ImageTagRepositoryImpl

+ func (impl *ImageTagRepositoryImpl) FetchActiveCustomTagDataList(entityValues []string) ([]*CustomTag, error)

Jun 7, 2024

Changes in this version

type GitOpsConfigRepository

+ GetAllGitOpsConfigCount func() (int, error)

type GitOpsConfigRepositoryImpl

+ func (impl *GitOpsConfigRepositoryImpl) GetAllGitOpsConfigCount() (int, error)

type GitProviderRepository

+ FindAllGitProviderCount func() (int, error)

type GitProviderRepositoryImpl

+ func (impl GitProviderRepositoryImpl) FindAllGitProviderCount() (int, error)

type LastDeployed

+ CiArtifactId int

type NotificationSettings

+ AdditionalConfigJson string

+ NotificationRuleId int

type NotificationSettingsView

+ Internal bool

Apr 13, 2024

Changes in this version

type CiArtifact

+ func (artifact *CiArtifact) IsRegistryCredentialMapped() bool

type DeploymentTemplateComparisonMetadata

+ ChartRefId int

type GitOpsConfig

+ AllowCustomRepository bool

Mar 13, 2024

Changes in this version

+ type ArtifactsSourceType = string

+ const EXT

type CiArtifact

+ func (c *CiArtifact) IsMigrationRequired() bool

type CiArtifactRepository

+ MigrateToWebHookDataSourceType func(id int) error

type CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) MigrateToWebHookDataSourceType(id int) error

Dec 14, 2023

Changes in this version

+ const CI_RUNNER

+ const EmptyLikeRegex

+ const GLOBAL_CONTAINER_REGISTRY

+ const GOCD

+ const Hibernating

+ const POST_CD

+ const POST_CI

+ const PRE_CD

+ const PRE_CI

+ const WEBHOOK

+ func BuildQueryForArtifactsForCdStage(listingFilterOptions bean.ArtifactsListFilterOptions) string

+ func BuildQueryForArtifactsForRollback(listingFilterOptions bean.ArtifactsListFilterOptions) string

+ func BuildQueryForParentTypeCIOrWebhook(listingFilterOpts bean.ArtifactsListFilterOptions) string

type AppListingRepository

+ FetchLastDeployedImage func(appId, envId int) (*LastDeployed, error)

type AppListingRepositoryImpl

+ func (impl AppListingRepositoryImpl) FetchLastDeployedImage(appId, envId int) (*LastDeployed, error)

type CiArtifact

+ ComponentId int

+ CredentialSourceValue string

+ CredentialsSourceType string

type CiArtifactRepository

+ FetchArtifactsByCdPipelineIdV2 func(listingFilterOptions bean.ArtifactsListFilterOptions) ([]CiArtifactWithExtraData, int, error)

+ FindArtifactByListFilter func(listingFilterOptions *bean.ArtifactsListFilterOptions) ([]CiArtifact, int, error)

+ FindCiArtifactByImagePaths func(images []string) ([]CiArtifact, error)

+ GetArtifactsByCDPipelineV3 func(listingFilterOpts *bean.ArtifactsListFilterOptions) ([]*CiArtifact, int, error)

+ GetArtifactsByCiPipelineIds func(ciPipelineIds []int) ([]CiArtifact, error)

+ GetArtifactsByDataSourceAndComponentId func(dataSource string, componentId int) ([]CiArtifact, error)

+ UpdateLatestTimestamp func(artifactIds []int) error

type CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) FetchArtifactsByCdPipelineIdV2(listingFilterOptions bean.ArtifactsListFilterOptions) ([]CiArtifactWithExtraData, int, error)

+ func (impl CiArtifactRepositoryImpl) FindArtifactByListFilter(listingFilterOptions *bean.ArtifactsListFilterOptions) ([]CiArtifact, int, error)

+ func (impl CiArtifactRepositoryImpl) FindCiArtifactByImagePaths(images []string) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineV3(listingFilterOpts *bean.ArtifactsListFilterOptions) ([]*CiArtifact, int, error)

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByCiPipelineIds(ciPipelineIds []int) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByDataSourceAndComponentId(dataSource string, componentId int) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) UpdateLatestTimestamp(artifactIds []int) error

+ type CiArtifactWithExtraData struct

+ CdWorkflowRunnerId int

+ PayloadSchema string

+ StartedOn time.Time

+ TotalCount int

+ TriggeredBy int32

type CustomTag

+ Enabled bool

type ImageTagRepository

+ DeactivateImagePathReservationByImagePathReservationIds func(tx *pg.Tx, imagePathReservationIds []int) error

+ DeactivateImagePathReservationByImagePaths func(tx *pg.Tx, imagePaths []string) error

+ DisableCustomTag func(entityKey int, entityValue string) error

type ImageTagRepositoryImpl

+ func (impl *ImageTagRepositoryImpl) DeactivateImagePathReservationByImagePathReservationIds(tx *pg.Tx, imagePathReservationIds []int) error

+ func (impl *ImageTagRepositoryImpl) DeactivateImagePathReservationByImagePaths(tx *pg.Tx, imagePaths []string) error

+ func (impl *ImageTagRepositoryImpl) DisableCustomTag(entityKey int, entityValue string) error

+ type LastDeployed struct

+ LastDeployedBy string

+ LastDeployedImage string

Dec 7, 2023

Changes in this version

+ type CustomTag struct

+ Active bool

+ AutoIncreasingNumber int

+ EntityKey int

+ EntityValue string

+ Id int

+ Metadata string

+ TagPattern string

+ type ImagePathReservation struct

+ CustomTagId int

+ Id int

+ ImagePath string

+ type ImageTagRepository interface

+ CreateImageTag func(customTagData *CustomTag) error

+ DeactivateImagePathReservation func(id int) error

+ DeleteByEntityKeyAndValue func(entityKey int, entityValue string) error

+ FetchActiveCustomTagData func(entityKey int, entityValue string) (*CustomTag, error)

+ FetchCustomTagData func(entityType int, entityValue string) (*CustomTag, error)

+ FindByImagePath func(tx *pg.Tx, path string) ([]*ImagePathReservation, error)

+ GetConnection func() *pg.DB

+ IncrementAndFetchByEntityKeyAndValue func(tx *pg.Tx, entityKey int, entityValue string) (*CustomTag, error)

+ InsertImagePath func(tx *pg.Tx, reservation *ImagePathReservation) error

+ UpdateImageTag func(customTag *CustomTag) error

+ type ImageTagRepositoryImpl struct

+ func NewImageTagRepository(dbConnection *pg.DB, logger *zap.SugaredLogger) *ImageTagRepositoryImpl

+ func (impl *ImageTagRepositoryImpl) CreateImageTag(customTagData *CustomTag) error

+ func (impl *ImageTagRepositoryImpl) DeactivateImagePathReservation(id int) error

+ func (impl *ImageTagRepositoryImpl) DeleteByEntityKeyAndValue(entityKey int, entityValue string) error

+ func (impl *ImageTagRepositoryImpl) FetchActiveCustomTagData(entityType int, entityValue string) (*CustomTag, error)

+ func (impl *ImageTagRepositoryImpl) FetchCustomTagData(entityType int, entityValue string) (*CustomTag, error)

+ func (impl *ImageTagRepositoryImpl) FindByImagePath(tx *pg.Tx, path string) ([]*ImagePathReservation, error)

+ func (impl *ImageTagRepositoryImpl) GetConnection() *pg.DB

+ func (impl *ImageTagRepositoryImpl) IncrementAndFetchByEntityKeyAndValue(tx *pg.Tx, entityKey int, entityValue string) (*CustomTag, error)

+ func (impl *ImageTagRepositoryImpl) InsertImagePath(tx *pg.Tx, reservation *ImagePathReservation) error

+ func (impl *ImageTagRepositoryImpl) UpdateImageTag(customTag *CustomTag) error

Oct 29, 2023

Changes in this version

type CiArtifactRepository

+ GetArtifactsByParentCiWorkflowId func(parentCiWorkflowId int) ([]string, error)

+ GetLatestArtifactTimeByCiPipelineId func(ciPipelineId int) (*CiArtifact, error)

+ GetLatestArtifactTimeByCiPipelineIds func(ciPipelineIds []int) ([]*CiArtifact, error)

type CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByParentCiWorkflowId(parentCiWorkflowId int) ([]string, error)

+ func (impl CiArtifactRepositoryImpl) GetLatestArtifactTimeByCiPipelineId(ciPipelineId int) (*CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetLatestArtifactTimeByCiPipelineIds(ciPipelineIds []int) ([]*CiArtifact, error)

+ type DeploymentTemplateComparisonMetadata struct

+ ChartId int

+ ChartType string

+ ChartVersion string

+ DeploymentTemplateHistoryId int

+ EnvironmentId int

+ EnvironmentName string

+ FinishedOn *time.Time

+ PipelineId int

+ StartedOn *time.Time

+ Status string

+ Type DeploymentTemplateType

+ type DeploymentTemplateRepository interface

+ FetchDeploymentHistoryWithChartRefs func(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)

+ FetchLatestDeploymentWithChartRefs func(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)

+ FetchPipelineOverrideValues func(id int) (string, error)

+ type DeploymentTemplateRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewDeploymentTemplateRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *DeploymentTemplateRepositoryImpl

+ func (impl DeploymentTemplateRepositoryImpl) FetchDeploymentHistoryWithChartRefs(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)

+ func (impl DeploymentTemplateRepositoryImpl) FetchLatestDeploymentWithChartRefs(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)

+ func (impl DeploymentTemplateRepositoryImpl) FetchPipelineOverrideValues(id int) (string, error)

+ type DeploymentTemplateType int

+ const DefaultVersions

+ const DeployedOnOtherEnvironment

+ const DeployedOnSelfEnvironment

+ const PublishedOnEnvironments

Jul 3, 2023

Changes in this version

+ type WebhookConfig struct

+ Active bool

+ ConfigName string

+ Deleted bool

+ Description string

+ Header map[string]interface{}

+ Id int

+ OwnerId int32

+ Payload map[string]interface{}

+ WebHookUrl string

+ type WebhookNotificationRepository interface

+ FindAll func() ([]WebhookConfig, error)

+ FindByIds func(ids []*int) ([]*WebhookConfig, error)

+ FindByName func(value string) ([]WebhookConfig, error)

+ FindOne func(id int) (*WebhookConfig, error)

+ MarkWebhookConfigDeleted func(webhookConfig *WebhookConfig) error

+ SaveWebhookConfig func(webhookConfig *WebhookConfig) (*WebhookConfig, error)

+ UpdateWebhookConfig func(webhookConfig *WebhookConfig) (*WebhookConfig, error)

+ type WebhookNotificationRepositoryImpl struct

+ func NewWebhookNotificationRepositoryImpl(dbConnection *pg.DB) *WebhookNotificationRepositoryImpl

+ func (impl *WebhookNotificationRepositoryImpl) FindAll() ([]WebhookConfig, error)

+ func (impl *WebhookNotificationRepositoryImpl) FindByName(value string) ([]WebhookConfig, error)

+ func (impl *WebhookNotificationRepositoryImpl) FindOne(id int) (*WebhookConfig, error)

+ func (impl *WebhookNotificationRepositoryImpl) MarkWebhookConfigDeleted(webhookConfig *WebhookConfig) error

+ func (impl *WebhookNotificationRepositoryImpl) SaveWebhookConfig(webhookConfig *WebhookConfig) (*WebhookConfig, error)

+ func (impl *WebhookNotificationRepositoryImpl) UpdateWebhookConfig(webhookConfig *WebhookConfig) (*WebhookConfig, error)

+ func (repo *WebhookNotificationRepositoryImpl) FindByIds(ids []*int) ([]*WebhookConfig, error)

Jun 1, 2023

Changes in this version

type AppListingRepository

+ FetchAppsByEnvironmentV2 func(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, int, error)

+ FetchMinDetailOtherEnvironment func(appId int) ([]*bean.Environment, error)

+ FetchOverviewAppsByEnvironment func(envId, limit, offset int) ([]*bean.AppEnvironmentContainer, error)

type AppListingRepositoryImpl

+ func (impl AppListingRepositoryImpl) FetchAppsByEnvironmentV2(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, int, error)

+ func (impl AppListingRepositoryImpl) FetchMinDetailOtherEnvironment(appId int) ([]*bean.Environment, error)

+ func (impl AppListingRepositoryImpl) FetchOverviewAppsByEnvironment(envId, limit, offset int) ([]*bean.AppEnvironmentContainer, error)

type CiArtifactRepository

+ GetArtifactParentCiAndWorkflowDetailsByIds func(ids []int) ([]*CiArtifact, error)

type CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) GetArtifactParentCiAndWorkflowDetailsByIds(ids []int) ([]*CiArtifact, error)

type EnvLevelAppMetricsRepository

+ FindByAppIdAndEnvIds func(appId int, envIds []int) ([]*EnvLevelAppMetrics, error)

type EnvLevelAppMetricsRepositoryImpl

+ func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppIdAndEnvIds(appId int, envIds []int) ([]*EnvLevelAppMetrics, error)

Apr 11, 2023

Changes in this version

+ const PIPELINE_TYPE_CD

+ const PIPELINE_TYPE_CI

+ const PIPELINE_TYPE_CI_CD

type AppListingRepository

+ FetchJobs func(appIds []int, statuses []string, sortOrder string) ([]*bean.JobListingContainer, error)

+ FetchJobsLastSucceededOn func(ciPipelineIDs []int) ([]*bean.CiPipelineLastSucceededTime, error)

+ FetchOverviewCiPipelines func(jobId int) ([]*bean.JobListingContainer, error)

type AppListingRepositoryImpl

+ func (impl AppListingRepositoryImpl) FetchJobs(appIds []int, statuses []string, sortOrder string) ([]*bean.JobListingContainer, error)

+ func (impl AppListingRepositoryImpl) FetchJobsLastSucceededOn(CiPipelineIDs []int) ([]*bean.CiPipelineLastSucceededTime, error)

+ func (impl AppListingRepositoryImpl) FetchOverviewCiPipelines(jobId int) ([]*bean.JobListingContainer, error)

type CiArtifact

+ IsArtifactUploaded bool

type GlobalCMCS

+ SecretIngestionFor string

type GlobalCMCSRepository

+ Delete func(model *GlobalCMCS) error

+ FindAllActiveByPipelineType func(pipelineType string) ([]*GlobalCMCS, error)

+ FindById func(id int) (*GlobalCMCS, error)

type GlobalCMCSRepositoryImpl

+ func (impl *GlobalCMCSRepositoryImpl) Delete(model *GlobalCMCS) error

+ func (impl *GlobalCMCSRepositoryImpl) FindAllActiveByPipelineType(pipelineType string) ([]*GlobalCMCS, error)

+ func (impl *GlobalCMCSRepositoryImpl) FindById(id int) (*GlobalCMCS, error)

Jan 9, 2023

Changes in this version

+ type TerminalAccessRepository interface

+ FetchAllTemplates func() ([]*models.TerminalAccessTemplates, error)

+ FetchTerminalAccessTemplate func(templateName string) (*models.TerminalAccessTemplates, error)

+ GetAllRunningUserTerminalData func() ([]*models.UserTerminalAccessData, error)

+ GetUserTerminalAccessData func(id int) (*models.UserTerminalAccessData, error)

+ SaveUserTerminalAccessData func(data *models.UserTerminalAccessData) error

+ UpdateUserTerminalAccessData func(data *models.UserTerminalAccessData) error

+ UpdateUserTerminalStatus func(id int, status string) error

+ type TerminalAccessRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewTerminalAccessRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *TerminalAccessRepositoryImpl

+ func (impl TerminalAccessRepositoryImpl) FetchAllTemplates() ([]*models.TerminalAccessTemplates, error)

+ func (impl TerminalAccessRepositoryImpl) FetchTerminalAccessTemplate(templateName string) (*models.TerminalAccessTemplates, error)

+ func (impl TerminalAccessRepositoryImpl) GetAllRunningUserTerminalData() ([]*models.UserTerminalAccessData, error)

+ func (impl TerminalAccessRepositoryImpl) GetUserTerminalAccessData(id int) (*models.UserTerminalAccessData, error)

+ func (impl TerminalAccessRepositoryImpl) SaveUserTerminalAccessData(data *models.UserTerminalAccessData) error

+ func (impl TerminalAccessRepositoryImpl) UpdateUserTerminalAccessData(data *models.UserTerminalAccessData) error

+ func (impl TerminalAccessRepositoryImpl) UpdateUserTerminalStatus(id int, status string) error

Dec 14, 2022

Changes in this version

+ type AppNameTypeIdContainerDBResponse struct

+ AppId int

+ AppName string

type CiArtifact

+ ExternalCiPipelineId int

type CiArtifactRepository

+ Delete func(artifact *CiArtifact) error

type CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) Delete(artifact *CiArtifact) error

Nov 23, 2022

Changes in this version

type UserAttributesRepository

+ GetUserDataByEmailId func(emailId string) (string, error)

type UserAttributesRepositoryImpl

+ func (repo UserAttributesRepositoryImpl) GetUserDataByEmailId(emailId string) (string, error)

Nov 1, 2022

Changes in this version

type DeploymentGroupRepository

+ GetNamesByAppIdAndEnvId func(envId, appId int) ([]string, error)

type DeploymentGroupRepositoryImpl

+ func (impl *DeploymentGroupRepositoryImpl) GetNamesByAppIdAndEnvId(envId, appId int) ([]string, error)

Oct 8, 2022

Changes in this version

+ const CM_TYPE_CONFIG

+ const CS_TYPE_CONFIG

+ const ENVIRONMENT_CONFIG

+ const VOLUME_CONFIG

+ type GlobalCMCS struct

+ ConfigType string

+ Data json.RawMessage

+ Deleted bool

+ Id int

+ MountPath string

+ Name string

+ TableName struct{}

+ Type string

+ type GlobalCMCSRepository interface

+ FindAllActive func() ([]*GlobalCMCS, error)

+ FindByConfigTypeAndName func(configType, name string) (*GlobalCMCS, error)

+ FindByMountPath func(mountPath string) (*GlobalCMCS, error)

+ Save func(model *GlobalCMCS) (*GlobalCMCS, error)

+ Update func(model *GlobalCMCS) (*GlobalCMCS, error)

+ type GlobalCMCSRepositoryImpl struct

+ func NewGlobalCMCSRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *GlobalCMCSRepositoryImpl

+ func (impl *GlobalCMCSRepositoryImpl) FindAllActive() ([]*GlobalCMCS, error)

+ func (impl *GlobalCMCSRepositoryImpl) FindByConfigTypeAndName(configType, name string) (*GlobalCMCS, error)

+ func (impl *GlobalCMCSRepositoryImpl) FindByMountPath(mountPath string) (*GlobalCMCS, error)

+ func (impl *GlobalCMCSRepositoryImpl) Save(model *GlobalCMCS) (*GlobalCMCS, error)

+ func (impl *GlobalCMCSRepositoryImpl) Update(model *GlobalCMCS) (*GlobalCMCS, error)

Sep 13, 2022

Changes in this version

type GitOpsConfigRepository

+ IsGitOpsConfigured func() (bool, error)

type GitOpsConfigRepositoryImpl

+ func (impl *GitOpsConfigRepositoryImpl) IsGitOpsConfigured() (bool, error)

+ type UserAttributes struct

+ EmailId string

+ UserData string

+ type UserAttributesDao struct

+ EmailId string

+ Key string

+ UserId int32

+ Value string

+ type UserAttributesRepository interface

+ AddUserAttribute func(attrDto *UserAttributesDao) (*UserAttributesDao, error)

+ GetConnection func() (dbConnection *pg.DB)

+ GetDataValueByKey func(attrDto *UserAttributesDao) (string, error)

+ UpdateDataValByKey func(attrDto *UserAttributesDao) error

+ type UserAttributesRepositoryImpl struct

+ func NewUserAttributesRepositoryImpl(dbConnection *pg.DB) *UserAttributesRepositoryImpl

+ func (impl *UserAttributesRepositoryImpl) GetConnection() (dbConnection *pg.DB)

+ func (repo UserAttributesRepositoryImpl) AddUserAttribute(attrDto *UserAttributesDao) (*UserAttributesDao, error)

+ func (repo UserAttributesRepositoryImpl) GetDataValueByKey(attrDto *UserAttributesDao) (string, error)

+ func (repo UserAttributesRepositoryImpl) UpdateDataValByKey(attrDto *UserAttributesDao) error

Sep 1, 2022

Changes in this version

type AppListingRepository

+ FindLatestDeployedStatusesForAppsByStatusAndLastUpdatedBefore func(deployedBeforeMinutes int) ([]DeploymentStatus, error)

+ SaveNewDeploymentsWithTxn func(deploymentStatuses []DeploymentStatus, tx *pg.Tx) error

type AppListingRepositoryImpl

+ func (impl AppListingRepositoryImpl) FindLatestDeployedStatusesForAppsByStatusAndLastUpdatedBefore(deployedBeforeMinutes int) ([]DeploymentStatus, error)

+ func (impl AppListingRepositoryImpl) SaveNewDeploymentsWithTxn(deploymentStatuses []DeploymentStatus, tx *pg.Tx) error

Jul 19, 2022

Changes in this version

+ type SMTPConfig struct

+ AuthPassword string

+ AuthType string

+ AuthUser string

+ ConfigName string

+ Default bool

+ Deleted bool

+ Description string

+ FromEmail string

+ Host string

+ Id int

+ OwnerId int32

+ Port string

+ type SMTPNotificationRepository interface

+ FindAll func() ([]*SMTPConfig, error)

+ FindByIds func(ids []*int) ([]*SMTPConfig, error)

+ FindByIdsIn func(ids []int) ([]*SMTPConfig, error)

+ FindByTeamIdOrOwnerId func(ownerId int32) ([]*SMTPConfig, error)

+ FindDefault func() (*SMTPConfig, error)

+ FindOne func(id int) (*SMTPConfig, error)

+ MarkSMTPConfigDeleted func(smtpConfig *SMTPConfig) error

+ SaveSMTPConfig func(smtpConfig *SMTPConfig) (*SMTPConfig, error)

+ UpdateSMTPConfig func(smtpConfig *SMTPConfig) (*SMTPConfig, error)

+ UpdateSMTPConfigDefault func() (bool, error)

+ type SMTPNotificationRepositoryImpl struct

+ func NewSMTPNotificationRepositoryImpl(dbConnection *pg.DB) *SMTPNotificationRepositoryImpl

+ func (impl *SMTPNotificationRepositoryImpl) FindAll() ([]*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32) ([]*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) FindDefault() (*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) FindOne(id int) (*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) MarkSMTPConfigDeleted(smtpConfig *SMTPConfig) error

+ func (impl *SMTPNotificationRepositoryImpl) SaveSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) UpdateSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)

+ func (impl *SMTPNotificationRepositoryImpl) UpdateSMTPConfigDefault() (bool, error)

Jul 1, 2022

Changes in this version

type DeploymentGroupRepository

+ FindByAppIdAndEnvId func(envId, appId int) ([]DeploymentGroup, error)

type DeploymentGroupRepositoryImpl

+ func (impl *DeploymentGroupRepositoryImpl) FindByAppIdAndEnvId(envId, appId int) ([]DeploymentGroup, error)

May 10, 2022

Changes in this version

type GitOpsConfig

+ EmailId string

type GitOpsConfigRepository

+ GetEmailIdFromActiveGitOpsConfig func() (string, error)

type GitOpsConfigRepositoryImpl

+ func (impl *GitOpsConfigRepositoryImpl) GetEmailIdFromActiveGitOpsConfig() (string, error)

Feb 14, 2022

Changes in this version

type DockerArtifactStoreRepository

+ MarkRegistryDeleted func(artifactStore *DockerArtifactStore) error

type DockerArtifactStoreRepositoryImpl

+ func (impl DockerArtifactStoreRepositoryImpl) MarkRegistryDeleted(deleteReq *DockerArtifactStore) error

type GitProvider

+ Deleted bool

type GitProviderRepository

+ MarkProviderDeleted func(gitProvider *GitProvider) error

type GitProviderRepositoryImpl

+ func (impl GitProviderRepositoryImpl) MarkProviderDeleted(gitProvider *GitProvider) error

type NotificationSettingsRepository

+ FindNotificationSettingsByConfigIdAndConfigType func(configId int, configType string) ([]*NotificationSettings, error)

type NotificationSettingsRepositoryImpl

+ func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsByConfigIdAndConfigType(configId int, configType string) ([]*NotificationSettings, error)

type SESConfig

+ Deleted bool

type SESNotificationRepository

+ MarkSESConfigDeleted func(sesConfig *SESConfig) error

type SESNotificationRepositoryImpl

+ func (impl *SESNotificationRepositoryImpl) MarkSESConfigDeleted(sesConfig *SESConfig) error

type SlackConfig

+ Deleted bool

type SlackNotificationRepository

+ MarkSlackConfigDeleted func(slackConfig *SlackConfig) error

type SlackNotificationRepositoryImpl

+ func (impl *SlackNotificationRepositoryImpl) MarkSlackConfigDeleted(slackConfig *SlackConfig) error

Dec 29, 2021

Changes in this version

type CiArtifact

+ RunningOnParent bool

type CiArtifactRepository

+ GetArtifactByCdWorkflowId func(cdWorkflowId int) (artifact *CiArtifact, err error)

type CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) GetArtifactByCdWorkflowId(cdWorkflowId int) (artifact *CiArtifact, err error)

Dec 2, 2021

Changes in this version

type GitProviderRepository

+ FindByUrl func(providerUrl string) (GitProvider, error)

type GitProviderRepositoryImpl

+ func (impl GitProviderRepositoryImpl) FindByUrl(providerUrl string) (GitProvider, error)

Oct 21, 2021

Changes in this version

type GitOpsConfig

+ BitBucketProjectKey string

+ BitBucketWorkspaceId string

Oct 10, 2021

Changes in this version

type DockerArtifactStore

+ Cert string

+ Connection string

type GitProvider

+ SshPrivateKey string

Sep 9, 2021

Changes in this version

type WebhookEventDataRepository

+ GetById func(id int) (*WebhookEventData, error)

type WebhookEventDataRepositoryImpl

+ func (impl WebhookEventDataRepositoryImpl) GetById(id int) (*WebhookEventData, error)

Aug 20, 2021

Changes in this version

+ type GitHost struct

+ Active bool

+ EventTypeHeader string

+ Id int

+ Name string

+ SecretHeader string

+ SecretValidator string

+ WebhookSecret string

+ WebhookUrl string

+ type GitHostRepository interface

+ Exists func(name string) (bool, error)

+ FindAll func() ([]GitHost, error)

+ FindOneById func(Id int) (GitHost, error)

+ FindOneByName func(name string) (GitHost, error)

+ Save func(gitHost *GitHost) error

+ type GitHostRepositoryImpl struct

+ func NewGitHostRepositoryImpl(dbConnection *pg.DB) *GitHostRepositoryImpl

+ func (impl GitHostRepositoryImpl) Exists(name string) (bool, error)

+ func (impl GitHostRepositoryImpl) FindAll() ([]GitHost, error)

+ func (impl GitHostRepositoryImpl) FindOneById(id int) (GitHost, error)

+ func (impl GitHostRepositoryImpl) FindOneByName(name string) (GitHost, error)

+ func (impl GitHostRepositoryImpl) Save(gitHost *GitHost) error

type GitProvider

+ GitHostId int

type Modification

+ WebhookData WebhookData

+ type WebhookData struct

+ Data map[string]string

+ EventActionType string

+ Id int

+ type WebhookEventData struct

+ CreatedOn time.Time

+ EventType string

+ GitHostId int

+ Id int

+ PayloadJson string

+ type WebhookEventDataRepository interface

+ Save func(webhookEventData *WebhookEventData) error

+ type WebhookEventDataRepositoryImpl struct

+ func NewWebhookEventDataRepositoryImpl(dbConnection *pg.DB) *WebhookEventDataRepositoryImpl

+ func (impl WebhookEventDataRepositoryImpl) Save(webhookEventData *WebhookEventData) error

Aug 13, 2021

Changes in this version

type UserRepository

+ GetByIdIncludeDeleted func(id int32) (*UserModel, error)

type UserRepositoryImpl

+ func (impl UserRepositoryImpl) GetByIdIncludeDeleted(id int32) (*UserModel, error)

Jun 28, 2021

Changes in this version

type AppListingRepository

+ FindAppCount func(isProd bool) (int, error)

type AppListingRepositoryImpl

+ func (impl AppListingRepositoryImpl) FindAppCount(isProd bool) (int, error)

Jun 17, 2021

Changes in this version

type SettingOptionDTO

+ AppName string

May 24, 2021

Changes in this version

type GitOpsConfig

+ AzureProject string

May 5, 2021

Changes in this version

type RoleGroupRepository

+ GetRoleGroupListByNames func(groupNames []string) ([]*RoleGroup, error)

+ GetRoleGroupRoleMappingByRoleGroupIds func(roleGroupIds []int32) ([]*RoleModel, error)

type RoleGroupRepositoryImpl

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupListByNames(groupNames []string) ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMappingByRoleGroupIds(roleGroupIds []int32) ([]*RoleModel, error)

type RoleGroupRoleMapping

+ RoleModel *RoleModel

Apr 23, 2021

Changes in this version

+ const REGISTRYTYPE_DOCKER_HUB

Mar 15, 2021

Changes in this version

+ const Failure

+ const NewDeployment

+ const REGISTRYTYPE_ECR

+ const REGISTRYTYPE_OTHER

+ const Success

+ type AppLevelMetrics struct

+ AppId int

+ AppMetrics bool

+ Id int

+ InfraMetrics bool

+ type AppLevelMetricsRepository interface

+ FindByAppId func(id int) (*AppLevelMetrics, error)

+ Save func(metrics *AppLevelMetrics) error

+ Update func(metrics *AppLevelMetrics) error

+ type AppLevelMetricsRepositoryImpl struct

+ func NewAppLevelMetricsRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *AppLevelMetricsRepositoryImpl

+ func (impl *AppLevelMetricsRepositoryImpl) FindByAppId(appId int) (*AppLevelMetrics, error)

+ func (impl *AppLevelMetricsRepositoryImpl) Save(metrics *AppLevelMetrics) error

+ func (impl *AppLevelMetricsRepositoryImpl) Update(metrics *AppLevelMetrics) error

+ type AppListingRepository interface

+ DeleteOldDeployments func(appName string) (int, error)

+ DeploymentDetailByArtifactId func(ciArtifactId int) (bean.DeploymentDetailContainer, error)

+ DeploymentDetailsByAppIdAndEnvId func(appId int, envId int) (bean.DeploymentDetailContainer, error)

+ FetchAppDetail func(appId int, envId int) (bean.AppDetailContainer, error)

+ FetchAppStageStatus func(appId int) ([]bean.AppStageStatus, error)

+ FetchAppTriggerView func(appId int) ([]bean.TriggerView, error)

+ FetchAppsByEnvironment func(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, error)

+ FetchOtherEnvironment func(appId int) ([]*bean.Environment, error)

+ FindLastDeployedStatus func(appName string) (DeploymentStatus, error)

+ FindLastDeployedStatuses func(appNames []string) ([]DeploymentStatus, error)

+ FindLastDeployedStatusesForAllApps func() ([]DeploymentStatus, error)

+ GetDeploymentStatusByAppName func(appName string) ([]DeploymentStatus, error)

+ PrometheusApiByEnvId func(id int) (*string, error)

+ SaveNewDeployment func(deploymentStatus *DeploymentStatus) error

+ type AppListingRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewAppListingRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB, ...) *AppListingRepositoryImpl

+ func (impl AppListingRepositoryImpl) DeleteOldDeployments(appName string) (int, error)

+ func (impl AppListingRepositoryImpl) DeploymentDetailByArtifactId(ciArtifactId int) (bean.DeploymentDetailContainer, error)

+ func (impl AppListingRepositoryImpl) DeploymentDetailsByAppIdAndEnvId(appId int, envId int) (bean.DeploymentDetailContainer, error)

+ func (impl AppListingRepositoryImpl) FetchAppDetail(appId int, envId int) (bean.AppDetailContainer, error)

+ func (impl AppListingRepositoryImpl) FetchAppStageStatus(appId int) ([]bean.AppStageStatus, error)

+ func (impl AppListingRepositoryImpl) FetchAppTriggerView(appId int) ([]bean.TriggerView, error)

+ func (impl AppListingRepositoryImpl) FetchAppsByEnvironment(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, error)

+ func (impl AppListingRepositoryImpl) FetchOtherEnvironment(appId int) ([]*bean.Environment, error)

+ func (impl AppListingRepositoryImpl) FindLastDeployedStatus(appName string) (DeploymentStatus, error)

+ func (impl AppListingRepositoryImpl) FindLastDeployedStatuses(appNames []string) ([]DeploymentStatus, error)

+ func (impl AppListingRepositoryImpl) FindLastDeployedStatusesForAllApps() ([]DeploymentStatus, error)

+ func (impl AppListingRepositoryImpl) GetDeploymentStatusByAppName(appName string) ([]DeploymentStatus, error)

+ func (impl AppListingRepositoryImpl) PrometheusApiByEnvId(id int) (*string, error)

+ func (impl AppListingRepositoryImpl) SaveNewDeployment(deploymentStatus *DeploymentStatus) error

+ type Attributes struct

+ Active bool

+ Id int

+ Key string

+ Value string

+ type AttributesRepository interface

+ FindActiveList func() ([]*Attributes, error)

+ FindById func(id int) (*Attributes, error)

+ FindByKey func(key string) (*Attributes, error)

+ GetConnection func() (dbConnection *pg.DB)

+ Save func(model *Attributes, tx *pg.Tx) (*Attributes, error)

+ Update func(model *Attributes, tx *pg.Tx) error

+ type AttributesRepositoryImpl struct

+ func NewAttributesRepositoryImpl(dbConnection *pg.DB) *AttributesRepositoryImpl

+ func (impl *AttributesRepositoryImpl) GetConnection() (dbConnection *pg.DB)

+ func (repo AttributesRepositoryImpl) FindActiveList() ([]*Attributes, error)

+ func (repo AttributesRepositoryImpl) FindById(id int) (*Attributes, error)

+ func (repo AttributesRepositoryImpl) FindByKey(key string) (*Attributes, error)

+ func (repo AttributesRepositoryImpl) Save(model *Attributes, tx *pg.Tx) (*Attributes, error)

+ func (repo AttributesRepositoryImpl) Update(model *Attributes, tx *pg.Tx) error

+ type AuthMode string

+ const AUTH_MODE_ACCESS_TOKEN

+ const AUTH_MODE_ANONYMOUS

+ const AUTH_MODE_SSH

+ const AUTH_MODE_USERNAME_PASSWORD

+ type CiArtifact struct

+ DataSource string

+ Deployed bool

+ DeployedTime time.Time

+ Id int

+ Image string

+ ImageDigest string

+ Latest bool

+ MaterialInfo string

+ ParentCiArtifact int

+ PipelineId int

+ ScanEnabled bool

+ Scanned bool

+ WorkflowId *int

+ func (info *CiArtifact) ParseMaterialInfo() (map[string]string, error)

+ type CiArtifactRepository interface

+ FetchArtifactForRollback func(cdPipelineId int) ([]CiArtifact, error)

+ FinDByParentCiArtifactAndCiId func(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error)

+ Get func(id int) (artifact *CiArtifact, err error)

+ GetArtifactsByCDPipeline func(cdPipelineId int) ([]CiArtifact, error)

+ GetArtifactsByCDPipelineAndRunnerType func(cdPipelineId int, runnerType bean.CdWorkflowType) ([]CiArtifact, error)

+ GetArtifactsByCDPipelineV2 func(cdPipelineId int) ([]CiArtifact, error)

+ GetArtifactsByCiPipelineId func(ciPipelineId int) ([]CiArtifact, error)

+ GetByIds func(ids []int) ([]*CiArtifact, error)

+ GetByImageDigest func(imageDigest string) (artifact *CiArtifact, err error)

+ GetByWfId func(wfId int) (artifact *CiArtifact, err error)

+ GetLatest func(cdPipelineId int) (int, error)

+ Save func(artifact *CiArtifact) error

+ SaveAll func(artifacts []*CiArtifact) error

+ type CiArtifactRepositoryImpl struct

+ func NewCiArtifactRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *CiArtifactRepositoryImpl

+ func (impl CiArtifactRepositoryImpl) FetchArtifactForRollback(cdPipelineId int) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) FinDByParentCiArtifactAndCiId(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) Get(id int) (artifact *CiArtifact, err error)

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipeline(cdPipelineId int) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.CdWorkflowType) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipelineV2(cdPipelineId int) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetArtifactsByCiPipelineId(ciPipelineId int) ([]CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetByIds(ids []int) ([]*CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetByImageDigest(imageDigest string) (*CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetByWfId(wfId int) (*CiArtifact, error)

+ func (impl CiArtifactRepositoryImpl) GetLatest(cdPipelineId int) (int, error)

+ func (impl CiArtifactRepositoryImpl) Save(artifact *CiArtifact) error

+ func (impl CiArtifactRepositoryImpl) SaveAll(artifacts []*CiArtifact) error

+ type CiMaterialInfo struct

+ Changed bool

+ Material Material

+ Modifications []Modification

+ func GetCiMaterialInfo(materialInfo string, source string) ([]CiMaterialInfo, error)

+ type DbConfig struct

+ Active bool

+ DbName string

+ Host string

+ Id int

+ Name string

+ Password string

+ Port string

+ Type DbType

+ UserName string

+ type DbConfigRepository interface

+ GetActiveForAutocomplete func() (configs []*DbConfig, err error)

+ GetAll func() (configs []*DbConfig, err error)

+ GetById func(id int) (*DbConfig, error)

+ Save func(config *DbConfig) error

+ Update func(config *DbConfig) (*DbConfig, error)

+ type DbConfigRepositoryImpl struct

+ func NewDbConfigRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *DbConfigRepositoryImpl

+ func (impl DbConfigRepositoryImpl) GetActiveForAutocomplete() (configs []*DbConfig, err error)

+ func (impl DbConfigRepositoryImpl) GetAll() (configs []*DbConfig, err error)

+ func (impl DbConfigRepositoryImpl) GetById(id int) (*DbConfig, error)

+ func (impl DbConfigRepositoryImpl) Save(config *DbConfig) error

+ func (impl DbConfigRepositoryImpl) Update(config *DbConfig) (*DbConfig, error)

+ type DbType string

+ const DB_TYPE_MARIADB

+ const Db_TYPE_MYSQL

+ const Db_TYPE_POSTGRESS

+ func (t DbType) IsValid() bool

+ type DeploymentGroup struct

+ Active bool

+ AppCount int

+ CiPipelineId int

+ DeploymentGroupApps []*DeploymentGroupApp

+ EnvironmentId int

+ Id int

+ Name string

+ NoOfApps string

+ TableName struct{}

+ type DeploymentGroupApp struct

+ Active bool

+ AppId int

+ DeploymentGroupId int

+ Id int

+ TableName struct{}

+ type DeploymentGroupAppRepository interface

+ Create func(model *DeploymentGroupApp) (*DeploymentGroupApp, error)

+ Delete func(model *DeploymentGroupApp) error

+ GetAll func() ([]*DeploymentGroupApp, error)

+ GetByDeploymentGroup func(deploymentGroupId int) ([]*DeploymentGroupApp, error)

+ GetById func(id int) (*DeploymentGroupApp, error)

+ Update func(model *DeploymentGroupApp) (*DeploymentGroupApp, error)

+ type DeploymentGroupAppRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewDeploymentGroupAppRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *DeploymentGroupAppRepositoryImpl

+ func (impl DeploymentGroupAppRepositoryImpl) Create(model *DeploymentGroupApp) (*DeploymentGroupApp, error)

+ func (impl DeploymentGroupAppRepositoryImpl) Delete(model *DeploymentGroupApp) error

+ func (impl DeploymentGroupAppRepositoryImpl) GetAll() ([]*DeploymentGroupApp, error)

+ func (impl DeploymentGroupAppRepositoryImpl) GetByDeploymentGroup(deploymentGroupId int) ([]*DeploymentGroupApp, error)

+ func (impl DeploymentGroupAppRepositoryImpl) GetById(id int) (*DeploymentGroupApp, error)

+ func (impl DeploymentGroupAppRepositoryImpl) Update(model *DeploymentGroupApp) (*DeploymentGroupApp, error)

+ type DeploymentGroupRepository interface

+ Create func(model *DeploymentGroup) (*DeploymentGroup, error)

+ Delete func(model *DeploymentGroup) error

+ FindByIdWithApp func(id int) (*DeploymentGroup, error)

+ GetAll func() ([]DeploymentGroup, error)

+ GetById func(id int) (*DeploymentGroup, error)

+ Update func(model *DeploymentGroup) (*DeploymentGroup, error)

+ type DeploymentGroupRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewDeploymentGroupRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *DeploymentGroupRepositoryImpl

+ func (impl *DeploymentGroupRepositoryImpl) Create(model *DeploymentGroup) (*DeploymentGroup, error)

+ func (impl *DeploymentGroupRepositoryImpl) Delete(model *DeploymentGroup) error

+ func (impl *DeploymentGroupRepositoryImpl) FindByIdWithApp(id int) (*DeploymentGroup, error)

+ func (impl *DeploymentGroupRepositoryImpl) GetAll() ([]DeploymentGroup, error)

+ func (impl *DeploymentGroupRepositoryImpl) GetById(id int) (*DeploymentGroup, error)

+ func (impl *DeploymentGroupRepositoryImpl) Update(model *DeploymentGroup) (*DeploymentGroup, error)

+ type DeploymentStatus struct

+ AppId int

+ AppName string

+ CreatedOn time.Time

+ EnvId int

+ Id int

+ Status string

+ UpdatedOn time.Time

+ type DockerArtifactStore struct

+ AWSAccessKeyId string

+ AWSRegion string

+ AWSSecretAccessKey string

+ Active bool

+ Id string

+ IsDefault bool

+ Password string

+ PluginId string

+ RegistryType RegistryType

+ RegistryURL string

+ Username string

+ func (store *DockerArtifactStore) GetRegistryLocation() (registryLocation string, err error)

+ type DockerArtifactStoreRepository interface

+ Delete func(storeId string) error

+ FindActiveDefaultStore func() (*DockerArtifactStore, error)

+ FindAll func() ([]DockerArtifactStore, error)

+ FindAllActiveForAutocomplete func() ([]DockerArtifactStore, error)

+ FindOne func(storeId string) (*DockerArtifactStore, error)

+ Save func(artifactStore *DockerArtifactStore) error

+ Update func(artifactStore *DockerArtifactStore) error

+ type DockerArtifactStoreRepositoryImpl struct

+ func NewDockerArtifactStoreRepositoryImpl(dbConnection *pg.DB) *DockerArtifactStoreRepositoryImpl

+ func (impl DockerArtifactStoreRepositoryImpl) Delete(storeId string) error

+ func (impl DockerArtifactStoreRepositoryImpl) FindActiveDefaultStore() (*DockerArtifactStore, error)

+ func (impl DockerArtifactStoreRepositoryImpl) FindAll() ([]DockerArtifactStore, error)

+ func (impl DockerArtifactStoreRepositoryImpl) FindAllActiveForAutocomplete() ([]DockerArtifactStore, error)

+ func (impl DockerArtifactStoreRepositoryImpl) FindOne(storeId string) (*DockerArtifactStore, error)

+ func (impl DockerArtifactStoreRepositoryImpl) Save(artifactStore *DockerArtifactStore) error

+ func (impl DockerArtifactStoreRepositoryImpl) Update(artifactStore *DockerArtifactStore) error

+ type EnvLevelAppMetrics struct

+ AppId int

+ AppMetrics *bool

+ EnvId int

+ Id int

+ InfraMetrics *bool

+ type EnvLevelAppMetricsRepository interface

+ Delete func(metrics *EnvLevelAppMetrics) error

+ FindByAppId func(appId int) ([]*EnvLevelAppMetrics, error)

+ FindByAppIdAndEnvId func(appId int, envId int) (*EnvLevelAppMetrics, error)

+ Save func(metrics *EnvLevelAppMetrics) error

+ Update func(metrics *EnvLevelAppMetrics) error

+ type EnvLevelAppMetricsRepositoryImpl struct

+ func NewEnvLevelAppMetricsRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *EnvLevelAppMetricsRepositoryImpl

+ func (impl *EnvLevelAppMetricsRepositoryImpl) Delete(metrics *EnvLevelAppMetrics) error

+ func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppId(appId int) ([]*EnvLevelAppMetrics, error)

+ func (impl *EnvLevelAppMetricsRepositoryImpl) FindByAppIdAndEnvId(appId int, envId int) (*EnvLevelAppMetrics, error)

+ func (impl *EnvLevelAppMetricsRepositoryImpl) Save(metrics *EnvLevelAppMetrics) error

+ func (impl *EnvLevelAppMetricsRepositoryImpl) Update(metrics *EnvLevelAppMetrics) error

+ type EventRepository interface

+ FindLastCompletedEvent func(eventTypeId int) (*JobEvent, error)

+ Save func(event *JobEvent) error

+ Update func(event *JobEvent) error

+ type EventRepositoryImpl struct

+ func NewEventRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *EventRepositoryImpl

+ func (impl *EventRepositoryImpl) FindLastCompletedEvent(eventTypeId int) (*JobEvent, error)

+ func (impl *EventRepositoryImpl) Save(event *JobEvent) error

+ func (impl *EventRepositoryImpl) Update(event *JobEvent) error

+ type GitConfiguration struct

+ URL string

+ type GitOpsConfig struct

+ Active bool

+ GitHubOrgId string

+ GitLabGroupId string

+ Host string

+ Id int

+ Provider string

+ Token string

+ Username string

+ type GitOpsConfigRepository interface

+ CreateGitOpsConfig func(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error)

+ GetAllGitOpsConfig func() ([]*GitOpsConfig, error)

+ GetConnection func() *pg.DB

+ GetGitOpsConfigActive func() (*GitOpsConfig, error)

+ GetGitOpsConfigById func(id int) (*GitOpsConfig, error)

+ GetGitOpsConfigByProvider func(provider string) (*GitOpsConfig, error)

+ UpdateGitOpsConfig func(model *GitOpsConfig, tx *pg.Tx) error

+ type GitOpsConfigRepositoryImpl struct

+ func NewGitOpsConfigRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *GitOpsConfigRepositoryImpl

+ func (impl *GitOpsConfigRepositoryImpl) CreateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error)

+ func (impl *GitOpsConfigRepositoryImpl) GetAllGitOpsConfig() ([]*GitOpsConfig, error)

+ func (impl *GitOpsConfigRepositoryImpl) GetConnection() *pg.DB

+ func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigActive() (*GitOpsConfig, error)

+ func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigById(id int) (*GitOpsConfig, error)

+ func (impl *GitOpsConfigRepositoryImpl) GetGitOpsConfigByProvider(provider string) (*GitOpsConfig, error)

+ func (impl *GitOpsConfigRepositoryImpl) UpdateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) error

+ type GitProvider struct

+ AccessToken string

+ Active bool

+ AuthMode AuthMode

+ Id int

+ Name string

+ Password string

+ SshKey string

+ Url string

+ UserName string

+ type GitProviderRepository interface

+ FindAll func() ([]GitProvider, error)

+ FindAllActiveForAutocomplete func() ([]GitProvider, error)

+ FindOne func(providerId string) (GitProvider, error)

+ ProviderExists func(url string) (bool, error)

+ Save func(gitProvider *GitProvider) error

+ Update func(gitProvider *GitProvider) error

+ type GitProviderRepositoryImpl struct

+ func NewGitProviderRepositoryImpl(dbConnection *pg.DB) *GitProviderRepositoryImpl

+ func (impl GitProviderRepositoryImpl) FindAll() ([]GitProvider, error)

+ func (impl GitProviderRepositoryImpl) FindAllActiveForAutocomplete() ([]GitProvider, error)

+ func (impl GitProviderRepositoryImpl) FindOne(providerId string) (GitProvider, error)

+ func (impl GitProviderRepositoryImpl) ProviderExists(url string) (bool, error)

+ func (impl GitProviderRepositoryImpl) Save(gitProvider *GitProvider) error

+ func (impl GitProviderRepositoryImpl) Update(gitProvider *GitProvider) error

+ type GitWebhook struct

+ Active bool

+ CiMaterialId int

+ CreatedOn time.Time

+ GitMaterialId int

+ Id int

+ LastSeenHash string

+ Type string

+ Value string

+ type GitWebhookRepository interface

+ Save func(gitWebhook *GitWebhook) error

+ type GitWebhookRepositoryImpl struct

+ func NewGitWebhookRepositoryImpl(dbConnection *pg.DB) *GitWebhookRepositoryImpl

+ func (impl *GitWebhookRepositoryImpl) Save(gitWebhook *GitWebhook) error

+ type JiraAccountDetails struct

+ AccountURL string

+ AuthToken string

+ CommitMessageRegex string

+ FinalIssueStatus string

+ Id int32

+ PipelineId int32

+ PipelineStage string

+ UserName string

+ type JiraAccountRepository interface

+ FindByPipelineIdAndStage func(pipelineId int32, pipelineStage string) (*JiraAccountDetails, error)

+ Save func(accountDetails *JiraAccountDetails) error

+ Update func(accountDetails *JiraAccountDetails) error

+ type JiraAccountRepositoryImpl struct

+ func NewJiraAccountRepositoryImpl(dbConnection *pg.DB) *JiraAccountRepositoryImpl

+ func (impl *JiraAccountRepositoryImpl) FindByPipelineIdAndStage(pipelineId int32, pipelineStage string) (*JiraAccountDetails, error)

+ func (impl *JiraAccountRepositoryImpl) Save(jiraAccountDetails *JiraAccountDetails) error

+ func (impl *JiraAccountRepositoryImpl) Update(jiraAccountDetails *JiraAccountDetails) error

+ type JobEvent struct

+ CreatedOn time.Time

+ EventName string

+ EventTriggerTime time.Time

+ Id int

+ Message string

+ Status string

+ UpdatedOn time.Time

+ type LinkoutsModel struct

+ AppId int

+ Description string

+ EnvironmentId int

+ Id int

+ Link string

+ Name string

+ TableName struct{}

+ type LinkoutsRepository interface

+ Create func(model *LinkoutsModel) (*LinkoutsModel, error)

+ FetchLinkoutById func(Id int) (bean.LinkOuts, error)

+ FetchLinkoutsByAppIdAndEnvId func(appId int, envId int) ([]LinkoutsModel, error)

+ GetAll func() ([]LinkoutsModel, error)

+ GetById func(id int) (*LinkoutsModel, error)

+ Update func(model *LinkoutsModel) (*LinkoutsModel, error)

+ type LinkoutsRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewLinkoutsRepositoryImpl(Logger *zap.SugaredLogger, dbConnection *pg.DB) *LinkoutsRepositoryImpl

+ func (impl LinkoutsRepositoryImpl) Create(model *LinkoutsModel) (*LinkoutsModel, error)

+ func (impl LinkoutsRepositoryImpl) FetchLinkoutById(Id int) (bean.LinkOuts, error)

+ func (impl LinkoutsRepositoryImpl) FetchLinkoutsByAppIdAndEnvId(appId int, envId int) ([]LinkoutsModel, error)

+ func (impl LinkoutsRepositoryImpl) GetAll() ([]LinkoutsModel, error)

+ func (impl LinkoutsRepositoryImpl) GetById(id int) (*LinkoutsModel, error)

+ func (impl LinkoutsRepositoryImpl) Update(model *LinkoutsModel) (*LinkoutsModel, error)

+ type Material struct

+ GitConfiguration GitConfiguration

+ PluginID string

+ ScmConfiguration ScmConfiguration

+ Type string

+ type Modification struct

+ Author string

+ Branch string

+ Data map[string]string

+ Message string

+ ModifiedTime string

+ Revision string

+ Tag string

+ type NotificationSettings struct

+ AppId *int

+ Config string

+ EnvId *int

+ EventTypeId int

+ Id int

+ PipelineId *int

+ PipelineType string

+ TeamId *int

+ ViewId int

+ type NotificationSettingsRepository interface

+ DeleteNotificationSettingsByConfigId func(viewId int, tx *pg.Tx) (int, error)

+ DeleteNotificationSettingsViewById func(id int, tx *pg.Tx) (int, error)

+ FetchNotificationSettingGroupBy func(viewId int) ([]NotificationSettings, error)

+ FindAll func(offset int, size int) ([]*NotificationSettingsView, error)

+ FindNSViewCount func() (int, error)

+ FindNotificationSettingBuildOptions func(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)

+ FindNotificationSettingDeploymentOptions func(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)

+ FindNotificationSettingsByViewId func(viewId int) ([]NotificationSettings, error)

+ FindNotificationSettingsViewById func(id int) (*NotificationSettingsView, error)

+ FindNotificationSettingsViewByIds func(id []*int) ([]*NotificationSettingsView, error)

+ SaveAllNotificationSettings func(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error)

+ SaveNotificationSetting func(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)

+ SaveNotificationSettingsConfig func(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)

+ UpdateNotificationSettings func(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)

+ UpdateNotificationSettingsView func(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)

+ type NotificationSettingsRepositoryImpl struct

+ func NewNotificationSettingsRepositoryImpl(dbConnection *pg.DB) *NotificationSettingsRepositoryImpl

+ func (impl *NotificationSettingsRepositoryImpl) DeleteNotificationSettingsByConfigId(viewId int, tx *pg.Tx) (int, error)

+ func (impl *NotificationSettingsRepositoryImpl) DeleteNotificationSettingsViewById(id int, tx *pg.Tx) (int, error)

+ func (impl *NotificationSettingsRepositoryImpl) FetchNotificationSettingGroupBy(viewId int) ([]NotificationSettings, error)

+ func (impl *NotificationSettingsRepositoryImpl) FindAll(offset int, size int) ([]*NotificationSettingsView, error)

+ func (impl *NotificationSettingsRepositoryImpl) FindNSViewCount() (int, error)

+ func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingBuildOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)

+ func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingDeploymentOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)

+ func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsByViewId(viewId int) ([]NotificationSettings, error)

+ func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsViewById(id int) (*NotificationSettingsView, error)

+ func (impl *NotificationSettingsRepositoryImpl) FindNotificationSettingsViewByIds(ids []*int) ([]*NotificationSettingsView, error)

+ func (impl *NotificationSettingsRepositoryImpl) SaveAllNotificationSettings(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error)

+ func (impl *NotificationSettingsRepositoryImpl) SaveNotificationSetting(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)

+ func (impl *NotificationSettingsRepositoryImpl) SaveNotificationSettingsConfig(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)

+ func (impl *NotificationSettingsRepositoryImpl) UpdateNotificationSettings(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)

+ func (impl *NotificationSettingsRepositoryImpl) UpdateNotificationSettingsView(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)

+ type NotificationSettingsView struct

+ Config string

+ Id int

+ type NotificationSettingsViewWithAppEnv struct

+ AppId *int

+ AppName string

+ Config string

+ ConfigName string

+ EnvId *int

+ EnvironmentName string

+ Id int

+ type RegistryType string

+ type RoleGroup struct

+ Active bool

+ CasbinName string

+ Description string

+ Id int32

+ Name string

+ TableName struct{}

+ type RoleGroupRepository interface

+ CreateRoleGroup func(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ CreateRoleGroupRoleMapping func(model *RoleGroupRoleMapping, tx *pg.Tx) (*RoleGroupRoleMapping, error)

+ DeleteRoleGroupRoleMapping func(model *RoleGroupRoleMapping, tx *pg.Tx) (bool, error)

+ GetAllRoleGroup func() ([]*RoleGroup, error)

+ GetConnection func() (dbConnection *pg.DB)

+ GetRoleGroupById func(id int32) (*RoleGroup, error)

+ GetRoleGroupByName func(name string) (*RoleGroup, error)

+ GetRoleGroupListByCasbinNames func(name []string) ([]*RoleGroup, error)

+ GetRoleGroupListByName func(name string) ([]*RoleGroup, error)

+ GetRoleGroupRoleMapping func(model int32) (*RoleGroupRoleMapping, error)

+ GetRoleGroupRoleMappingByRoleGroupId func(roleGroupId int32) ([]*RoleGroupRoleMapping, error)

+ UpdateRoleGroup func(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ type RoleGroupRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewRoleGroupRepositoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger) *RoleGroupRepositoryImpl

+ func (impl *RoleGroupRepositoryImpl) GetConnection() (dbConnection *pg.DB)

+ func (impl RoleGroupRepositoryImpl) CreateRoleGroup(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) CreateRoleGroupRoleMapping(model *RoleGroupRoleMapping, tx *pg.Tx) (*RoleGroupRoleMapping, error)

+ func (impl RoleGroupRepositoryImpl) DeleteRoleGroupRoleMapping(model *RoleGroupRoleMapping, tx *pg.Tx) (bool, error)

+ func (impl RoleGroupRepositoryImpl) GetAllRoleGroup() ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupById(id int32) (*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupByName(name string) (*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupListByCasbinNames(names []string) ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupListByName(name string) ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMapping(userRoleModelId int32) (*RoleGroupRoleMapping, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMappingByRoleGroupId(roleGroupId int32) ([]*RoleGroupRoleMapping, error)

+ func (impl RoleGroupRepositoryImpl) UpdateRoleGroup(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ type RoleGroupRoleMapping struct

+ Id int

+ RoleGroupId int32

+ RoleId int

+ TableName struct{}

+ type RoleModel struct

+ Action string

+ Entity string

+ EntityName string

+ Environment string

+ Id int

+ Role string

+ TableName struct{}

+ Team string

+ type SESConfig struct

+ AccessKey string

+ ConfigName string

+ Default bool

+ Description string

+ FromEmail string

+ Id int

+ OwnerId int32

+ Region string

+ SecretKey string

+ SessionToken string

+ type SESNotificationRepository interface

+ FindAll func() ([]*SESConfig, error)

+ FindByIds func(ids []*int) ([]*SESConfig, error)

+ FindByIdsIn func(ids []int) ([]*SESConfig, error)

+ FindByTeamIdOrOwnerId func(ownerId int32) ([]*SESConfig, error)

+ FindDefault func() (*SESConfig, error)

+ FindOne func(id int) (*SESConfig, error)

+ SaveSESConfig func(sesConfig *SESConfig) (*SESConfig, error)

+ UpdateSESConfig func(sesConfig *SESConfig) (*SESConfig, error)

+ UpdateSESConfigDefault func() (bool, error)

+ type SESNotificationRepositoryImpl struct

+ func NewSESNotificationRepositoryImpl(dbConnection *pg.DB) *SESNotificationRepositoryImpl

+ func (impl *SESNotificationRepositoryImpl) FindAll() ([]*SESConfig, error)

+ func (impl *SESNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SESConfig, error)

+ func (impl *SESNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32) ([]*SESConfig, error)

+ func (impl *SESNotificationRepositoryImpl) FindDefault() (*SESConfig, error)

+ func (impl *SESNotificationRepositoryImpl) FindOne(id int) (*SESConfig, error)

+ func (impl *SESNotificationRepositoryImpl) SaveSESConfig(sesConfig *SESConfig) (*SESConfig, error)

+ func (impl *SESNotificationRepositoryImpl) UpdateSESConfig(sesConfig *SESConfig) (*SESConfig, error)

+ func (impl *SESNotificationRepositoryImpl) UpdateSESConfigDefault() (bool, error)

+ func (repo *SESNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SESConfig, error)

+ type SSOLoginModel struct

+ Active bool

+ Config string

+ Id int32

+ Label string

+ Name string

+ TableName struct{}

+ Url string

+ type SSOLoginRepository interface

+ Create func(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error)

+ Delete func(userModel *SSOLoginModel, tx *pg.Tx) (bool, error)

+ GetActive func() (*SSOLoginModel, error)

+ GetAll func() ([]SSOLoginModel, error)

+ GetById func(id int32) (*SSOLoginModel, error)

+ GetByName func(name string) (*SSOLoginModel, error)

+ GetConnection func() (dbConnection *pg.DB)

+ Update func(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error)

+ type SSOLoginRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewSSOLoginRepositoryImpl(dbConnection *pg.DB) *SSOLoginRepositoryImpl

+ func (impl *SSOLoginRepositoryImpl) GetConnection() (dbConnection *pg.DB)

+ func (impl SSOLoginRepositoryImpl) Create(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error)

+ func (impl SSOLoginRepositoryImpl) Delete(userModel *SSOLoginModel, tx *pg.Tx) (bool, error)

+ func (impl SSOLoginRepositoryImpl) GetActive() (*SSOLoginModel, error)

+ func (impl SSOLoginRepositoryImpl) GetAll() ([]SSOLoginModel, error)

+ func (impl SSOLoginRepositoryImpl) GetById(id int32) (*SSOLoginModel, error)

+ func (impl SSOLoginRepositoryImpl) GetByName(name string) (*SSOLoginModel, error)

+ func (impl SSOLoginRepositoryImpl) Update(userModel *SSOLoginModel, tx *pg.Tx) (*SSOLoginModel, error)

+ type ScmConfiguration struct

+ URL string

+ type SearchRequest struct

+ AppId []*int

+ EnvId []*int

+ PipelineName string

+ TeamId []*int

+ UserId int32

+ type SettingOptionDTO struct

+ EnvironmentName string

+ PipelineId int

+ PipelineName string

+ PipelineType string

+ type SlackConfig struct

+ ConfigName string

+ Description string

+ Id int

+ OwnerId int32

+ TeamId int

+ WebHookUrl string

+ type SlackNotificationRepository interface

+ FindAll func() ([]SlackConfig, error)

+ FindByIds func(ids []*int) ([]*SlackConfig, error)

+ FindByIdsIn func(ids []int) ([]*SlackConfig, error)

+ FindByName func(value string) ([]SlackConfig, error)

+ FindByTeamIdOrOwnerId func(ownerId int32, teamIds []int) ([]SlackConfig, error)

+ FindOne func(id int) (*SlackConfig, error)

+ SaveSlackConfig func(slackConfig *SlackConfig) (*SlackConfig, error)

+ UpdateSlackConfig func(slackConfig *SlackConfig) (*SlackConfig, error)

+ type SlackNotificationRepositoryImpl struct

+ func NewSlackNotificationRepositoryImpl(dbConnection *pg.DB) *SlackNotificationRepositoryImpl

+ func (impl *SlackNotificationRepositoryImpl) FindAll() ([]SlackConfig, error)

+ func (impl *SlackNotificationRepositoryImpl) FindByIdsIn(ids []int) ([]*SlackConfig, error)

+ func (impl *SlackNotificationRepositoryImpl) FindByName(value string) ([]SlackConfig, error)

+ func (impl *SlackNotificationRepositoryImpl) FindByTeamIdOrOwnerId(ownerId int32, teamIds []int) ([]SlackConfig, error)

+ func (impl *SlackNotificationRepositoryImpl) FindOne(id int) (*SlackConfig, error)

+ func (impl *SlackNotificationRepositoryImpl) SaveSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)

+ func (impl *SlackNotificationRepositoryImpl) UpdateSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)

+ func (repo *SlackNotificationRepositoryImpl) FindByIds(ids []*int) ([]*SlackConfig, error)

+ type UserAuthRepository interface

+ CreateDefaultPolicies func(team string, entityName string, env string, tx *pg.Tx) (bool, error)

+ CreateDefaultPoliciesForGlobalEntity func(entity string, entityName string, action string, tx *pg.Tx) (bool, error)

+ CreateRole func(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error)

+ CreateUpdateDefaultPoliciesForSuperAdmin func(tx *pg.Tx) (bool, error)

+ CreateUserRoleMapping func(userRoleModel *UserRoleModel, tx *pg.Tx) (*UserRoleModel, error)

+ DeleteRole func(roleModel *RoleModel, tx *pg.Tx) (bool, error)

+ DeleteUserRoleMapping func(userRoleModel *UserRoleModel, tx *pg.Tx) (bool, error)

+ GetAllRole func() ([]RoleModel, error)

+ GetRole func(role string) (*RoleModel, error)

+ GetRoleByFilter func(entity string, team string, app string, env string, act string) (RoleModel, error)

+ GetRoleById func(id int) (*RoleModel, error)

+ GetRolesByGroupId func(userId int32) ([]*RoleModel, error)

+ GetRolesByUserId func(userId int32) ([]RoleModel, error)

+ GetUserRoleMapping func(userRoleModelId int) (*UserRoleModel, error)

+ GetUserRoleMappingByRoleId func(roleId int) ([]*UserRoleModel, error)

+ GetUserRoleMappingByUserId func(userId int32) ([]*UserRoleModel, error)

+ SyncOrchestratorToCasbin func(team string, entityName string, env string, tx *pg.Tx) (bool, error)

+ UpdateRole func(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error)

+ type UserAuthRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewUserAuthRepositoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger) *UserAuthRepositoryImpl

+ func (impl UserAuthRepositoryImpl) CreateDefaultPolicies(team string, entityName string, env string, tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) CreateDefaultPoliciesForGlobalEntity(entity string, entityName string, action string, tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) CreateRole(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) CreateUpdateDefaultPoliciesForSuperAdmin(tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) CreateUserRoleMapping(userRoleModel *UserRoleModel, tx *pg.Tx) (*UserRoleModel, error)

+ func (impl UserAuthRepositoryImpl) DeleteRole(roleModel *RoleModel, tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) DeleteUserRoleMapping(userRoleModel *UserRoleModel, tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) GetAllRole() ([]RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRole(role string) (*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleByFilter(entity string, team string, app string, env string, act string) (RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleById(id int) (*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesByGroupId(roleGroupId int32) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesByUserId(userId int32) ([]RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetUserRoleMapping(userRoleModelId int) (*UserRoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetUserRoleMappingByRoleId(roleId int) ([]*UserRoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetUserRoleMappingByUserId(userId int32) ([]*UserRoleModel, error)

+ func (impl UserAuthRepositoryImpl) SyncOrchestratorToCasbin(team string, entityName string, env string, tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) UpdateRole(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error)

+ type UserModel struct

+ AccessToken string

+ Active bool

+ EmailId string

+ Id int32

+ TableName struct{}

+ type UserRepository interface

+ CreateUser func(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ DeleteUser func(userModel *UserModel, tx *pg.Tx) (bool, error)

+ FetchActiveOrDeletedUserByEmail func(email string) (*UserModel, error)

+ FetchActiveUserByEmail func(email string) (bean.UserInfo, error)

+ FetchUserDetailByEmail func(email string) (bean.UserInfo, error)

+ FetchUserMatchesByEmailId func(email string) ([]UserModel, error)

+ GetAll func() ([]UserModel, error)

+ GetById func(id int32) (*UserModel, error)

+ GetByIds func(ids []int32) ([]UserModel, error)

+ GetConnection func() (dbConnection *pg.DB)

+ GetUsersByFilter func(size int, from int) ([]UserModel, error)

+ UpdateUser func(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ type UserRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewUserRepositoryImpl(dbConnection *pg.DB) *UserRepositoryImpl

+ func (impl *UserRepositoryImpl) GetConnection() (dbConnection *pg.DB)

+ func (impl UserRepositoryImpl) CreateUser(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ func (impl UserRepositoryImpl) DeleteUser(userModel *UserModel, tx *pg.Tx) (bool, error)

+ func (impl UserRepositoryImpl) FetchActiveOrDeletedUserByEmail(email string) (*UserModel, error)

+ func (impl UserRepositoryImpl) FetchActiveUserByEmail(email string) (bean.UserInfo, error)

+ func (impl UserRepositoryImpl) FetchUserDetailByEmail(email string) (bean.UserInfo, error)

+ func (impl UserRepositoryImpl) FetchUserMatchesByEmailId(email string) ([]UserModel, error)

+ func (impl UserRepositoryImpl) GetAll() ([]UserModel, error)

+ func (impl UserRepositoryImpl) GetById(id int32) (*UserModel, error)

+ func (impl UserRepositoryImpl) GetByIds(ids []int32) ([]UserModel, error)

+ func (impl UserRepositoryImpl) GetUsersByFilter(size int, from int) ([]UserModel, error)

+ func (impl UserRepositoryImpl) UpdateUser(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ type UserRoleModel struct

+ Id int

+ RoleId int

+ TableName struct{}

+ User UserModel

+ UserId int32