repository

package

Go to main page

Versions in this module

v0

v0.2.21

Aug 13, 2021

v0.2.20

Aug 10, 2021

Changes in this version

type UserRepository

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

type UserRepositoryImpl

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

v0.2.19

Jul 28, 2021

v0.2.18

Jul 20, 2021

v0.2.17

Jul 16, 2021

v0.2.16

Jul 9, 2021

v0.2.15

Jul 2, 2021

v0.2.14

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)

v0.2.13

Jun 22, 2021

Changes in this version

type SettingOptionDTO

+ AppName string

v0.2.12

Jun 1, 2021

v0.2.11

May 24, 2021

Changes in this version

type GitOpsConfig

+ AzureProject string

v0.2.10

May 23, 2021

v0.2.9

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

v0.2.8

Apr 23, 2021

v0.2.7

Apr 12, 2021

v0.2.6

Apr 7, 2021

Changes in this version

+ const Failure

+ const NewDeployment

+ const REGISTRYTYPE_DOCKER_HUB

+ 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

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

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

+ SaveNewDeployment func(deploymentStatus *DeploymentStatus, tx *pg.Tx) error

+ type AppListingRepositoryImpl struct

+ Logger *zap.SugaredLogger

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

+ 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) PrometheusApiByEnvId(id int) (*string, error)

+ func (impl AppListingRepositoryImpl) SaveNewDeployment(deploymentStatus *DeploymentStatus, tx *pg.Tx) 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL