Documentation ¶
Index ¶
- Constants
- type ManifestPushConfig
- type ManifestPushConfigRepository
- type ManifestPushConfigRepositoryImpl
- type PipelineStage
- type PipelineStageRepository
- type PipelineStageRepositoryImpl
- func (impl *PipelineStageRepositoryImpl) CheckIfCommandArgMappingExists(command string, arg string, scriptId int) (bool, error)
- func (impl *PipelineStageRepositoryImpl) CheckIfFilePathMappingExists(filePathOnDisk string, filePathOnContainer string, scriptId int) (bool, error)
- func (impl *PipelineStageRepositoryImpl) CheckIfPortMappingExists(portOnLocal int, portOnContainer int, scriptId int) (bool, error)
- func (impl *PipelineStageRepositoryImpl) CheckPluginExistsInCiPipeline(pipelineId int, stageType string, pluginId int) (bool, error)
- func (impl *PipelineStageRepositoryImpl) CreatePipelineScript(pipelineScript *PluginPipelineScript, tx *pg.Tx) (*PluginPipelineScript, error)
- func (impl *PipelineStageRepositoryImpl) CreatePipelineStage(pipelineStage *PipelineStage, tx *pg.Tx) (*PipelineStage, error)
- func (impl *PipelineStageRepositoryImpl) CreatePipelineStageStep(step *PipelineStageStep, tx *pg.Tx) (*PipelineStageStep, error)
- func (impl *PipelineStageRepositoryImpl) CreatePipelineStageStepConditions(conditions []PipelineStageStepCondition, tx *pg.Tx) ([]PipelineStageStepCondition, error)
- func (impl *PipelineStageRepositoryImpl) CreatePipelineStageStepVariables(variables []PipelineStageStepVariable, tx *pg.Tx) ([]PipelineStageStepVariable, error)
- func (impl *PipelineStageRepositoryImpl) CreateScriptMapping(mappings []ScriptPathArgPortMapping, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) GetActiveStepsByRefPluginId(refPluginId int) ([]*PipelineStageStep, error)
- func (impl *PipelineStageRepositoryImpl) GetAllCdStagesByCdPipelineId(cdPipelineId int) ([]*PipelineStage, error)
- func (impl *PipelineStageRepositoryImpl) GetAllCdStagesByCdPipelineIds(cdPipelineIds []int) ([]*PipelineStage, error)
- func (impl *PipelineStageRepositoryImpl) GetAllCiPipelineIdsByPluginIdAndStageType(pluginId int, stageType string) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetAllCiStagesByCiPipelineId(ciPipelineId int) ([]*PipelineStage, error)
- func (impl *PipelineStageRepositoryImpl) GetAllStepsByStageId(stageId int) ([]*PipelineStageStep, error)
- func (impl *PipelineStageRepositoryImpl) GetCdStageByCdPipelineIdAndStageType(cdPipelineId int, stageType PipelineStageType) (*PipelineStage, error)
- func (impl *PipelineStageRepositoryImpl) GetCiStageByCiPipelineIdAndStageType(ciPipelineId int, stageType PipelineStageType) (*PipelineStage, error)
- func (impl *PipelineStageRepositoryImpl) GetConditionIdsByStageId(stageId int) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetConditionIdsByStepId(stepId int) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetConditionsByStepId(stepId int) ([]*PipelineStageStepCondition, error)
- func (impl *PipelineStageRepositoryImpl) GetConditionsByVariableId(variableId int) ([]*PipelineStageStepCondition, error)
- func (impl *PipelineStageRepositoryImpl) GetConnection() *pg.DB
- func (impl *PipelineStageRepositoryImpl) GetScriptDetailById(id int) (*PluginPipelineScript, error)
- func (impl *PipelineStageRepositoryImpl) GetScriptIdsByStageId(stageId int) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetScriptMappingDetailByScriptId(scriptId int) ([]*ScriptPathArgPortMapping, error)
- func (impl *PipelineStageRepositoryImpl) GetScriptMappingIdsByStageId(stageId int) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetStepById(stepId int) (*PipelineStageStep, error)
- func (impl *PipelineStageRepositoryImpl) GetStepIdsByStageId(stageId int) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetVariableIdsByStageId(stageId int) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetVariableIdsByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType) ([]int, error)
- func (impl *PipelineStageRepositoryImpl) GetVariablesByStepId(stepId int) ([]*PipelineStageStepVariable, error)
- func (impl *PipelineStageRepositoryImpl) MarkConditionsDeletedByStepId(stepId int, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkConditionsDeletedExcludingActiveVariablesInUpdateReq(activeConditionIdsPresentInReq []int, stepId int, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkPipelineScriptMappingsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkPipelineScriptsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkPipelineStageDeletedById(stageId int, updatedBy int32, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkPipelineStageStepConditionDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkPipelineStageStepVariablesDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkPipelineStageStepsDeletedByStageId(stageId int, updatedBy int32, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkScriptDeletedById(scriptId int) error
- func (impl *PipelineStageRepositoryImpl) MarkScriptMappingDeletedByScriptId(scriptId int) error
- func (impl *PipelineStageRepositoryImpl) MarkStepsDeletedByStageId(stageId int) error
- func (impl *PipelineStageRepositoryImpl) MarkStepsDeletedExcludingActiveStepsInUpdateReq(activeStepIdsPresentInReq []int, stageId int) error
- func (impl *PipelineStageRepositoryImpl) MarkVariablesDeletedByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType, tx *pg.Tx) error
- func (impl *PipelineStageRepositoryImpl) MarkVariablesDeletedExcludingActiveVariablesInUpdateReq(activeVariableIdsPresentInReq []int, stepId int, ...) error
- func (impl *PipelineStageRepositoryImpl) UpdatePipelineScript(pipelineScript *PluginPipelineScript) (*PluginPipelineScript, error)
- func (impl *PipelineStageRepositoryImpl) UpdatePipelineStage(pipelineStage *PipelineStage) (*PipelineStage, error)
- func (impl *PipelineStageRepositoryImpl) UpdatePipelineStageStep(step *PipelineStageStep) (*PipelineStageStep, error)
- func (impl *PipelineStageRepositoryImpl) UpdatePipelineStageStepConditions(conditions []PipelineStageStepCondition, tx *pg.Tx) ([]PipelineStageStepCondition, error)
- func (impl *PipelineStageRepositoryImpl) UpdatePipelineStageStepVariables(variables []PipelineStageStepVariable, tx *pg.Tx) ([]PipelineStageStepVariable, error)
- func (impl *PipelineStageRepositoryImpl) UpdateScriptMapping(mappings []*ScriptPathArgPortMapping, tx *pg.Tx) error
- type PipelineStageStep
- type PipelineStageStepCondition
- type PipelineStageStepConditionType
- type PipelineStageStepVariable
- type PipelineStageStepVariableFormatType
- type PipelineStageStepVariableType
- type PipelineStageStepVariableValueType
- type PipelineStageType
- type PipelineStepType
- type PluginPipelineScript
- type ScriptPathArgPortMapping
Constants ¶
View Source
const ( PIPELINE_STAGE_TYPE_PRE_CI PipelineStageType = "PRE_CI" PIPELINE_STAGE_TYPE_POST_CI PipelineStageType = "POST_CI" PIPELINE_STAGE_TYPE_PRE_CD PipelineStageType = "PRE_CD" PIPELINE_STAGE_TYPE_POST_CD PipelineStageType = "POST_CD" PIPELINE_STEP_TYPE_INLINE PipelineStepType = "INLINE" PIPELINE_STEP_TYPE_REF_PLUGIN PipelineStepType = "REF_PLUGIN" PIPELINE_STAGE_STEP_VARIABLE_TYPE_INPUT PipelineStageStepVariableType = "INPUT" PIPELINE_STAGE_STEP_VARIABLE_TYPE_OUTPUT PipelineStageStepVariableType = "OUTPUT" PIPELINE_STAGE_STEP_VARIABLE_VALUE_TYPE_NEW PipelineStageStepVariableValueType = "NEW" PIPELINE_STAGE_STEP_VARIABLE_VALUE_TYPE_PREVIOUS PipelineStageStepVariableValueType = "FROM_PREVIOUS_STEP" PIPELINE_STAGE_STEP_VARIABLE_VALUE_TYPE_GLOBAL PipelineStageStepVariableValueType = "GLOBAL" PIPELINE_STAGE_STEP_CONDITION_TYPE_SKIP PipelineStageStepConditionType = "SKIP" PIPELINE_STAGE_STEP_CONDITION_TYPE_TRIGGER PipelineStageStepConditionType = "TRIGGER" PIPELINE_STAGE_STEP_CONDITION_TYPE_SUCCESS PipelineStageStepConditionType = "PASS" PIPELINE_STAGE_STEP_CONDITION_TYPE_FAIL PipelineStageStepConditionType = "FAIL" PIPELINE_STAGE_STEP_VARIABLE_FORMAT_TYPE_STRING PipelineStageStepVariableFormatType = "STRING" PIPELINE_STAGE_STEP_VARIABLE_FORMAT_TYPE_NUMBER PipelineStageStepVariableFormatType = "NUMBER" PIPELINE_STAGE_STEP_VARIABLE_FORMAT_TYPE_BOOL PipelineStageStepVariableFormatType = "BOOL" PIPELINE_STAGE_STEP_VARIABLE_FORMAT_TYPE_DATE PipelineStageStepVariableFormatType = "DATE" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ManifestPushConfig ¶ added in v0.6.19
type ManifestPushConfig struct { Id int `sql:"id,pk"` AppId int `sql:"app_id"` EnvId int `sql:"env_id"` CredentialsConfig string `sql:"credentials_config"` ChartName string `sql:"chart_name"` ChartBaseVersion string `sql:"chart_base_version"` StorageType string `sql:"storage_type"` Deleted bool `sql:"deleted, notnull"` sql.AuditLog // contains filtered or unexported fields }
type ManifestPushConfigRepository ¶ added in v0.6.19
type ManifestPushConfigRepository interface { SaveConfig(manifestPushConfig *ManifestPushConfig) (*ManifestPushConfig, error) GetManifestPushConfigByAppIdAndEnvId(appId, envId int) (*ManifestPushConfig, error) }
type ManifestPushConfigRepositoryImpl ¶ added in v0.6.19
type ManifestPushConfigRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewManifestPushConfigRepository ¶ added in v0.6.19
func NewManifestPushConfigRepository(logger *zap.SugaredLogger, dbConnection *pg.DB, ) *ManifestPushConfigRepositoryImpl
func (ManifestPushConfigRepositoryImpl) GetManifestPushConfigByAppIdAndEnvId ¶ added in v0.6.19
func (impl ManifestPushConfigRepositoryImpl) GetManifestPushConfigByAppIdAndEnvId(appId, envId int) (*ManifestPushConfig, error)
func (ManifestPushConfigRepositoryImpl) SaveConfig ¶ added in v0.6.19
func (impl ManifestPushConfigRepositoryImpl) SaveConfig(manifestPushConfig *ManifestPushConfig) (*ManifestPushConfig, error)
type PipelineStage ¶
type PipelineStage struct { Id int `sql:"id,pk"` Name string `sql:"name"` Description string `sql:"description"` Type PipelineStageType `sql:"type"` Deleted bool `sql:"deleted, notnull"` CiPipelineId int `sql:"ci_pipeline_id"` CdPipelineId int `sql:"cd_pipeline_id"` sql.AuditLog // contains filtered or unexported fields }
type PipelineStageRepository ¶
type PipelineStageRepository interface { GetConnection() *pg.DB CreatePipelineStage(pipelineStage *PipelineStage, tx *pg.Tx) (*PipelineStage, error) UpdatePipelineStage(pipelineStage *PipelineStage) (*PipelineStage, error) MarkPipelineStageDeletedById(stageId int, updatedBy int32, tx *pg.Tx) error GetAllCiStagesByCiPipelineId(ciPipelineId int) ([]*PipelineStage, error) GetAllCdStagesByCdPipelineId(cdPipelineId int) ([]*PipelineStage, error) GetAllCdStagesByCdPipelineIds(cdPipelineIds []int) ([]*PipelineStage, error) GetCiStageByCiPipelineIdAndStageType(ciPipelineId int, stageType PipelineStageType) (*PipelineStage, error) GetCdStageByCdPipelineIdAndStageType(cdPipelineId int, stageType PipelineStageType) (*PipelineStage, error) GetStepIdsByStageId(stageId int) ([]int, error) CreatePipelineStageStep(step *PipelineStageStep, tx *pg.Tx) (*PipelineStageStep, error) UpdatePipelineStageStep(step *PipelineStageStep) (*PipelineStageStep, error) MarkPipelineStageStepsDeletedByStageId(stageId int, updatedBy int32, tx *pg.Tx) error GetAllStepsByStageId(stageId int) ([]*PipelineStageStep, error) GetAllCiPipelineIdsByPluginIdAndStageType(pluginId int, stageType string) ([]int, error) CheckPluginExistsInCiPipeline(pipelineId int, stageType string, pluginId int) (bool, error) GetStepById(stepId int) (*PipelineStageStep, error) MarkStepsDeletedByStageId(stageId int) error MarkStepsDeletedExcludingActiveStepsInUpdateReq(activeStepIdsPresentInReq []int, stageId int) error GetActiveStepsByRefPluginId(refPluginId int) ([]*PipelineStageStep, error) CreatePipelineScript(pipelineScript *PluginPipelineScript, tx *pg.Tx) (*PluginPipelineScript, error) UpdatePipelineScript(pipelineScript *PluginPipelineScript) (*PluginPipelineScript, error) GetScriptIdsByStageId(stageId int) ([]int, error) MarkPipelineScriptsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error GetScriptDetailById(id int) (*PluginPipelineScript, error) MarkScriptDeletedById(scriptId int) error MarkScriptMappingDeletedByScriptId(scriptId int) error CreateScriptMapping(mappings []ScriptPathArgPortMapping, tx *pg.Tx) error UpdateScriptMapping(mappings []*ScriptPathArgPortMapping, tx *pg.Tx) error GetScriptMappingIdsByStageId(stageId int) ([]int, error) MarkPipelineScriptMappingsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error GetScriptMappingDetailByScriptId(scriptId int) ([]*ScriptPathArgPortMapping, error) CheckIfFilePathMappingExists(filePathOnDisk string, filePathOnContainer string, scriptId int) (bool, error) CheckIfCommandArgMappingExists(command string, arg string, scriptId int) (bool, error) CheckIfPortMappingExists(portOnLocal int, portOnContainer int, scriptId int) (bool, error) CreatePipelineStageStepVariables([]PipelineStageStepVariable, *pg.Tx) ([]PipelineStageStepVariable, error) UpdatePipelineStageStepVariables(variables []PipelineStageStepVariable, tx *pg.Tx) ([]PipelineStageStepVariable, error) GetVariableIdsByStageId(stageId int) ([]int, error) MarkPipelineStageStepVariablesDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error GetVariablesByStepId(stepId int) ([]*PipelineStageStepVariable, error) GetVariableIdsByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType) ([]int, error) MarkVariablesDeletedByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType, tx *pg.Tx) error MarkVariablesDeletedExcludingActiveVariablesInUpdateReq(activeVariableIdsPresentInReq []int, stepId int, variableType PipelineStageStepVariableType, tx *pg.Tx) error CreatePipelineStageStepConditions([]PipelineStageStepCondition, *pg.Tx) ([]PipelineStageStepCondition, error) UpdatePipelineStageStepConditions(conditions []PipelineStageStepCondition, tx *pg.Tx) ([]PipelineStageStepCondition, error) GetConditionIdsByStageId(stageId int) ([]int, error) MarkPipelineStageStepConditionDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error GetConditionsByStepId(stepId int) ([]*PipelineStageStepCondition, error) GetConditionsByVariableId(variableId int) ([]*PipelineStageStepCondition, error) GetConditionIdsByStepId(stepId int) ([]int, error) MarkConditionsDeletedByStepId(stepId int, tx *pg.Tx) error MarkConditionsDeletedExcludingActiveVariablesInUpdateReq(activeConditionIdsPresentInReq []int, stepId int, tx *pg.Tx) error }
type PipelineStageRepositoryImpl ¶
type PipelineStageRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewPipelineStageRepository ¶
func NewPipelineStageRepository(logger *zap.SugaredLogger, dbConnection *pg.DB) *PipelineStageRepositoryImpl
func (*PipelineStageRepositoryImpl) CheckIfCommandArgMappingExists ¶
func (*PipelineStageRepositoryImpl) CheckIfFilePathMappingExists ¶
func (*PipelineStageRepositoryImpl) CheckIfPortMappingExists ¶
func (*PipelineStageRepositoryImpl) CheckPluginExistsInCiPipeline ¶ added in v0.6.26
func (*PipelineStageRepositoryImpl) CreatePipelineScript ¶
func (impl *PipelineStageRepositoryImpl) CreatePipelineScript(pipelineScript *PluginPipelineScript, tx *pg.Tx) (*PluginPipelineScript, error)
func (*PipelineStageRepositoryImpl) CreatePipelineStage ¶ added in v0.6.21
func (impl *PipelineStageRepositoryImpl) CreatePipelineStage(pipelineStage *PipelineStage, tx *pg.Tx) (*PipelineStage, error)
func (*PipelineStageRepositoryImpl) CreatePipelineStageStep ¶
func (impl *PipelineStageRepositoryImpl) CreatePipelineStageStep(step *PipelineStageStep, tx *pg.Tx) (*PipelineStageStep, error)
func (*PipelineStageRepositoryImpl) CreatePipelineStageStepConditions ¶
func (impl *PipelineStageRepositoryImpl) CreatePipelineStageStepConditions(conditions []PipelineStageStepCondition, tx *pg.Tx) ([]PipelineStageStepCondition, error)
func (*PipelineStageRepositoryImpl) CreatePipelineStageStepVariables ¶
func (impl *PipelineStageRepositoryImpl) CreatePipelineStageStepVariables(variables []PipelineStageStepVariable, tx *pg.Tx) ([]PipelineStageStepVariable, error)
func (*PipelineStageRepositoryImpl) CreateScriptMapping ¶
func (impl *PipelineStageRepositoryImpl) CreateScriptMapping(mappings []ScriptPathArgPortMapping, tx *pg.Tx) error
func (*PipelineStageRepositoryImpl) GetActiveStepsByRefPluginId ¶ added in v0.6.26
func (impl *PipelineStageRepositoryImpl) GetActiveStepsByRefPluginId(refPluginId int) ([]*PipelineStageStep, error)
func (*PipelineStageRepositoryImpl) GetAllCdStagesByCdPipelineId ¶ added in v0.6.21
func (impl *PipelineStageRepositoryImpl) GetAllCdStagesByCdPipelineId(cdPipelineId int) ([]*PipelineStage, error)
func (*PipelineStageRepositoryImpl) GetAllCdStagesByCdPipelineIds ¶ added in v0.6.21
func (impl *PipelineStageRepositoryImpl) GetAllCdStagesByCdPipelineIds(cdPipelineIds []int) ([]*PipelineStage, error)
func (*PipelineStageRepositoryImpl) GetAllCiPipelineIdsByPluginIdAndStageType ¶ added in v0.6.24
func (impl *PipelineStageRepositoryImpl) GetAllCiPipelineIdsByPluginIdAndStageType(pluginId int, stageType string) ([]int, error)
func (*PipelineStageRepositoryImpl) GetAllCiStagesByCiPipelineId ¶
func (impl *PipelineStageRepositoryImpl) GetAllCiStagesByCiPipelineId(ciPipelineId int) ([]*PipelineStage, error)
func (*PipelineStageRepositoryImpl) GetAllStepsByStageId ¶
func (impl *PipelineStageRepositoryImpl) GetAllStepsByStageId(stageId int) ([]*PipelineStageStep, error)
func (*PipelineStageRepositoryImpl) GetCdStageByCdPipelineIdAndStageType ¶ added in v0.6.21
func (impl *PipelineStageRepositoryImpl) GetCdStageByCdPipelineIdAndStageType(cdPipelineId int, stageType PipelineStageType) (*PipelineStage, error)
func (*PipelineStageRepositoryImpl) GetCiStageByCiPipelineIdAndStageType ¶
func (impl *PipelineStageRepositoryImpl) GetCiStageByCiPipelineIdAndStageType(ciPipelineId int, stageType PipelineStageType) (*PipelineStage, error)
func (*PipelineStageRepositoryImpl) GetConditionIdsByStageId ¶
func (impl *PipelineStageRepositoryImpl) GetConditionIdsByStageId(stageId int) ([]int, error)
func (*PipelineStageRepositoryImpl) GetConditionIdsByStepId ¶
func (impl *PipelineStageRepositoryImpl) GetConditionIdsByStepId(stepId int) ([]int, error)
func (*PipelineStageRepositoryImpl) GetConditionsByStepId ¶
func (impl *PipelineStageRepositoryImpl) GetConditionsByStepId(stepId int) ([]*PipelineStageStepCondition, error)
func (*PipelineStageRepositoryImpl) GetConditionsByVariableId ¶
func (impl *PipelineStageRepositoryImpl) GetConditionsByVariableId(variableId int) ([]*PipelineStageStepCondition, error)
func (*PipelineStageRepositoryImpl) GetConnection ¶
func (impl *PipelineStageRepositoryImpl) GetConnection() *pg.DB
func (*PipelineStageRepositoryImpl) GetScriptDetailById ¶
func (impl *PipelineStageRepositoryImpl) GetScriptDetailById(id int) (*PluginPipelineScript, error)
func (*PipelineStageRepositoryImpl) GetScriptIdsByStageId ¶
func (impl *PipelineStageRepositoryImpl) GetScriptIdsByStageId(stageId int) ([]int, error)
func (*PipelineStageRepositoryImpl) GetScriptMappingDetailByScriptId ¶
func (impl *PipelineStageRepositoryImpl) GetScriptMappingDetailByScriptId(scriptId int) ([]*ScriptPathArgPortMapping, error)
func (*PipelineStageRepositoryImpl) GetScriptMappingIdsByStageId ¶
func (impl *PipelineStageRepositoryImpl) GetScriptMappingIdsByStageId(stageId int) ([]int, error)
func (*PipelineStageRepositoryImpl) GetStepById ¶
func (impl *PipelineStageRepositoryImpl) GetStepById(stepId int) (*PipelineStageStep, error)
func (*PipelineStageRepositoryImpl) GetStepIdsByStageId ¶
func (impl *PipelineStageRepositoryImpl) GetStepIdsByStageId(stageId int) ([]int, error)
func (*PipelineStageRepositoryImpl) GetVariableIdsByStageId ¶
func (impl *PipelineStageRepositoryImpl) GetVariableIdsByStageId(stageId int) ([]int, error)
func (*PipelineStageRepositoryImpl) GetVariableIdsByStepIdAndVariableType ¶
func (impl *PipelineStageRepositoryImpl) GetVariableIdsByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType) ([]int, error)
func (*PipelineStageRepositoryImpl) GetVariablesByStepId ¶
func (impl *PipelineStageRepositoryImpl) GetVariablesByStepId(stepId int) ([]*PipelineStageStepVariable, error)
func (*PipelineStageRepositoryImpl) MarkConditionsDeletedByStepId ¶
func (impl *PipelineStageRepositoryImpl) MarkConditionsDeletedByStepId(stepId int, tx *pg.Tx) error
func (*PipelineStageRepositoryImpl) MarkConditionsDeletedExcludingActiveVariablesInUpdateReq ¶
func (*PipelineStageRepositoryImpl) MarkPipelineScriptMappingsDeletedByIds ¶
func (*PipelineStageRepositoryImpl) MarkPipelineScriptsDeletedByIds ¶
func (*PipelineStageRepositoryImpl) MarkPipelineStageDeletedById ¶ added in v0.6.21
func (*PipelineStageRepositoryImpl) MarkPipelineStageStepConditionDeletedByIds ¶
func (*PipelineStageRepositoryImpl) MarkPipelineStageStepVariablesDeletedByIds ¶
func (*PipelineStageRepositoryImpl) MarkPipelineStageStepsDeletedByStageId ¶ added in v0.6.21
func (*PipelineStageRepositoryImpl) MarkScriptDeletedById ¶
func (impl *PipelineStageRepositoryImpl) MarkScriptDeletedById(scriptId int) error
func (*PipelineStageRepositoryImpl) MarkScriptMappingDeletedByScriptId ¶
func (impl *PipelineStageRepositoryImpl) MarkScriptMappingDeletedByScriptId(scriptId int) error
func (*PipelineStageRepositoryImpl) MarkStepsDeletedByStageId ¶
func (impl *PipelineStageRepositoryImpl) MarkStepsDeletedByStageId(stageId int) error
func (*PipelineStageRepositoryImpl) MarkStepsDeletedExcludingActiveStepsInUpdateReq ¶
func (impl *PipelineStageRepositoryImpl) MarkStepsDeletedExcludingActiveStepsInUpdateReq(activeStepIdsPresentInReq []int, stageId int) error
func (*PipelineStageRepositoryImpl) MarkVariablesDeletedByStepIdAndVariableType ¶
func (impl *PipelineStageRepositoryImpl) MarkVariablesDeletedByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType, tx *pg.Tx) error
func (*PipelineStageRepositoryImpl) MarkVariablesDeletedExcludingActiveVariablesInUpdateReq ¶
func (impl *PipelineStageRepositoryImpl) MarkVariablesDeletedExcludingActiveVariablesInUpdateReq(activeVariableIdsPresentInReq []int, stepId int, variableType PipelineStageStepVariableType, tx *pg.Tx) error
func (*PipelineStageRepositoryImpl) UpdatePipelineScript ¶
func (impl *PipelineStageRepositoryImpl) UpdatePipelineScript(pipelineScript *PluginPipelineScript) (*PluginPipelineScript, error)
func (*PipelineStageRepositoryImpl) UpdatePipelineStage ¶ added in v0.6.21
func (impl *PipelineStageRepositoryImpl) UpdatePipelineStage(pipelineStage *PipelineStage) (*PipelineStage, error)
func (*PipelineStageRepositoryImpl) UpdatePipelineStageStep ¶
func (impl *PipelineStageRepositoryImpl) UpdatePipelineStageStep(step *PipelineStageStep) (*PipelineStageStep, error)
func (*PipelineStageRepositoryImpl) UpdatePipelineStageStepConditions ¶
func (impl *PipelineStageRepositoryImpl) UpdatePipelineStageStepConditions(conditions []PipelineStageStepCondition, tx *pg.Tx) ([]PipelineStageStepCondition, error)
func (*PipelineStageRepositoryImpl) UpdatePipelineStageStepVariables ¶
func (impl *PipelineStageRepositoryImpl) UpdatePipelineStageStepVariables(variables []PipelineStageStepVariable, tx *pg.Tx) ([]PipelineStageStepVariable, error)
func (*PipelineStageRepositoryImpl) UpdateScriptMapping ¶ added in v0.6.26
func (impl *PipelineStageRepositoryImpl) UpdateScriptMapping(mappings []*ScriptPathArgPortMapping, tx *pg.Tx) error
type PipelineStageStep ¶
type PipelineStageStep struct { Id int `sql:"id,pk"` PipelineStageId int `sql:"pipeline_stage_id"` Name string `sql:"name"` Description string `sql:"description"` Index int `sql:"index"` StepType PipelineStepType `sql:"step_type"` ScriptId int `sql:"script_id"` RefPluginId int `sql:"ref_plugin_id"` //id of plugin used as reference OutputDirectoryPath []string `sql:"output_directory_path" pg:",array"` DependentOnStep string `sql:"dependent_on_step"` Deleted bool `sql:"deleted,notnull"` TriggerIfParentStageFail bool `sql:"trigger_if_parent_stage_fail"` sql.AuditLog // contains filtered or unexported fields }
type PipelineStageStepCondition ¶
type PipelineStageStepCondition struct { Id int `sql:"id,pk"` PipelineStageStepId int `sql:"pipeline_stage_step_id"` ConditionVariableId int `sql:"condition_variable_id"` //id of variable on which condition is written ConditionType PipelineStageStepConditionType `sql:"condition_type"` ConditionalOperator string `sql:"conditional_operator"` ConditionalValue string `sql:"conditional_value"` Deleted bool `sql:"deleted,notnull"` sql.AuditLog // contains filtered or unexported fields }
type PipelineStageStepConditionType ¶
type PipelineStageStepConditionType string
type PipelineStageStepVariable ¶
type PipelineStageStepVariable struct { Id int `sql:"id,pk"` PipelineStageStepId int `sql:"pipeline_stage_step_id"` Name string `sql:"name"` Format PipelineStageStepVariableFormatType `sql:"format"` Description string `sql:"description"` IsExposed bool `sql:"is_exposed,notnull"` AllowEmptyValue bool `sql:"allow_empty_value,notnull"` DefaultValue string `sql:"default_value"` Value string `sql:"value"` VariableType PipelineStageStepVariableType `sql:"variable_type"` ValueType PipelineStageStepVariableValueType `sql:"value_type"` PreviousStepIndex int `sql:"previous_step_index,type:integer"` VariableStepIndexInPlugin int `sql:"variable_step_index_in_plugin,type:integer"` ReferenceVariableName string `sql:"reference_variable_name,type:text"` ReferenceVariableStage PipelineStageType `sql:"reference_variable_stage,type:text"` Deleted bool `sql:"deleted,notnull"` sql.AuditLog // contains filtered or unexported fields }
type PipelineStageStepVariableFormatType ¶
type PipelineStageStepVariableFormatType string
type PipelineStageStepVariableType ¶
type PipelineStageStepVariableType string
type PipelineStageStepVariableValueType ¶
type PipelineStageStepVariableValueType string
type PipelineStageType ¶
type PipelineStageType string
type PipelineStepType ¶
type PipelineStepType string
type PluginPipelineScript ¶
type PluginPipelineScript struct { Id int `sql:"id,pk"` Script string `sql:"script"` StoreScriptAt string `sql:"store_script_at"` Type repository.ScriptType `sql:"type"` DockerfileExists bool `sql:"dockerfile_exists, notnull"` MountPath string `sql:"mount_path"` MountCodeToContainer bool `sql:"mount_code_to_container,notnull"` MountCodeToContainerPath string `sql:"mount_code_to_container_path"` MountDirectoryFromHost bool `sql:"mount_directory_from_host,notnull"` ContainerImagePath string `sql:"container_image_path"` ImagePullSecretType repository.ScriptImagePullSecretType `sql:"image_pull_secret_type"` ImagePullSecret string `sql:"image_pull_secret"` Deleted bool `sql:"deleted, notnull"` sql.AuditLog // contains filtered or unexported fields }
type ScriptPathArgPortMapping ¶
type ScriptPathArgPortMapping struct { Id int `sql:"id,pk"` TypeOfMapping repository.ScriptMappingType `sql:"type_of_mapping"` FilePathOnDisk string `sql:"file_path_on_disk"` FilePathOnContainer string `sql:"file_path_on_container"` Command string `sql:"command"` Args []string `sql:"args" pg:",array"` PortOnLocal int `sql:"port_on_local"` PortOnContainer int `sql:"port_on_container"` ScriptId int `sql:"script_id"` Deleted bool `sql:"deleted, notnull"` sql.AuditLog // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.