repository

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

@description: app listing view

Index

Constants

View Source 
const (
	CM_TYPE_CONFIG     = "CONFIGMAP"
	CS_TYPE_CONFIG     = "SECRET"
	ENVIRONMENT_CONFIG = "environment"
	VOLUME_CONFIG      = "volume"
)
View Source 
const (
	PIPELINE_TYPE_CI    = "CI"
	PIPELINE_TYPE_CD    = "CD"
	PIPELINE_TYPE_CI_CD = "CI/CD"
)
View Source 
const EmptyLikeRegex = "%%"
View Source 
const (
	GLOBAL_CONTAINER_REGISTRY credentialsSource = "global_container_registry"
)

Variables

This section is empty.

Functions

func BuildQueryForArtifactsForCdStage added in v0.6.26 

func BuildQueryForArtifactsForCdStage(listingFilterOptions bean.ArtifactsListFilterOptions) string

func BuildQueryForArtifactsForRollback added in v0.6.26 

func BuildQueryForArtifactsForRollback(listingFilterOptions bean.ArtifactsListFilterOptions) string

func BuildQueryForParentTypeCIOrWebhook added in v0.6.26 

func BuildQueryForParentTypeCIOrWebhook(listingFilterOpts bean.ArtifactsListFilterOptions) string

Types

type AppListingRepository 

type AppListingRepository interface {
	FetchJobs(appIds []int, statuses []string, environmentIds []int, sortOrder string) ([]*bean.JobListingContainer, error)
	FetchOverviewCiPipelines(jobId int) ([]*bean.JobListingContainer, error)
	FetchJobsLastSucceededOn(ciPipelineIDs []int) ([]*bean.CiPipelineLastSucceededTime, error)
	FetchAppDetail(ctx context.Context, appId int, envId int) (bean.AppDetailContainer, error)

	FetchAppTriggerView(appId int) ([]bean.TriggerView, error)
	FetchAppStageStatus(appId int, appType int) ([]bean.AppStageStatus, error)

	// Not in used
	PrometheusApiByEnvId(id int) (*string, error)

	FetchOtherEnvironment(appId int) ([]*bean.Environment, error)
	FetchMinDetailOtherEnvironment(appId int) ([]*bean.Environment, error)
	DeploymentDetailByArtifactId(ciArtifactId int, envId int) (bean.DeploymentDetailContainer, error)
	FindAppCount(isProd bool) (int, error)
	FetchAppsByEnvironmentV2(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, int, error)
	FetchOverviewAppsByEnvironment(envId, limit, offset int) ([]*bean.AppEnvironmentContainer, error)
	FetchLastDeployedImage(appId, envId int) (*LastDeployed, error)
}

type AppListingRepositoryImpl 

type AppListingRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewAppListingRepositoryImpl 

func NewAppListingRepositoryImpl(
	Logger *zap.SugaredLogger,
	dbConnection *pg.DB,
	appListingRepositoryQueryBuilder helper.AppListingRepositoryQueryBuilder,
	environmentRepository repository2.EnvironmentRepository,
	gitOpsRepository GitOpsConfigRepository, appWorkflowRepository appWorkflow2.AppWorkflowRepository) *AppListingRepositoryImpl

func (AppListingRepositoryImpl) DeploymentDetailByArtifactId 

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

func (AppListingRepositoryImpl) FetchAppDetail 

func (impl AppListingRepositoryImpl) FetchAppDetail(ctx context.Context, appId int, envId int) (bean.AppDetailContainer, error)

func (AppListingRepositoryImpl) FetchAppStageStatus 

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

func (AppListingRepositoryImpl) FetchAppTriggerView 

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

func (AppListingRepositoryImpl) FetchAppsByEnvironmentV2 added in v0.6.17 

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

func (AppListingRepositoryImpl) FetchJobs added in v0.6.15 

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

func (AppListingRepositoryImpl) FetchJobsLastSucceededOn added in v0.6.15 

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

func (AppListingRepositoryImpl) FetchLastDeployedImage added in v0.6.26 

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

func (AppListingRepositoryImpl) FetchMinDetailOtherEnvironment added in v0.6.17 

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

func (AppListingRepositoryImpl) FetchOtherEnvironment 

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

func (AppListingRepositoryImpl) FetchOverviewAppsByEnvironment added in v0.6.17 

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

func (AppListingRepositoryImpl) FetchOverviewCiPipelines added in v0.6.15 

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

func (AppListingRepositoryImpl) FindAppCount added in v0.2.14 

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

func (AppListingRepositoryImpl) PrometheusApiByEnvId 

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

type AppNameTypeIdContainerDBResponse added in v0.6.9 

type AppNameTypeIdContainerDBResponse struct {
	AppName string `sql:"app_name"`
	AppId   int    `sql:"id"`
}

type ArtifactsSourceType added in v0.6.28 

type ArtifactsSourceType = string
const (
	CI_RUNNER ArtifactsSourceType = "CI-RUNNER"
	WEBHOOK   ArtifactsSourceType = "EXTERNAL" // Currently in use instead of EXT
	PRE_CD    ArtifactsSourceType = "pre_cd"
	POST_CD   ArtifactsSourceType = "post_cd"
	POST_CI   ArtifactsSourceType = "post_ci"
	GOCD      ArtifactsSourceType = "GOCD"
	// deprecated; Handled for backward compatibility
	EXT ArtifactsSourceType = "ext"
)

List of possible DataSource Type for an artifact

type Attributes 

