repository

package
v0.5.3 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2022 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CdStageType 

type CdStageType string
const (
	PRE_CD_TYPE  CdStageType = "PRE_CD"
	POST_CD_TYPE CdStageType = "POST_CD"
)

type ConfigMapHistoryRepository 

type ConfigMapHistoryRepository interface {
	CreateHistory(model *ConfigmapAndSecretHistory) (*ConfigmapAndSecretHistory, error)
	GetHistoryForDeployedCMCSById(id, pipelineId int, configType ConfigType) (*ConfigmapAndSecretHistory, error)
	GetDeploymentDetailsForDeployedCMCSHistory(pipelineId int, configType ConfigType) ([]*ConfigmapAndSecretHistory, error)
	GetHistoryByPipelineIdAndWfrId(pipelineId, wfrId int, configType ConfigType) (*ConfigmapAndSecretHistory, error)
	GetDeployedHistoryList(pipelineId, baseConfigId int, configType ConfigType, componentName string) ([]*ConfigmapAndSecretHistory, error)
}

type ConfigMapHistoryRepositoryImpl 

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

func NewConfigMapHistoryRepositoryImpl 

func NewConfigMapHistoryRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *ConfigMapHistoryRepositoryImpl

func (ConfigMapHistoryRepositoryImpl) CreateHistory 

func (impl ConfigMapHistoryRepositoryImpl) CreateHistory(model *ConfigmapAndSecretHistory) (*ConfigmapAndSecretHistory, error)

func (ConfigMapHistoryRepositoryImpl) GetDeployedHistoryList added in v0.4.4 

func (impl ConfigMapHistoryRepositoryImpl) GetDeployedHistoryList(pipelineId, baseConfigId int, configType ConfigType, componentName string) ([]*ConfigmapAndSecretHistory, error)

func (ConfigMapHistoryRepositoryImpl) GetDeploymentDetailsForDeployedCMCSHistory 

func (impl ConfigMapHistoryRepositoryImpl) GetDeploymentDetailsForDeployedCMCSHistory(pipelineId int, configType ConfigType) ([]*ConfigmapAndSecretHistory, error)

func (ConfigMapHistoryRepositoryImpl) GetHistoryByPipelineIdAndWfrId added in v0.4.4 

func (impl ConfigMapHistoryRepositoryImpl) GetHistoryByPipelineIdAndWfrId(pipelineId, wfrId int, configType ConfigType) (*ConfigmapAndSecretHistory, error)

func (ConfigMapHistoryRepositoryImpl) GetHistoryForDeployedCMCSById 

func (impl ConfigMapHistoryRepositoryImpl) GetHistoryForDeployedCMCSById(id, pipelineId int, configType ConfigType) (*ConfigmapAndSecretHistory, error)

type ConfigType 

type ConfigType string
const (
	CONFIGMAP_TYPE ConfigType = "CONFIGMAP"
	SECRET_TYPE    ConfigType = "SECRET"
)

type ConfigmapAndSecretHistory 

type ConfigmapAndSecretHistory struct {
	TableName  struct{}   `sql:"config_map_history" pg:",discard_unknown_columns"`
	Id         int        `sql:"id,pk"`
	PipelineId int        `sql:"pipeline_id"`
	AppId      int        `sql:"app_id"`
	DataType   ConfigType `sql:"data_type"`
	Data       string     `sql:"data"`
	Deployed   bool       `sql:"deployed"`
	DeployedOn time.Time  `sql:"deployed_on"`
	DeployedBy int32      `sql:"deployed_by"`
	sql.AuditLog
	//getting below data from cd_workflow_runner join
	DeploymentStatus  string `sql:"-"`
	DeployedByEmailId string `sql:"-"`
}

type DeploymentTemplateHistory 

type DeploymentTemplateHistory struct {
	Id                      int       `sql:"id,pk"`
	PipelineId              int       `sql:"pipeline_id"`
	AppId                   int       `sql:"app_id"`
	ImageDescriptorTemplate string    `sql:"image_descriptor_template"`
	Template                string    `sql:"template"`
	TargetEnvironment       int       `sql:"target_environment"`
	TemplateName            string    `sql:"template_name"`
	TemplateVersion         string    `sql:"template_version"`
	IsAppMetricsEnabled     bool      `sql:"is_app_metrics_enabled,notnull"`
	Deployed                bool      `sql:"deployed"`
	DeployedOn              time.Time `sql:"deployed_on"`
	DeployedBy              int32     `sql:"deployed_by"`
	sql.AuditLog
	//getting below data from cd_workflow_runner and users join
	DeploymentStatus  string `sql:"-"`
	DeployedByEmailId string `sql:"-"`
	// contains filtered or unexported fields
}

type DeploymentTemplateHistoryRepository 

