repository

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2025 License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Index

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
}

func (*PipelineStage) IsPipelineStageExists added in v1.1.0 

func (ps *PipelineStage) IsPipelineStageExists() bool

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, tx *pg.Tx) (*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)
	CheckIfPluginExistsInPipelineStage(pipelineId int, stageType PipelineStageType, pluginId int) (bool, 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, tx *pg.Tx) error

	MarkScriptMappingDeletedByScriptId(scriptId int, tx *pg.Tx) 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)
	GetVariablesByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType) (variables []*PipelineStageStepVariable, err error)
	MarkVariablesDeletedByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType, userId int32, 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 (impl *PipelineStageRepositoryImpl) CheckIfCommandArgMappingExists(command string, arg string, scriptId int) (bool, error)

func (*PipelineStageRepositoryImpl) CheckIfFilePathMappingExists 

func (impl *PipelineStageRepositoryImpl) CheckIfFilePathMappingExists(filePathOnDisk string, filePathOnContainer string, scriptId int) (bool, error)

func (*PipelineStageRepositoryImpl) CheckIfPluginExistsInPipelineStage added in v1.1.0 

func (impl *PipelineStageRepositoryImpl) CheckIfPluginExistsInPipelineStage(pipelineId int, stageType PipelineStageType, pluginId int) (bool, error)

func (*PipelineStageRepositoryImpl) CheckIfPortMappingExists 

func (impl *PipelineStageRepositoryImpl) CheckIfPortMappingExists(portOnLocal int, portOnContainer int, scriptId int) (bool, error)

func (*PipelineStageRepositoryImpl) CheckPluginExistsInCiPipeline added in v0.6.26 

func (impl *PipelineStageRepositoryImpl) CheckPluginExistsInCiPipeline(pipelineId int, stageType string, pluginId int) (bool, error)

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

func (impl *PipelineStageRepositoryImpl) GetVariablesByStepId(stepId int) ([]*PipelineStageStepVariable, error)

func (*PipelineStageRepositoryImpl) GetVariablesByStepIdAndVariableType added in v1.1.0 

func (impl *PipelineStageRepositoryImpl) GetVariablesByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType) (variables []*PipelineStageStepVariable, err error)

func (*PipelineStageRepositoryImpl) MarkConditionsDeletedByStepId 

func (impl *PipelineStageRepositoryImpl) MarkConditionsDeletedByStepId(stepId int, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkConditionsDeletedExcludingActiveVariablesInUpdateReq 

func (impl *PipelineStageRepositoryImpl) MarkConditionsDeletedExcludingActiveVariablesInUpdateReq(activeConditionIdsPresentInReq []int, stepId int, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkPipelineScriptMappingsDeletedByIds 

func (impl *PipelineStageRepositoryImpl) MarkPipelineScriptMappingsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkPipelineScriptsDeletedByIds 

func (impl *PipelineStageRepositoryImpl) MarkPipelineScriptsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkPipelineStageDeletedById added in v0.6.21 

func (impl *PipelineStageRepositoryImpl) MarkPipelineStageDeletedById(stageId int, updatedBy int32, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkPipelineStageStepConditionDeletedByIds 

func (impl *PipelineStageRepositoryImpl) MarkPipelineStageStepConditionDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkPipelineStageStepVariablesDeletedByIds 

func (impl *PipelineStageRepositoryImpl) MarkPipelineStageStepVariablesDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkPipelineStageStepsDeletedByStageId added in v0.6.21 

func (impl *PipelineStageRepositoryImpl) MarkPipelineStageStepsDeletedByStageId(stageId int, updatedBy int32, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkScriptDeletedById 

func (impl *PipelineStageRepositoryImpl) MarkScriptDeletedById(scriptId int, tx *pg.Tx) error

func (*PipelineStageRepositoryImpl) MarkScriptMappingDeletedByScriptId 

func (impl *PipelineStageRepositoryImpl) MarkScriptMappingDeletedByScriptId(scriptId int, tx *pg.Tx) 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, userId int32, 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, tx *pg.Tx) (*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"` // oneof: STRING, NUMBER, BOOL, DATE
	Description         string                              `sql:"description"`
	// IsExposed: has conflicting data in DB.
	// Ideally, for user given input variables, it should always be TRUE.
	// Also, if IsExposed is false, then it's an internal variable (should not be exposed in UI).
	// TODO: investigate the conflicting data in DB.
	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

PipelineStageStepVariableFormatType - Duplicate of repository.PluginStepVariableFormatType TODO: analyse if we can remove the duplicates. Should ideally be a subset of repository.PluginStepVariableFormatType

func (PipelineStageStepVariableFormatType) String added in v1.1.0 

func (p PipelineStageStepVariableFormatType) String() string

type PipelineStageStepVariableType 

type PipelineStageStepVariableType string

func (PipelineStageStepVariableType) IsInput added in v1.1.0 

func (p PipelineStageStepVariableType) IsInput() bool

func (PipelineStageStepVariableType) IsOutput added in v1.1.0 

func (p PipelineStageStepVariableType) IsOutput() bool

type PipelineStageStepVariableValueType 

type PipelineStageStepVariableValueType string

func (PipelineStageStepVariableValueType) IsGlobalDefinedValue added in v1.1.0 

func (p PipelineStageStepVariableValueType) IsGlobalDefinedValue() bool

func (PipelineStageStepVariableValueType) IsPreviousOutputDefinedValue added in v1.1.0 

func (p PipelineStageStepVariableValueType) IsPreviousOutputDefinedValue() bool

func (PipelineStageStepVariableValueType) IsUserDefinedValue added in v1.1.0 

func (p PipelineStageStepVariableValueType) IsUserDefinedValue() bool

func (PipelineStageStepVariableValueType) String added in v1.1.0 

func (p PipelineStageStepVariableValueType) String() string

type PipelineStageType 

type PipelineStageType string

func (PipelineStageType) IsStageTypePostCd added in v1.1.0 

func (r PipelineStageType) IsStageTypePostCd() bool

func (PipelineStageType) IsStageTypePostCi added in v1.1.0 

func (r PipelineStageType) IsStageTypePostCi() bool

func (PipelineStageType) IsStageTypePreCd added in v1.1.0 

func (r PipelineStageType) IsStageTypePreCd() bool

func (PipelineStageType) IsStageTypePreCi added in v1.1.0 

func (r PipelineStageType) IsStageTypePreCi() bool

func (PipelineStageType) ToString added in v1.1.0 

func (r PipelineStageType) ToString() string

type PipelineStepType 

type PipelineStepType string

func (PipelineStepType) String added in v1.1.0 

func (p PipelineStepType) String() 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
}

PluginPipelineScript is the duplicate declaration of repository.PluginPipelineScript

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
}

ScriptPathArgPortMapping is the duplicate declaration of repository.ScriptPathArgPortMapping

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.