type Attributes struct {
	Id     int    `sql:"id,pk"`
	Key    string `sql:"key,notnull"`
	Value  string `sql:"value,notnull"`
	Active bool   `sql:"active, notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type AttributesRepository 

type AttributesRepository interface {
	Save(model *Attributes, tx *pg.Tx) (*Attributes, error)
	Update(model *Attributes, tx *pg.Tx) error
	FindByKey(key string) (*Attributes, error)
	FindById(id int) (*Attributes, error)
	FindActiveList() ([]*Attributes, error)
	GetConnection() (dbConnection *pg.DB)
}

type AttributesRepositoryImpl 

type AttributesRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewAttributesRepositoryImpl 

func NewAttributesRepositoryImpl(dbConnection *pg.DB) *AttributesRepositoryImpl

func (AttributesRepositoryImpl) FindActiveList 

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

func (AttributesRepositoryImpl) FindById 

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

func (AttributesRepositoryImpl) FindByKey 

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

func (*AttributesRepositoryImpl) GetConnection 

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

func (AttributesRepositoryImpl) Save 

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

func (AttributesRepositoryImpl) Update 

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

type AuthMode 

type AuthMode string
const (
	AUTH_MODE_USERNAME_PASSWORD AuthMode = "USERNAME_PASSWORD"
	AUTH_MODE_SSH               AuthMode = "SSH"
	AUTH_MODE_ACCESS_TOKEN      AuthMode = "ACCESS_TOKEN"
	AUTH_MODE_ANONYMOUS         AuthMode = "ANONYMOUS"
)

type CiArtifact 

type CiArtifact struct {
	Id                    int       `sql:"id,pk"`
	PipelineId            int       `sql:"pipeline_id"` // id of the ci pipeline from which this webhook was triggered
	Image                 string    `sql:"image,notnull"`
	ImageDigest           string    `sql:"image_digest,notnull"`
	MaterialInfo          string    `sql:"material_info"`       // git material metadata json array string
	DataSource            string    `sql:"data_source,notnull"` // possible values -> (CI_RUNNER,EXTERNAL,post_ci,pre_cd,post_cd) CI_runner is for normal build ci
	WorkflowId            *int      `sql:"ci_workflow_id"`
	ParentCiArtifact      int       `sql:"parent_ci_artifact"`
	ScanEnabled           bool      `sql:"scan_enabled,notnull"`
	Scanned               bool      `sql:"scanned,notnull"`
	ExternalCiPipelineId  int       `sql:"external_ci_pipeline_id"`
	IsArtifactUploaded    bool      `sql:"is_artifact_uploaded"`
	CredentialsSourceType string    `sql:"credentials_source_type"`
	CredentialSourceValue string    `sql:"credentials_source_value"`
	ComponentId           int       `sql:"component_id"`
	DeployedTime          time.Time `sql:"-"`
	Deployed              bool      `sql:"-"`
	Latest                bool      `sql:"-"`
	RunningOnParent       bool      `sql:"-"`
	sql.AuditLog
	// contains filtered or unexported fields
}

func (*CiArtifact) IsMigrationRequired added in v0.6.28 

func (artifact *CiArtifact) IsMigrationRequired() bool

func (*CiArtifact) IsRegistryCredentialMapped added in v0.6.29 

func (artifact *CiArtifact) IsRegistryCredentialMapped() bool

func (*CiArtifact) ParseMaterialInfo 

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

return map of gitUrl:hash

type CiArtifactRepository 

type CiArtifactRepository interface {
	Save(artifact *CiArtifact) error
	Delete(artifact *CiArtifact) error

	// Get returns the CiArtifact of the given id.
	// Note: Use Get along with MigrateToWebHookDataSourceType. For webhook artifacts, migration is required for column DataSource from 'ext' to 'EXTERNAL'
	Get(id int) (artifact *CiArtifact, err error)
	GetArtifactParentCiAndWorkflowDetailsByIds(ids []int) ([]*CiArtifact, error)
	GetByWfId(wfId int) (artifact *CiArtifact, err error)
	GetArtifactsByCDPipeline(cdPipelineId, limit int, parentId int, parentType bean.WorkflowType) ([]*CiArtifact, error)
	GetArtifactsByCDPipelineV3(listingFilterOpts *bean.ArtifactsListFilterOptions) ([]*CiArtifact, int, error)
	GetLatestArtifactTimeByCiPipelineIds(ciPipelineIds []int) ([]*CiArtifact, error)
	GetLatestArtifactTimeByCiPipelineId(ciPipelineId int) (*CiArtifact, error)
	GetArtifactsByCDPipelineV2(cdPipelineId int) ([]CiArtifact, error)
	GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.WorkflowType) ([]CiArtifact, error)
	SaveAll(artifacts []*CiArtifact) ([]*CiArtifact, error)
	GetArtifactsByCiPipelineId(ciPipelineId int) ([]CiArtifact, error)
	GetArtifactsByCiPipelineIds(ciPipelineIds []int) ([]CiArtifact, error)
	FinDByParentCiArtifactAndCiId(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error)
	GetLatest(cdPipelineId int) (int, error)
	GetByImageDigest(imageDigest string) (artifact *CiArtifact, err error)
	GetByIds(ids []int) ([]*CiArtifact, error)
	GetArtifactByCdWorkflowId(cdWorkflowId int) (artifact *CiArtifact, err error)
	GetArtifactsByParentCiWorkflowId(parentCiWorkflowId int) ([]string, error)
	FetchArtifactsByCdPipelineIdV2(listingFilterOptions bean.ArtifactsListFilterOptions) ([]CiArtifactWithExtraData, int, error)
	FindArtifactByListFilter(listingFilterOptions *bean.ArtifactsListFilterOptions) ([]*CiArtifact, int, error)
	GetArtifactsByDataSourceAndComponentId(dataSource string, componentId int) ([]CiArtifact, error)
	FindCiArtifactByImagePaths(images []string) ([]CiArtifact, error)

	// MigrateToWebHookDataSourceType is used for backward compatibility. It'll migrate the deprecated DataSource type
	MigrateToWebHookDataSourceType(id int) error
	UpdateLatestTimestamp(artifactIds []int) error
}

type CiArtifactRepositoryImpl 

type CiArtifactRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewCiArtifactRepositoryImpl 

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

func (CiArtifactRepositoryImpl) Delete added in v0.6.9 

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

func (CiArtifactRepositoryImpl) FetchArtifactsByCdPipelineIdV2 added in v0.6.26 

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

func (CiArtifactRepositoryImpl) FinDByParentCiArtifactAndCiId 

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

func (CiArtifactRepositoryImpl) FindArtifactByListFilter added in v0.6.26 

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

func (CiArtifactRepositoryImpl) FindCiArtifactByImagePaths added in v0.6.26 

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

func (CiArtifactRepositoryImpl) Get 

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

func (CiArtifactRepositoryImpl) GetArtifactByCdWorkflowId added in v0.3.12 

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

func (CiArtifactRepositoryImpl) GetArtifactParentCiAndWorkflowDetailsByIds added in v0.6.17 

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

func (CiArtifactRepositoryImpl) GetArtifactsByCDPipeline 

func (impl CiArtifactRepositoryImpl) GetArtifactsByCDPipeline(cdPipelineId, limit int, parentId int, parentType bean.WorkflowType) ([]*CiArtifact, error)

this method takes CD Pipeline id and Returns List of Artifacts Latest By last deployed

func (CiArtifactRepositoryImpl) GetArtifactsByCDPipelineAndRunnerType 

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

func (CiArtifactRepositoryImpl) GetArtifactsByCDPipelineV2 

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

func (CiArtifactRepositoryImpl) GetArtifactsByCDPipelineV3 added in v0.6.26 

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

func (CiArtifactRepositoryImpl) GetArtifactsByCiPipelineId 

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

func (CiArtifactRepositoryImpl) GetArtifactsByCiPipelineIds added in v0.6.26 

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

func (CiArtifactRepositoryImpl) GetArtifactsByDataSourceAndComponentId added in v0.6.26 

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

func (CiArtifactRepositoryImpl) GetArtifactsByParentCiWorkflowId added in v0.6.24 

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

GetArtifactsByParentCiWorkflowId will get all artifacts of child workflow sorted by descending order to fetch latest at top, child workflow required for handling container image polling plugin as there can be multiple images from a single parent workflow, which are accommodated in child workflows

func (CiArtifactRepositoryImpl) GetByIds 

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

func (CiArtifactRepositoryImpl) GetByImageDigest 

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

func (CiArtifactRepositoryImpl) GetByWfId 

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

func (CiArtifactRepositoryImpl) GetLatest 

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

func (CiArtifactRepositoryImpl) GetLatestArtifactTimeByCiPipelineId added in v0.6.24 

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

GetLatestArtifactTimeByCiPipelineId will fetch latest ci artifact time(created) against that ci pipeline

func (CiArtifactRepositoryImpl) GetLatestArtifactTimeByCiPipelineIds added in v0.6.24 

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

func (CiArtifactRepositoryImpl) MigrateToWebHookDataSourceType added in v0.6.28 

func (impl CiArtifactRepositoryImpl) MigrateToWebHookDataSourceType(id int) error

func (CiArtifactRepositoryImpl) Save 

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

func (CiArtifactRepositoryImpl) SaveAll 

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

func (CiArtifactRepositoryImpl) UpdateLatestTimestamp added in v0.6.26 

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

type CiArtifactWithExtraData added in v0.6.26 

type CiArtifactWithExtraData struct {
	CiArtifact
	PayloadSchema      string
	TotalCount         int
	TriggeredBy        int32
	StartedOn          time.Time
	CdWorkflowRunnerId int
}

type CiMaterialInfo 

type CiMaterialInfo struct {
	Material      Material       `json:"material"`
	Changed       bool           `json:"changed"`
	Modifications []Modification `json:"modifications"`
}

func GetCiMaterialInfo 

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

type CustomTag added in v0.6.25 

type CustomTag struct {
	Id                   int    `sql:"id"`
	EntityKey            int    `sql:"entity_key"`
	EntityValue          string `sql:"entity_value"`
	TagPattern           string `sql:"tag_pattern"`
	AutoIncreasingNumber int    `sql:"auto_increasing_number, notnull"`
	Active               bool   `sql:"active"`
	Metadata             string `sql:"metadata"`
	Enabled              bool   `sql:"enabled, notnull"`
	// contains filtered or unexported fields
}

type DeploymentGroup 

type DeploymentGroup struct {
	TableName           struct{} `sql:"deployment_group" pg:",discard_unknown_columns"`
	Id                  int      `sql:"id,pk"`
	Name                string   `sql:"name,notnull"`
	AppCount            int      `sql:"app_count,notnull"`
	NoOfApps            string   `sql:"no_of_apps"`
	EnvironmentId       int      `sql:"environment_id"`
	CiPipelineId        int      `sql:"ci_pipeline_id"`
	Active              bool     `sql:"active,notnull"`
	DeploymentGroupApps []*DeploymentGroupApp
	sql.AuditLog
}

type DeploymentGroupApp 

type DeploymentGroupApp struct {
	TableName         struct{} `sql:"deployment_group_app" pg:",discard_unknown_columns"`
	Id                int      `sql:"id,pk"`
	DeploymentGroupId int      `sql:"deployment_group_id"`
	AppId             int      `sql:"app_id"`
	Active            bool     `sql:"active,notnull"`
	sql.AuditLog
}

type DeploymentGroupAppRepository 

type DeploymentGroupAppRepository interface {
	Create(model *DeploymentGroupApp) (*DeploymentGroupApp, error)
	GetById(id int) (*DeploymentGroupApp, error)
	GetAll() ([]*DeploymentGroupApp, error)
	Update(model *DeploymentGroupApp) (*DeploymentGroupApp, error)
	Delete(model *DeploymentGroupApp) error
	GetByDeploymentGroup(deploymentGroupId int) ([]*DeploymentGroupApp, error)
}

type DeploymentGroupAppRepositoryImpl 

type DeploymentGroupAppRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewDeploymentGroupAppRepositoryImpl 

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

func (DeploymentGroupAppRepositoryImpl) Create 

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

func (DeploymentGroupAppRepositoryImpl) Delete 

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

func (DeploymentGroupAppRepositoryImpl) GetAll 

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

func (DeploymentGroupAppRepositoryImpl) GetByDeploymentGroup 

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

func (DeploymentGroupAppRepositoryImpl) GetById 

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

func (DeploymentGroupAppRepositoryImpl) Update 

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

type DeploymentGroupRepository 

type DeploymentGroupRepository interface {
	Create(model *DeploymentGroup) (*DeploymentGroup, error)
	GetById(id int) (*DeploymentGroup, error)
	GetAll() ([]DeploymentGroup, error)
	Update(model *DeploymentGroup) (*DeploymentGroup, error)
	Delete(model *DeploymentGroup) error
	FindByIdWithApp(id int) (*DeploymentGroup, error)
	FindByAppIdAndEnvId(envId, appId int) ([]DeploymentGroup, error)
	GetNamesByAppIdAndEnvId(envId, appId int) ([]string, error)
}

type DeploymentGroupRepositoryImpl 

type DeploymentGroupRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewDeploymentGroupRepositoryImpl 

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

func (*DeploymentGroupRepositoryImpl) Create 

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

func (*DeploymentGroupRepositoryImpl) Delete 

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

func (*DeploymentGroupRepositoryImpl) FindByAppIdAndEnvId added in v0.4.21 

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

func (*DeploymentGroupRepositoryImpl) FindByIdWithApp 

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

func (*DeploymentGroupRepositoryImpl) GetAll 

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

func (*DeploymentGroupRepositoryImpl) GetById 

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

func (*DeploymentGroupRepositoryImpl) GetNamesByAppIdAndEnvId added in v0.6.4 

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

func (*DeploymentGroupRepositoryImpl) Update 

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

type DeploymentStatus 

type DeploymentStatus struct {
	Id        int       `sql:"id,pk"`
	AppName   string    `sql:"app_name,notnull"`
	Status    string    `sql:"status,notnull"`
	AppId     int       `sql:"app_id"`
	EnvId     int       `sql:"env_id"`
	CreatedOn time.Time `sql:"created_on"`
	UpdatedOn time.Time `sql:"updated_on"`
	// contains filtered or unexported fields
}

below table is deprecated, not being used anywhere

type DeploymentTemplateComparisonMetadata added in v0.6.24 

type DeploymentTemplateComparisonMetadata struct {
	ChartRefId                  int                    `json:"chartRefId"`
	ChartVersion                string                 `json:"chartVersion,omitempty"`
	ChartType                   string                 `json:"chartType,omitempty"`
	EnvironmentId               int                    `json:"environmentId,omitempty"`
	EnvironmentName             string                 `json:"environmentName,omitempty"`
	DeploymentTemplateHistoryId int                    `json:"deploymentTemplateHistoryId,omitempty"`
	StartedOn                   *time.Time             `json:"startedOn,omitempty"`
	FinishedOn                  *time.Time             `json:"finishedOn,omitempty"`
	Status                      string                 `json:"status,omitempty"`
	PipelineId                  int                    `json:"pipelineId,omitempty"`
	Type                        DeploymentTemplateType `json:"type"`
}

type DeploymentTemplateRepository added in v0.6.24 

type DeploymentTemplateRepository interface {
	FetchDeploymentHistoryWithChartRefs(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)
	FetchPipelineOverrideValues(id int) (string, error)
	FetchLatestDeploymentWithChartRefs(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)
}

type DeploymentTemplateRepositoryImpl added in v0.6.24 

type DeploymentTemplateRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewDeploymentTemplateRepositoryImpl added in v0.6.24 

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

func (DeploymentTemplateRepositoryImpl) FetchDeploymentHistoryWithChartRefs added in v0.6.24 

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

func (DeploymentTemplateRepositoryImpl) FetchLatestDeploymentWithChartRefs added in v0.6.24 

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

func (DeploymentTemplateRepositoryImpl) FetchPipelineOverrideValues added in v0.6.24 

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

type DeploymentTemplateType added in v0.6.24 

type DeploymentTemplateType int
const (
	DefaultVersions            DeploymentTemplateType = 1
	PublishedOnEnvironments    DeploymentTemplateType = 2
	DeployedOnSelfEnvironment  DeploymentTemplateType = 3
	DeployedOnOtherEnvironment DeploymentTemplateType = 4
)

type GitConfiguration 

type GitConfiguration struct {
	URL string `json:"url"`
}

type GitHost added in v0.2.22 

type GitHost struct {
	Id              int    `sql:"id,pk"`
	Name            string `sql:"name,notnull"`
	Active          bool   `sql:"active,notnull"`
	WebhookUrl      string `sql:"webhook_url"`
	WebhookSecret   string `sql:"webhook_secret"`
	EventTypeHeader string `sql:"event_type_header"`
	SecretHeader    string `sql:"secret_header"`
	SecretValidator string `sql:"secret_validator"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type GitHostRepository added in v0.2.22 

type GitHostRepository interface {
	FindAll() ([]GitHost, error)
	FindOneById(Id int) (GitHost, error)
	FindOneByName(name string) (GitHost, error)
	Exists(name string) (bool, error)
	Save(gitHost *GitHost) error
}

type GitHostRepositoryImpl added in v0.2.22 

type GitHostRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewGitHostRepositoryImpl added in v0.2.22 

func NewGitHostRepositoryImpl(dbConnection *pg.DB) *GitHostRepositoryImpl

func (GitHostRepositoryImpl) Exists added in v0.2.22 

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

func (GitHostRepositoryImpl) FindAll added in v0.2.22 

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

func (GitHostRepositoryImpl) FindOneById added in v0.2.22 

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

func (GitHostRepositoryImpl) FindOneByName added in v0.2.22 

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

func (GitHostRepositoryImpl) Save added in v0.2.22 

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

type GitOpsConfig 

type GitOpsConfig struct {
	Id                    int    `sql:"id,pk"`
	Provider              string `sql:"provider"`
	Username              string `sql:"username"`
	Token                 string `sql:"token"`
	GitLabGroupId         string `sql:"gitlab_group_id"`
	GitHubOrgId           string `sql:"github_org_id"`
	AzureProject          string `sql:"azure_project"`
	Host                  string `sql:"host"`
	Active                bool   `sql:"active,notnull"`
	AllowCustomRepository bool   `sql:"allow_custom_repository,notnull"`
	BitBucketWorkspaceId  string `sql:"bitbucket_workspace_id"`
	BitBucketProjectKey   string `sql:"bitbucket_project_key"`
	EmailId               string `sql:"email_id"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type GitOpsConfigRepository 

type GitOpsConfigRepository interface {
	CreateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error)
	UpdateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) error
	GetGitOpsConfigById(id int) (*GitOpsConfig, error)
	GetAllGitOpsConfig() ([]*GitOpsConfig, error)
	GetAllGitOpsConfigCount() (int, error)
	GetGitOpsConfigByProvider(provider string) (*GitOpsConfig, error)
	GetGitOpsConfigActive() (*GitOpsConfig, error)
	GetConnection() *pg.DB
	GetEmailIdFromActiveGitOpsConfig() (string, error)
}

type GitOpsConfigRepositoryImpl 

type GitOpsConfigRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewGitOpsConfigRepositoryImpl 

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

func (*GitOpsConfigRepositoryImpl) CreateGitOpsConfig 

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

func (*GitOpsConfigRepositoryImpl) GetAllGitOpsConfig 

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

func (*GitOpsConfigRepositoryImpl) GetAllGitOpsConfigCount added in v0.7.0 

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

func (*GitOpsConfigRepositoryImpl) GetConnection 

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

func (*GitOpsConfigRepositoryImpl) GetEmailIdFromActiveGitOpsConfig added in v0.4.1 

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

func (*GitOpsConfigRepositoryImpl) GetGitOpsConfigActive 

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

func (*GitOpsConfigRepositoryImpl) GetGitOpsConfigById 

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

func (*GitOpsConfigRepositoryImpl) GetGitOpsConfigByProvider 

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

func (*GitOpsConfigRepositoryImpl) UpdateGitOpsConfig 

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

type GitProvider 

type GitProvider struct {
	Id            int      `sql:"id,pk"`
	Name          string   `sql:"name,notnull"`
	Url           string   `sql:"url,notnull"`
	UserName      string   `sql:"user_name"`
	Password      string   `sql:"password"`
	SshPrivateKey string   `sql:"ssh_private_key"`
	AccessToken   string   `sql:"access_token"`
	AuthMode      AuthMode `sql:"auth_mode,notnull"`
	Active        bool     `sql:"active,notnull"`
	Deleted       bool     `sql:"deleted,notnull"`
	GitHostId     int      `sql:"git_host_id"` //id stored in db git_host( foreign key)
	sql.AuditLog
	// contains filtered or unexported fields
}

type GitProviderRepository 

type GitProviderRepository interface {
	Save(gitProvider *GitProvider) error
	ProviderExists(url string) (bool, error)
	FindAllActiveForAutocomplete() ([]GitProvider, error)
	FindAll() ([]GitProvider, error)
	FindAllGitProviderCount() (int, error)
	FindOne(providerId string) (GitProvider, error)
	FindByUrl(providerUrl string) (GitProvider, error)
	Update(gitProvider *GitProvider) error
	MarkProviderDeleted(gitProvider *GitProvider) error
}

type GitProviderRepositoryImpl 

type GitProviderRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewGitProviderRepositoryImpl 

func NewGitProviderRepositoryImpl(dbConnection *pg.DB) *GitProviderRepositoryImpl

func (GitProviderRepositoryImpl) FindAll 

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

func (GitProviderRepositoryImpl) FindAllActiveForAutocomplete 

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

func (GitProviderRepositoryImpl) FindAllGitProviderCount added in v0.7.0 

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

func (GitProviderRepositoryImpl) FindByUrl added in v0.3.6 

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

func (GitProviderRepositoryImpl) FindOne 

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

func (GitProviderRepositoryImpl) MarkProviderDeleted added in v0.3.15 

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

func (GitProviderRepositoryImpl) ProviderExists 

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

func (GitProviderRepositoryImpl) Save 

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

func (GitProviderRepositoryImpl) Update 

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

type GitWebhook 

type GitWebhook struct {
	Id            int       `sql:"id,pk"`
	CiMaterialId  int       `sql:"ci_material_id"`
	GitMaterialId int       `sql:"git_material_id"`
	Type          string    `sql:"type"`
	Value         string    `sql:"value"`
	Active        bool      `sql:"active"`
	LastSeenHash  string    `sql:"last_seen_hash"`
	CreatedOn     time.Time `sql:"created_on"`
	// contains filtered or unexported fields
}

type GitWebhookRepository 

type GitWebhookRepository interface {
	Save(gitWebhook *GitWebhook) error
}

type GitWebhookRepositoryImpl 

type GitWebhookRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewGitWebhookRepositoryImpl 

func NewGitWebhookRepositoryImpl(dbConnection *pg.DB) *GitWebhookRepositoryImpl

func (*GitWebhookRepositoryImpl) Save 

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

type GlobalCMCS added in v0.6.1 

type GlobalCMCS struct {
	TableName  struct{} `sql:"global_cm_cs" pg:",discard_unknown_columns"`
	Id         int      `sql:"id,pk"`
	ConfigType string   `sql:"config_type"` // [CONFIGMAP, SECRET]
	Name       string   `sql:"name"`
	Type       string   `sql:"type"` // [environment, volume]
	//json string of map of key:value, example: '{ "a" : "b", "c" : "d"}'
	Data               string `sql:"data"`
	MountPath          string `sql:"mount_path"`
	Deleted            bool   `sql:"deleted,notnull"`
	SecretIngestionFor string `sql:"secret_ingestion_for,notnull"` // [CI, CD, CI/CD]
	sql.AuditLog
}

type GlobalCMCSRepository added in v0.6.1 

type GlobalCMCSRepository interface {
	Save(model *GlobalCMCS) (*GlobalCMCS, error)
	Update(model *GlobalCMCS) (*GlobalCMCS, error)
	FindAllActive() ([]*GlobalCMCS, error)
	FindById(id int) (*GlobalCMCS, error)
	FindByConfigTypeAndName(configType, name string) (*GlobalCMCS, error)
	FindByMountPath(mountPath string) (*GlobalCMCS, error)
	FindAllActiveByPipelineType(pipelineType string) ([]*GlobalCMCS, error)
	Delete(model *GlobalCMCS) error
}

type GlobalCMCSRepositoryImpl added in v0.6.1 

type GlobalCMCSRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewGlobalCMCSRepositoryImpl added in v0.6.1 

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

func (*GlobalCMCSRepositoryImpl) Delete added in v0.6.15 

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

func (*GlobalCMCSRepositoryImpl) FindAllActive added in v0.6.1 

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

func (*GlobalCMCSRepositoryImpl) FindAllActiveByPipelineType added in v0.6.15 

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

func (*GlobalCMCSRepositoryImpl) FindByConfigTypeAndName added in v0.6.1 

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

func (*GlobalCMCSRepositoryImpl) FindById added in v0.6.15 

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

func (*GlobalCMCSRepositoryImpl) FindByMountPath added in v0.6.1 

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

func (*GlobalCMCSRepositoryImpl) Save added in v0.6.1 

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

func (*GlobalCMCSRepositoryImpl) Update added in v0.6.1 

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

type ImagePathReservation added in v0.6.25 

type ImagePathReservation struct {
	Id          int    `sql:"id"`
	ImagePath   string `sql:"image_path"`
	CustomTagId int    `sql:"custom_tag_id"`
	// contains filtered or unexported fields
}

type ImageTagRepository added in v0.6.25 

type ImageTagRepository interface {
	GetConnection() *pg.DB
	CreateImageTag(customTagData *CustomTag) error
	FetchCustomTagData(entityType int, entityValue string) (*CustomTag, error)
	IncrementAndFetchByEntityKeyAndValue(tx *pg.Tx, entityKey int, entityValue string) (*CustomTag, error)
	FindByImagePath(tx *pg.Tx, path string) ([]*ImagePathReservation, error)
	InsertImagePath(tx *pg.Tx, reservation *ImagePathReservation) error
	UpdateImageTag(customTag *CustomTag) error
	DeleteByEntityKeyAndValue(entityKey int, entityValue string) error
	DeactivateImagePathReservation(id int) error
	FetchActiveCustomTagData(entityKey int, entityValue string) (*CustomTag, error)
	DeactivateImagePathReservationByImagePaths(tx *pg.Tx, imagePaths []string) error
	DeactivateImagePathReservationByImagePathReservationIds(tx *pg.Tx, imagePathReservationIds []int) error
	DisableCustomTag(entityKey int, entityValue string) error
}

type ImageTagRepositoryImpl added in v0.6.25 

type ImageTagRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewImageTagRepository added in v0.6.25 

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

func (*ImageTagRepositoryImpl) CreateImageTag added in v0.6.25 

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

func (*ImageTagRepositoryImpl) DeactivateImagePathReservation added in v0.6.25 

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

func (*ImageTagRepositoryImpl) DeactivateImagePathReservationByImagePathReservationIds added in v0.6.26 

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

func (*ImageTagRepositoryImpl) DeactivateImagePathReservationByImagePaths added in v0.6.26 

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

func (*ImageTagRepositoryImpl) DeleteByEntityKeyAndValue added in v0.6.25 

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

func (*ImageTagRepositoryImpl) DisableCustomTag added in v0.6.26 

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

func (*ImageTagRepositoryImpl) FetchActiveCustomTagData added in v0.6.25 

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

func (*ImageTagRepositoryImpl) FetchCustomTagData added in v0.6.25 

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

func (*ImageTagRepositoryImpl) FindByImagePath added in v0.6.25 

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

func (*ImageTagRepositoryImpl) GetConnection added in v0.6.25 

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

func (*ImageTagRepositoryImpl) IncrementAndFetchByEntityKeyAndValue added in v0.6.25 

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

func (*ImageTagRepositoryImpl) InsertImagePath added in v0.6.25 

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

func (*ImageTagRepositoryImpl) UpdateImageTag added in v0.6.25 

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

type LastDeployed added in v0.6.26 

type LastDeployed struct {
	CiArtifactId      int    `sql:"ci_artifact_id"`
	LastDeployedBy    string `sql:"last_deployed_by"`
	LastDeployedImage string `sql:"last_deployed_image"`
}

type LinkoutsModel 

type LinkoutsModel struct {
	TableName     struct{} `sql:"app_env_linkouts" pg:",discard_unknown_columns"`
	Id            int      `sql:"id,pk"`
	AppId         int      `sql:"app_id,notnull"`
	EnvironmentId int      `sql:"environment_id,notnull"`
	Link          string   `sql:"link"`
	Description   string   `sql:"description"`
	Name          string   `sql:"name"`
	sql.AuditLog
}

type LinkoutsRepository 

type LinkoutsRepository interface {
	Create(model *LinkoutsModel) (*LinkoutsModel, error)
	GetById(id int) (*LinkoutsModel, error)
	GetAll() ([]LinkoutsModel, error)
	Update(model *LinkoutsModel) (*LinkoutsModel, error)
	FetchLinkoutsByAppIdAndEnvId(appId int, envId int) ([]LinkoutsModel, error)
	FetchLinkoutById(Id int) (bean.LinkOuts, error)
}

type LinkoutsRepositoryImpl 

type LinkoutsRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewLinkoutsRepositoryImpl 

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

func (LinkoutsRepositoryImpl) Create 

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

func (LinkoutsRepositoryImpl) FetchLinkoutById 

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

func (LinkoutsRepositoryImpl) FetchLinkoutsByAppIdAndEnvId 

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

func (LinkoutsRepositoryImpl) GetAll 

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

func (LinkoutsRepositoryImpl) GetById 

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

func (LinkoutsRepositoryImpl) Update 

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

type Material 

type Material struct {
	PluginID         string           `json:"plugin-id"`
	GitConfiguration GitConfiguration `json:"git-configuration"`
	ScmConfiguration ScmConfiguration `json:"scm-configuration"`
	Type             string           `json:"type"`
}

type Modification 

type Modification struct {
	Revision     string            `json:"revision"`
	ModifiedTime string            `json:"modified-time"`
	Data         map[string]string `json:"data"`
	Author       string            `json:"author"`
	Message      string            `json:"message"`
	Branch       string            `json:"branch"`
	Tag          string            `json:"tag,omitempty"`
	WebhookData  WebhookData       `json:"webhookData,omitempty"`
}

type NotificationSettings 

type NotificationSettings struct {
	Id                   int    `sql:"id,pk"`
	TeamId               *int   `sql:"team_id"`
	AppId                *int   `sql:"app_id"`
	EnvId                *int   `sql:"env_id"`
	PipelineId           *int   `sql:"pipeline_id"`
	PipelineType         string `sql:"pipeline_type"`
	EventTypeId          int    `sql:"event_type_id"`
	Config               string `sql:"config"`
	ViewId               int    `sql:"view_id"`
	NotificationRuleId   int    `sql:"notification_rule_id"`
	AdditionalConfigJson string `sql:"additional_config_json"` // user defined config json;
	// contains filtered or unexported fields
}

type NotificationSettingsRepository 

type NotificationSettingsRepository interface {
	FindNSViewCount() (int, error)
	SaveNotificationSettingsConfig(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)
	FindNotificationSettingsViewById(id int) (*NotificationSettingsView, error)
	FindNotificationSettingsViewByIds(id []*int) ([]*NotificationSettingsView, error)
	UpdateNotificationSettingsView(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)
	SaveNotificationSetting(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)
	UpdateNotificationSettings(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)
	FindNotificationSettingsByViewId(viewId int) ([]NotificationSettings, error)
	SaveAllNotificationSettings(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error)
	DeleteNotificationSettingsByConfigId(viewId int, tx *pg.Tx) (int, error)
	FindAll(offset int, size int) ([]*NotificationSettingsView, error)
	DeleteNotificationSettingsViewById(id int, tx *pg.Tx) (int, error)

	FindNotificationSettingDeploymentOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)
	FindNotificationSettingBuildOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)
	FetchNotificationSettingGroupBy(viewId int) ([]NotificationSettings, error)
	FindNotificationSettingsByConfigIdAndConfigType(configId int, configType string) ([]*NotificationSettings, error)
}

type NotificationSettingsRepositoryImpl 

type NotificationSettingsRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewNotificationSettingsRepositoryImpl 

func NewNotificationSettingsRepositoryImpl(dbConnection *pg.DB) *NotificationSettingsRepositoryImpl

func (*NotificationSettingsRepositoryImpl) DeleteNotificationSettingsByConfigId 

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

func (*NotificationSettingsRepositoryImpl) DeleteNotificationSettingsViewById 

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

func (*NotificationSettingsRepositoryImpl) FetchNotificationSettingGroupBy 

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

func (*NotificationSettingsRepositoryImpl) FindAll 

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

func (*NotificationSettingsRepositoryImpl) FindNSViewCount 

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

func (*NotificationSettingsRepositoryImpl) FindNotificationSettingBuildOptions 

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

func (*NotificationSettingsRepositoryImpl) FindNotificationSettingDeploymentOptions 

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

func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsByConfigIdAndConfigType added in v0.3.15 

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

func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsByViewId 

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

func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsViewById 

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

func (*NotificationSettingsRepositoryImpl) FindNotificationSettingsViewByIds 

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

func (*NotificationSettingsRepositoryImpl) SaveAllNotificationSettings 

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

func (*NotificationSettingsRepositoryImpl) SaveNotificationSetting 

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

func (*NotificationSettingsRepositoryImpl) SaveNotificationSettingsConfig 

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

func (*NotificationSettingsRepositoryImpl) UpdateNotificationSettings 

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

func (*NotificationSettingsRepositoryImpl) UpdateNotificationSettingsView 

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

type NotificationSettingsView 

type NotificationSettingsView struct {
	Id       int    `sql:"id,pk"`
	Config   string `sql:"config"`
	Internal bool   `sql:"internal"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type NotificationSettingsViewWithAppEnv 

type NotificationSettingsViewWithAppEnv struct {
	Id              int    `json:"id"`
	AppId           *int   `json:"app_id"`
	EnvId           *int   `json:"env_id"`
	ConfigName      string `sql:"config_name"`
	Config          string `sql:"config"`
	AppName         string `json:"app_name"`
	EnvironmentName string `json:"env_name"`
	sql.AuditLog
}

type SESConfig 

type SESConfig struct {
	Id           int    `sql:"id,pk"`
	Region       string `sql:"region"`
	AccessKey    string `sql:"access_key"`
	SecretKey    string `sql:"secret_access_key"`
	FromEmail    string `sql:"from_email"`
	SessionToken string `sql:"session_token"`
	ConfigName   string `sql:"config_name"`
	Description  string `sql:"description"`
	OwnerId      int32  `sql:"owner_id"`
	Default      bool   `sql:"default,notnull"`
	Deleted      bool   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type SESNotificationRepository 

type SESNotificationRepository interface {
	FindOne(id int) (*SESConfig, error)
	UpdateSESConfig(sesConfig *SESConfig) (*SESConfig, error)
	SaveSESConfig(sesConfig *SESConfig) (*SESConfig, error)
	FindAll() ([]*SESConfig, error)
	FindByIdsIn(ids []int) ([]*SESConfig, error)
	FindByTeamIdOrOwnerId(ownerId int32) ([]*SESConfig, error)
	UpdateSESConfigDefault() (bool, error)
	FindByIds(ids []*int) ([]*SESConfig, error)
	FindDefault() (*SESConfig, error)
	MarkSESConfigDeleted(sesConfig *SESConfig) error
}

type SESNotificationRepositoryImpl 

type SESNotificationRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewSESNotificationRepositoryImpl 

func NewSESNotificationRepositoryImpl(dbConnection *pg.DB) *SESNotificationRepositoryImpl

func (*SESNotificationRepositoryImpl) FindAll 

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

func (*SESNotificationRepositoryImpl) FindByIds 

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

func (*SESNotificationRepositoryImpl) FindByIdsIn 

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

func (*SESNotificationRepositoryImpl) FindByTeamIdOrOwnerId 

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

func (*SESNotificationRepositoryImpl) FindDefault 

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

func (*SESNotificationRepositoryImpl) FindOne 

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

func (*SESNotificationRepositoryImpl) MarkSESConfigDeleted added in v0.3.15 

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

func (*SESNotificationRepositoryImpl) SaveSESConfig 

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

func (*SESNotificationRepositoryImpl) UpdateSESConfig 

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

func (*SESNotificationRepositoryImpl) UpdateSESConfigDefault 

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

type SMTPConfig added in v0.4.24 

type SMTPConfig struct {
	Id           int    `sql:"id,pk"`
	Port         string `sql:"port"`
	Host         string `sql:"host"`
	AuthType     string `sql:"auth_type"`
	AuthUser     string `sql:"auth_user"`
	AuthPassword string `sql:"auth_password"`
	FromEmail    string `sql:"from_email"`
	ConfigName   string `sql:"config_name"`
	Description  string `sql:"description"`
	OwnerId      int32  `sql:"owner_id"`
	Default      bool   `sql:"default,notnull"`
	Deleted      bool   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type SMTPNotificationRepository added in v0.4.24 

type SMTPNotificationRepository interface {
	FindOne(id int) (*SMTPConfig, error)
	UpdateSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
	SaveSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
	FindAll() ([]*SMTPConfig, error)
	FindByIdsIn(ids []int) ([]*SMTPConfig, error)
	FindByTeamIdOrOwnerId(ownerId int32) ([]*SMTPConfig, error)
	UpdateSMTPConfigDefault() (bool, error)
	FindByIds(ids []*int) ([]*SMTPConfig, error)
	FindDefault() (*SMTPConfig, error)
	MarkSMTPConfigDeleted(smtpConfig *SMTPConfig) error
}

type SMTPNotificationRepositoryImpl added in v0.4.24 

type SMTPNotificationRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewSMTPNotificationRepositoryImpl added in v0.4.24 

func NewSMTPNotificationRepositoryImpl(dbConnection *pg.DB) *SMTPNotificationRepositoryImpl

func (*SMTPNotificationRepositoryImpl) FindAll added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) FindByIds added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) FindByIdsIn added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) FindByTeamIdOrOwnerId added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) FindDefault added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) FindOne added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) MarkSMTPConfigDeleted added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) SaveSMTPConfig added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) UpdateSMTPConfig added in v0.4.24 

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