type DeploymentTemplateHistoryRepository interface {
	CreateHistory(chart *DeploymentTemplateHistory) (*DeploymentTemplateHistory, error)
	CreateHistoryWithTxn(chart *DeploymentTemplateHistory, tx *pg.Tx) (*DeploymentTemplateHistory, error)
	GetHistoryForDeployedTemplateById(id, pipelineId int) (*DeploymentTemplateHistory, error)
	GetDeploymentDetailsForDeployedTemplateHistory(pipelineId, offset, limit int) ([]*DeploymentTemplateHistory, error)
	GetHistoryByPipelineIdAndWfrId(pipelineId, wfrId int) (*DeploymentTemplateHistory, error)
	GetDeployedHistoryList(pipelineId, baseConfigId int) ([]*DeploymentTemplateHistory, error)
}

type DeploymentTemplateHistoryRepositoryImpl 

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

func NewDeploymentTemplateHistoryRepositoryImpl 

func NewDeploymentTemplateHistoryRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *DeploymentTemplateHistoryRepositoryImpl

func (DeploymentTemplateHistoryRepositoryImpl) CreateHistory 

func (impl DeploymentTemplateHistoryRepositoryImpl) CreateHistory(chart *DeploymentTemplateHistory) (*DeploymentTemplateHistory, error)

func (DeploymentTemplateHistoryRepositoryImpl) CreateHistoryWithTxn 

func (impl DeploymentTemplateHistoryRepositoryImpl) CreateHistoryWithTxn(chart *DeploymentTemplateHistory, tx *pg.Tx) (*DeploymentTemplateHistory, error)

func (DeploymentTemplateHistoryRepositoryImpl) GetDeployedHistoryList added in v0.4.4 

func (impl DeploymentTemplateHistoryRepositoryImpl) GetDeployedHistoryList(pipelineId, baseConfigId int) ([]*DeploymentTemplateHistory, error)

func (DeploymentTemplateHistoryRepositoryImpl) GetDeploymentDetailsForDeployedTemplateHistory 

func (impl DeploymentTemplateHistoryRepositoryImpl) GetDeploymentDetailsForDeployedTemplateHistory(pipelineId, offset, limit int) ([]*DeploymentTemplateHistory, error)

func (DeploymentTemplateHistoryRepositoryImpl) GetHistoryByPipelineIdAndWfrId added in v0.4.4 

func (impl DeploymentTemplateHistoryRepositoryImpl) GetHistoryByPipelineIdAndWfrId(pipelineId, wfrId int) (*DeploymentTemplateHistory, error)

func (DeploymentTemplateHistoryRepositoryImpl) GetHistoryForDeployedTemplateById 

func (impl DeploymentTemplateHistoryRepositoryImpl) GetHistoryForDeployedTemplateById(id, pipelineId int) (*DeploymentTemplateHistory, error)

type PipelineStrategyHistory 

type PipelineStrategyHistory struct {
	TableName           struct{}                          `sql:"pipeline_strategy_history" pg:",discard_unknown_columns"`
	Id                  int                               `sql:"id,pk"`
	PipelineId          int                               `sql:"pipeline_id, notnull"`
	Strategy            pipelineConfig.DeploymentTemplate `sql:"strategy,notnull"`
	Config              string                            `sql:"config"`
	Default             bool                              `sql:"default,notnull"`
	Deployed            bool                              `sql:"deployed"`
	DeployedOn          time.Time                         `sql:"deployed_on"`
	DeployedBy          int32                             `sql:"deployed_by"`
	PipelineTriggerType pipelineConfig.TriggerType        `sql:"pipeline_trigger_type"`
	sql.AuditLog
	//getting below data from cd_workflow_runner and users join
	DeploymentStatus  string `sql:"-"`
	DeployedByEmailId string `sql:"-"`
}

type PipelineStrategyHistoryRepository 

type PipelineStrategyHistoryRepository interface {
	CreateHistory(model *PipelineStrategyHistory) (*PipelineStrategyHistory, error)
	CreateHistoryWithTxn(model *PipelineStrategyHistory, tx *pg.Tx) (*PipelineStrategyHistory, error)
	GetHistoryForDeployedStrategyById(id, pipelineId int) (*PipelineStrategyHistory, error)
	GetDeploymentDetailsForDeployedStrategyHistory(pipelineId int) ([]*PipelineStrategyHistory, error)
	GetHistoryByPipelineIdAndWfrId(pipelineId, wfrId int) (*PipelineStrategyHistory, error)
	GetDeployedHistoryList(pipelineId, baseConfigId int) ([]*PipelineStrategyHistory, error)
}

type PipelineStrategyHistoryRepositoryImpl 

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

func NewPipelineStrategyHistoryRepositoryImpl 

func NewPipelineStrategyHistoryRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *PipelineStrategyHistoryRepositoryImpl

func (PipelineStrategyHistoryRepositoryImpl) CreateHistory 

func (impl PipelineStrategyHistoryRepositoryImpl) CreateHistory(model *PipelineStrategyHistory) (*PipelineStrategyHistory, error)

func (PipelineStrategyHistoryRepositoryImpl) CreateHistoryWithTxn 

func (impl PipelineStrategyHistoryRepositoryImpl) CreateHistoryWithTxn(model *PipelineStrategyHistory, tx *pg.Tx) (*PipelineStrategyHistory, error)

func (PipelineStrategyHistoryRepositoryImpl) GetDeployedHistoryList added in v0.4.4 

