Documentation
¶
Index ¶
- func CheckPrerequisites(t sdk.PipelineTrigger, pb sdk.PipelineBuild) (bool, error)
- func DeleteApplicationPipelineTriggers(db database.Executer, proj, app, pip string) error
- func DeleteApplicationTriggers(db database.Executer, appID int64) error
- func DeletePipelineTriggers(db database.Executer, pipelineID int64) error
- func DeleteTrigger(db database.Executer, triggerID int64) error
- func Exists(db database.Querier, ...) (bool, error)
- func InsertTrigger(tx database.QueryExecuter, t *sdk.PipelineTrigger) error
- func InsertTriggerParameter(db database.Executer, triggerID int64, p sdk.Parameter) error
- func InsertTriggerPrerequisite(db database.Executer, triggerID int64, paramName, value string) error
- func LoadAutomaticTriggersAsSource(db database.Querier, appID, pipelineID, envID int64) ([]sdk.PipelineTrigger, error)
- func LoadTrigger(db database.Querier, triggerID int64) (*sdk.PipelineTrigger, error)
- func LoadTriggerByApp(db database.Querier, appID int64) ([]sdk.PipelineTrigger, error)
- func LoadTriggers(db *sql.DB, appID, pipelineID, envID int64) ([]sdk.PipelineTrigger, error)
- func LoadTriggersAsSource(db database.Querier, appID, pipelineID, envID int64) ([]sdk.PipelineTrigger, error)
- func LoadTriggersByAppAndPipeline(db database.Querier, appID int64, pipID int64) ([]sdk.PipelineTrigger, error)
- func ProcessTriggerExpectedValue(payload string, pb sdk.PipelineBuild) string
- func ProcessTriggerParameters(t sdk.PipelineTrigger, pbParams []sdk.Parameter) ([]sdk.Parameter, error)
- func UpdateTrigger(db database.QueryExecuter, t *sdk.PipelineTrigger) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckPrerequisites ¶
func CheckPrerequisites(t sdk.PipelineTrigger, pb sdk.PipelineBuild) (bool, error)
CheckPrerequisites verifies that all prerequisite are matched before scheduling
func DeleteApplicationPipelineTriggers ¶
DeleteApplicationPipelineTriggers removes from database all triggers linked to a pipeline in a specific app
func DeleteApplicationTriggers ¶
DeleteApplicationTriggers removes from database all triggers where given application is present
func DeletePipelineTriggers ¶
DeletePipelineTriggers removes from database all triggers where given pipeline is present
func DeleteTrigger ¶
DeleteTrigger removes from database given trigger
func Exists ¶
func Exists(db database.Querier, applicationSource, pipelineSource, EnvSource, applicationDest, pipelineDest, EnvDest int64) (bool, error)
Exists checks if trigger exists
func InsertTrigger ¶
func InsertTrigger(tx database.QueryExecuter, t *sdk.PipelineTrigger) error
InsertTrigger adds a new trigger in database
func InsertTriggerParameter ¶
InsertTriggerParameter insert given parameter in database
func InsertTriggerPrerequisite ¶
func InsertTriggerPrerequisite(db database.Executer, triggerID int64, paramName, value string) error
InsertTriggerPrerequisite Insert the given prerequisite
func LoadAutomaticTriggersAsSource ¶
func LoadAutomaticTriggersAsSource(db database.Querier, appID, pipelineID, envID int64) ([]sdk.PipelineTrigger, error)
LoadAutomaticTriggersAsSource will only retrieves from database triggers where given pipeline is the source func LoadAutomaticTriggersAsSource(db database.Querier, appID, pipelineID, envID int64, mods ...mod) ([]sdk.PipelineTrigger, error) {
func LoadTrigger ¶
LoadTrigger load the given trigger
func LoadTriggerByApp ¶
LoadTriggerByApp Load trigger where given app is source
func LoadTriggers ¶
LoadTriggers loads all triggers from database where given pipeline-env tuple is either triggering or triggered func LoadTriggers(db *sql.DB, appID, pipelineID, envID int64, mods ...mod) ([]sdk.PipelineTrigger, error) {
func LoadTriggersAsSource ¶
func LoadTriggersAsSource(db database.Querier, appID, pipelineID, envID int64) ([]sdk.PipelineTrigger, error)
LoadTriggersAsSource will only retrieves from database triggers where given pipeline is the source
func LoadTriggersByAppAndPipeline ¶
func LoadTriggersByAppAndPipeline(db database.Querier, appID int64, pipID int64) ([]sdk.PipelineTrigger, error)
LoadTriggersByAppAndPipeline Load triggers for the given app and pipeline
func ProcessTriggerExpectedValue ¶
func ProcessTriggerExpectedValue(payload string, pb sdk.PipelineBuild) string
ProcessTriggerExpectedValue processes prerequisites expected values
func ProcessTriggerParameters ¶
func ProcessTriggerParameters(t sdk.PipelineTrigger, pbParams []sdk.Parameter) ([]sdk.Parameter, error)
ProcessTriggerParameters replaces all placeholders in trigger before execution
func UpdateTrigger ¶
func UpdateTrigger(db database.QueryExecuter, t *sdk.PipelineTrigger) error
UpdateTrigger update trigger data
Types ¶
This section is empty.
Source Files