func (*SMTPNotificationRepositoryImpl) UpdateSMTPConfigDefault added in v0.4.24 

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

type ScmConfiguration 

type ScmConfiguration struct {
	URL string `json:"url"`
}

type SearchRequest 

type SearchRequest struct {
	TeamId       []*int `json:"teamId" validate:"number"`
	EnvId        []*int `json:"envId" validate:"number"`
	AppId        []*int `json:"appId" validate:"number"`
	PipelineName string `json:"pipelineName"`
	UserId       int32  `json:"-"`
}

type SettingOptionDTO 

type SettingOptionDTO struct {
	//TeamId       int    `json:"-"`
	//AppId        int    `json:"-"`
	//EnvId        int    `json:"-"`
	PipelineId      int    `json:"pipelineId"`
	PipelineName    string `json:"pipelineName"`
	PipelineType    string `json:"pipelineType"`
	AppName         string `json:"appName"`
	EnvironmentName string `json:"environmentName,omitempty"`
}

type SlackConfig 

type SlackConfig struct {
	Id          int    `sql:"id,pk"`
	WebHookUrl  string `sql:"web_hook_url"`
	ConfigName  string `sql:"config_name"`
	Description string `sql:"description"`
	OwnerId     int32  `sql:"owner_id"`
	TeamId      int    `sql:"team_id"`
	Deleted     bool   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type SlackNotificationRepository 

type SlackNotificationRepository interface {
	FindOne(id int) (*SlackConfig, error)
	UpdateSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
	SaveSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
	FindAll() ([]SlackConfig, error)
	FindByIdsIn(ids []int) ([]*SlackConfig, error)
	FindByTeamIdOrOwnerId(ownerId int32, teamIds []int) ([]SlackConfig, error)
	FindByName(value string) ([]SlackConfig, error)
	FindByIds(ids []*int) ([]*SlackConfig, error)
	MarkSlackConfigDeleted(slackConfig *SlackConfig) error
}

type SlackNotificationRepositoryImpl 

type SlackNotificationRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewSlackNotificationRepositoryImpl 

func NewSlackNotificationRepositoryImpl(dbConnection *pg.DB) *SlackNotificationRepositoryImpl

func (*SlackNotificationRepositoryImpl) FindAll 

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

func (*SlackNotificationRepositoryImpl) FindByIds 

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

func (*SlackNotificationRepositoryImpl) FindByIdsIn 

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

func (*SlackNotificationRepositoryImpl) FindByName 

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

func (*SlackNotificationRepositoryImpl) FindByTeamIdOrOwnerId 

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

func (*SlackNotificationRepositoryImpl) FindOne 

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

func (*SlackNotificationRepositoryImpl) MarkSlackConfigDeleted added in v0.3.15 

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

func (*SlackNotificationRepositoryImpl) SaveSlackConfig 

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

func (*SlackNotificationRepositoryImpl) UpdateSlackConfig 

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

type TerminalAccessRepository added in v0.6.10 

type TerminalAccessRepository interface {
	FetchTerminalAccessTemplate(templateName string) (*models.TerminalAccessTemplates, error)
	FetchAllTemplates() ([]*models.TerminalAccessTemplates, error)
	GetUserTerminalAccessData(id int) (*models.UserTerminalAccessData, error)
	GetAllRunningUserTerminalData() ([]*models.UserTerminalAccessData, error)
	SaveUserTerminalAccessData(data *models.UserTerminalAccessData) error
	UpdateUserTerminalAccessData(data *models.UserTerminalAccessData) error
	UpdateUserTerminalStatus(id int, status string) error
}

type TerminalAccessRepositoryImpl added in v0.6.10 

type TerminalAccessRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewTerminalAccessRepositoryImpl added in v0.6.10 

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

func (TerminalAccessRepositoryImpl) FetchAllTemplates added in v0.6.10 

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

func (TerminalAccessRepositoryImpl) FetchTerminalAccessTemplate added in v0.6.10 

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

func (TerminalAccessRepositoryImpl) GetAllRunningUserTerminalData added in v0.6.10 

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

func (TerminalAccessRepositoryImpl) GetUserTerminalAccessData added in v0.6.10 

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

func (TerminalAccessRepositoryImpl) SaveUserTerminalAccessData added in v0.6.10 

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

func (TerminalAccessRepositoryImpl) UpdateUserTerminalAccessData added in v0.6.10 

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

func (TerminalAccessRepositoryImpl) UpdateUserTerminalStatus added in v0.6.10 

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

type UserAttributes added in v0.5.3 

type UserAttributes struct {
	EmailId  string `sql:"email_id,pk"`
	UserData string `sql:"user_data,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type UserAttributesDao added in v0.5.3 

type UserAttributesDao struct {
	EmailId string `json:"emailId"`
	Key     string `json:"key"`
	Value   string `json:"value"`
	UserId  int32  `json:"-"`
}

type UserAttributesRepository added in v0.5.3 

type UserAttributesRepository interface {
	GetConnection() (dbConnection *pg.DB)
	AddUserAttribute(attrDto *UserAttributesDao) (*UserAttributesDao, error)
	UpdateDataValByKey(attrDto *UserAttributesDao) error
	GetDataValueByKey(attrDto *UserAttributesDao) (string, error)
	GetUserDataByEmailId(emailId string) (string, error)
}

type UserAttributesRepositoryImpl added in v0.5.3 

type UserAttributesRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewUserAttributesRepositoryImpl added in v0.5.3 

func NewUserAttributesRepositoryImpl(dbConnection *pg.DB) *UserAttributesRepositoryImpl

func (UserAttributesRepositoryImpl) AddUserAttribute added in v0.5.3 

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

func (*UserAttributesRepositoryImpl) GetConnection added in v0.5.3 

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

func (UserAttributesRepositoryImpl) GetDataValueByKey added in v0.5.3 

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

func (UserAttributesRepositoryImpl) GetUserDataByEmailId added in v0.6.7 

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

func (UserAttributesRepositoryImpl) UpdateDataValByKey added in v0.5.3 

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

type WebhookConfig added in v0.6.18 

type WebhookConfig struct {
	Id          int                    `sql:"id,pk"`
	WebHookUrl  string                 `sql:"web_hook_url"`
	ConfigName  string                 `sql:"config_name"`
	Header      map[string]interface{} `sql:"header"`
	Payload     string                 `sql:"payload"`
	Description string                 `sql:"description"`
	OwnerId     int32                  `sql:"owner_id"`
	Active      bool                   `sql:"active"`
	Deleted     bool                   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type WebhookData added in v0.2.22 

type WebhookData struct {
	Id              int
	EventActionType string
	Data            map[string]string
}

type WebhookEventData added in v0.2.22 

type WebhookEventData struct {
	Id          int       `sql:"id,pk"`
	GitHostId   int       `sql:"git_host_id,notnull"`
	EventType   string    `sql:"event_type,notnull"`
	PayloadJson string    `sql:"payload_json,notnull"`
	CreatedOn   time.Time `sql:"created_on,notnull"`
	// contains filtered or unexported fields
}

type WebhookEventDataRepository added in v0.2.22 

type WebhookEventDataRepository interface {
	Save(webhookEventData *WebhookEventData) error
	GetById(id int) (*WebhookEventData, error)
}

type WebhookEventDataRepositoryImpl added in v0.2.22 

type WebhookEventDataRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewWebhookEventDataRepositoryImpl added in v0.2.22 

func NewWebhookEventDataRepositoryImpl(dbConnection *pg.DB) *WebhookEventDataRepositoryImpl

func (WebhookEventDataRepositoryImpl) GetById added in v0.2.27 

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

func (WebhookEventDataRepositoryImpl) Save added in v0.2.22 

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

type WebhookNotificationRepository added in v0.6.18 

type WebhookNotificationRepository interface {
	FindOne(id int) (*WebhookConfig, error)
	UpdateWebhookConfig(webhookConfig *WebhookConfig) (*WebhookConfig, error)
	SaveWebhookConfig(webhookConfig *WebhookConfig) (*WebhookConfig, error)
	FindAll() ([]WebhookConfig, error)
	FindByName(value string) ([]WebhookConfig, error)
	FindByIds(ids []*int) ([]*WebhookConfig, error)
	MarkWebhookConfigDeleted(webhookConfig *WebhookConfig) error
}

type WebhookNotificationRepositoryImpl added in v0.6.18 

type WebhookNotificationRepositoryImpl struct {
	// contains filtered or unexported fields
}

func NewWebhookNotificationRepositoryImpl added in v0.6.18 

func NewWebhookNotificationRepositoryImpl(dbConnection *pg.DB) *WebhookNotificationRepositoryImpl

func (*WebhookNotificationRepositoryImpl) FindAll added in v0.6.18 

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

func (*WebhookNotificationRepositoryImpl) FindByIds added in v0.6.18 

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

func (*WebhookNotificationRepositoryImpl) FindByName added in v0.6.18 

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

func (*WebhookNotificationRepositoryImpl) FindOne added in v0.6.18 

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

func (*WebhookNotificationRepositoryImpl) MarkWebhookConfigDeleted added in v0.6.18 

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

func (*WebhookNotificationRepositoryImpl) SaveWebhookConfig added in v0.6.18 

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

func (*WebhookNotificationRepositoryImpl) UpdateWebhookConfig added in v0.6.18 

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

Source Files

View all Source files

Directories

Path Synopsis
app
mocks
mocks
mocks
mocks
mocks
bean
mocks
Package mock_pipelineConfig is a generated GoMock package.
 Package mock_pipelineConfig is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.