func (impl PipelineStrategyHistoryRepositoryImpl) GetDeployedHistoryList(pipelineId, baseConfigId int) ([]*PipelineStrategyHistory, error)

func (PipelineStrategyHistoryRepositoryImpl) GetDeploymentDetailsForDeployedStrategyHistory 

func (impl PipelineStrategyHistoryRepositoryImpl) GetDeploymentDetailsForDeployedStrategyHistory(pipelineId int) ([]*PipelineStrategyHistory, error)

func (PipelineStrategyHistoryRepositoryImpl) GetHistoryByPipelineIdAndWfrId added in v0.4.4 

func (impl PipelineStrategyHistoryRepositoryImpl) GetHistoryByPipelineIdAndWfrId(pipelineId, wfrId int) (*PipelineStrategyHistory, error)

func (PipelineStrategyHistoryRepositoryImpl) GetHistoryForDeployedStrategyById 

func (impl PipelineStrategyHistoryRepositoryImpl) GetHistoryForDeployedStrategyById(id, pipelineId int) (*PipelineStrategyHistory, error)

type PrePostCdScriptHistory 

type PrePostCdScriptHistory struct {
	Id                   int                        `sql:"id,pk"`
	PipelineId           int                        `sql:"pipeline_id, notnull"`
	Script               string                     `sql:"script"`
	Stage                CdStageType                `sql:"stage"`
	TriggerType          pipelineConfig.TriggerType `sql:"trigger_type"`
	ConfigMapSecretNames string                     `sql:"configmap_secret_names"`
	ConfigMapData        string                     `sql:"configmap_data"`
	SecretData           string                     `sql:"secret_data"`
	ExecInEnv            bool                       `sql:"exec_in_env,notnull"`
	Deployed             bool                       `sql:"deployed"`
	DeployedOn           time.Time                  `sql:"deployed_on"`
	DeployedBy           int32                      `sql:"deployed_by"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PrePostCdScriptHistoryRepository 

type PrePostCdScriptHistoryRepository interface {
	CreateHistoryWithTxn(history *PrePostCdScriptHistory, tx *pg.Tx) (*PrePostCdScriptHistory, error)
	CreateHistory(history *PrePostCdScriptHistory) (*PrePostCdScriptHistory, error)
	GetHistoryForDeployedPrePostScriptByStage(pipelineId int, stage CdStageType) ([]*PrePostCdScriptHistory, error)
}

type PrePostCdScriptHistoryRepositoryImpl 

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

func NewPrePostCdScriptHistoryRepositoryImpl 

func NewPrePostCdScriptHistoryRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *PrePostCdScriptHistoryRepositoryImpl

func (PrePostCdScriptHistoryRepositoryImpl) CreateHistory 

func (impl PrePostCdScriptHistoryRepositoryImpl) CreateHistory(history *PrePostCdScriptHistory) (*PrePostCdScriptHistory, error)

func (PrePostCdScriptHistoryRepositoryImpl) CreateHistoryWithTxn 

func (impl PrePostCdScriptHistoryRepositoryImpl) CreateHistoryWithTxn(history *PrePostCdScriptHistory, tx *pg.Tx) (*PrePostCdScriptHistory, error)

func (PrePostCdScriptHistoryRepositoryImpl) GetHistoryForDeployedPrePostScriptByStage 

func (impl PrePostCdScriptHistoryRepositoryImpl) GetHistoryForDeployedPrePostScriptByStage(pipelineId int, stage CdStageType) ([]*PrePostCdScriptHistory, error)

type PrePostCiScriptHistory 

type PrePostCiScriptHistory struct {
	Id                  int       `sql:"id,pk"`
	CiPipelineScriptsId int       `sql:"ci_pipeline_scripts_id, notnull"`
	Script              string    `sql:"script"`
	Stage               string    `sql:"stage"`
	Name                string    `sql:"name"`
	OutputLocation      string    `sql:"output_location"`
	Built               bool      `sql:"built"`
	BuiltOn             time.Time `sql:"built_on"`
	BuiltBy             int32     `sql:"built_by"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PrePostCiScriptHistoryRepository 

type PrePostCiScriptHistoryRepository interface {
	CreateHistoryWithTxn(history *PrePostCiScriptHistory, tx *pg.Tx) (*PrePostCiScriptHistory, error)
	CreateHistory(history *PrePostCiScriptHistory) (*PrePostCiScriptHistory, error)
}

type PrePostCiScriptHistoryRepositoryImpl 

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

func NewPrePostCiScriptHistoryRepositoryImpl 

func NewPrePostCiScriptHistoryRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *PrePostCiScriptHistoryRepositoryImpl

func (PrePostCiScriptHistoryRepositoryImpl) CreateHistory 

func (impl PrePostCiScriptHistoryRepositoryImpl) CreateHistory(history *PrePostCiScriptHistory) (*PrePostCiScriptHistory, error)

func (PrePostCiScriptHistoryRepositoryImpl) CreateHistoryWithTxn 

func (impl PrePostCiScriptHistoryRepositoryImpl) CreateHistoryWithTxn(history *PrePostCiScriptHistory, tx *pg.Tx) (*PrePostCiScriptHistory, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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