triggerService

Documentation

Index

• Variables
• type TriggerManager
  • func (manager *TriggerManager) AddTriggers(accountId string, projectName string, triggers []*models.EventTrigger, ...) (err error)
  • func (manager *TriggerManager) CreateEventBridgeScheduler(trigger models.EventTrigger) (err error)
  • func (manager *TriggerManager) DeleteEventBridgeScheduler(pipelineEndpoint, triggerName string) (err error)
  • func (manager *TriggerManager) DeleteTrigger(accountId string, triggerName, pipeline string) error
  • func (manager *TriggerManager) DeleteTriggers(accountId, pipelineName, pipelineEndpoint string) (err error)
  • func (manager *TriggerManager) DisableAllScheduledTriggers(pipelineEndpoint string) (err error)
  • func (manager *TriggerManager) EnableAllScheduledTriggers(pipelineEndpoint string) (err error)
  • func (manager *TriggerManager) GetAllTriggers() ([]models.EventTrigger, error)
  • func (manager *TriggerManager) GetAllTriggersForAccount(accountId string) ([]models.EventTrigger, error)
  • func (manager *TriggerManager) GetAllTriggersForAccountByType(accountId, triggerType string) ([]models.EventTrigger, error)
  • func (manager *TriggerManager) GetAllTriggersForPipelineByEndpoint(pipelineEndpoint string) ([]models.EventTrigger, error)
  • func (manager *TriggerManager) GetDefinitionForTrigger(accountId, triggerType string) (models.TriggerDefinition, error)
  • func (manager *TriggerManager) GetTriggerTypes() (map[string][]triggerSummery, error)
  • func (manager *TriggerManager) HandleEventBridgeScheduler(pipelineEndpoint string) (err error)
  • func (manager *TriggerManager) HandleScheduledTriggers(pipelineEndpoint, accountId string) (err error)
  • func (manager *TriggerManager) StartChecking(store integrationStore.IntegrationStore) error
  • func (manager *TriggerManager) StartScheduller() error
  • func (manager *TriggerManager) StartSchedulling(trigger models.EventTrigger) error
  • func (manager *TriggerManager) StopScheduler(accId, pipelineName, triggerName string) error
  • func (manager *TriggerManager) UpdateTriggers(accountId, projectName string, triggers []*models.EventTrigger, ...) (err error)
• type TriggerService
  • func NewTriggerService(store triggerStore.TriggerStore, service utopiopsService.UtopiopsService, ...) TriggerService

Variables

var ActiveSchedulers map[string]*gocron.Scheduler

Types

type TriggerManager

type TriggerManager struct {
	Store              triggerStore.TriggerStore
	UtopiopsService    utopiopsService.UtopiopsService
	ExecutionService   executionService.ExecutionService
	IntegrationService integrationService.IntegrationService
	PipelineStore      pipelineStore.PipelineStore
	MarketplaceStore   marketplaceStore.MarketplaceStore
	RedisStore         redisStore.RedisStore
}

func (*TriggerManager) AddTriggers

func (manager *TriggerManager) AddTriggers(accountId string, projectName string, triggers []*models.EventTrigger, endpoint string) (err error)

func (*TriggerManager) CreateEventBridgeScheduler

func (manager *TriggerManager) CreateEventBridgeScheduler(trigger models.EventTrigger) (err error)

func (*TriggerManager) DeleteEventBridgeScheduler

func (manager *TriggerManager) DeleteEventBridgeScheduler(pipelineEndpoint, triggerName string) (err error)

func (*TriggerManager) DeleteTrigger

func (manager *TriggerManager) DeleteTrigger(accountId string, triggerName, pipeline string) error

func (*TriggerManager) DeleteTriggers

func (manager *TriggerManager) DeleteTriggers(accountId, pipelineName, pipelineEndpoint string) (err error)

DeleteTriggers deletes Event Bridge Scheduler from triggers that their type is 'Schedule' and delete all triggers from database

func (*TriggerManager) DisableAllScheduledTriggers

func (manager *TriggerManager) DisableAllScheduledTriggers(pipelineEndpoint string) (err error)

func (*TriggerManager) EnableAllScheduledTriggers

func (manager *TriggerManager) EnableAllScheduledTriggers(pipelineEndpoint string) (err error)

func (*TriggerManager) GetAllTriggers

func (manager *TriggerManager) GetAllTriggers() ([]models.EventTrigger, error)

func (*TriggerManager) GetAllTriggersForAccount

func (manager *TriggerManager) GetAllTriggersForAccount(accountId string) ([]models.EventTrigger, error)

func (*TriggerManager) GetAllTriggersForAccountByType

func (manager *TriggerManager) GetAllTriggersForAccountByType(accountId, triggerType string) ([]models.EventTrigger, error)

func (*TriggerManager) GetAllTriggersForPipelineByEndpoint

func (manager *TriggerManager) GetAllTriggersForPipelineByEndpoint(pipelineEndpoint string) ([]models.EventTrigger, error)

func (*TriggerManager) GetDefinitionForTrigger

func (manager *TriggerManager) GetDefinitionForTrigger(accountId, triggerType string) (models.TriggerDefinition, error)

func (*TriggerManager) GetTriggerTypes

func (manager *TriggerManager) GetTriggerTypes() (map[string][]triggerSummery, error)

func (*TriggerManager) HandleEventBridgeScheduler

func (manager *TriggerManager) HandleEventBridgeScheduler(pipelineEndpoint string) (err error)

func (*TriggerManager) HandleScheduledTriggers

func (manager *TriggerManager) HandleScheduledTriggers(pipelineEndpoint, accountId string) (err error)

func (*TriggerManager) StartChecking

func (manager *TriggerManager) StartChecking(store integrationStore.IntegrationStore) error

This function (currently) finds all the triggers and check if they have to start the pipelines they belong to

func (*TriggerManager) StartScheduller

func (manager *TriggerManager) StartScheduller() error

func (*TriggerManager) StartSchedulling

func (manager *TriggerManager) StartSchedulling(trigger models.EventTrigger) error

func (*TriggerManager) StopScheduler

func (manager *TriggerManager) StopScheduler(accId, pipelineName, triggerName string) error

func (*TriggerManager) UpdateTriggers

func (manager *TriggerManager) UpdateTriggers(accountId, projectName string, triggers []*models.EventTrigger, endpoint string) (err error)

TODO: UpdateTriggers doesn't enable triggers based on state of pipeline (is active or not) probably we should delete this function

type TriggerService

type TriggerService interface {
	GetTriggerTypes() (map[string][]triggerSummery, error)
	GetAllTriggers() ([]models.EventTrigger, error)
	GetAllTriggersForAccount(accountId string) ([]models.EventTrigger, error)
	// This function finds all the triggers of a pipeline
	GetAllTriggersForPipelineByEndpoint(pipelineEndpoint string) ([]models.EventTrigger, error)
	GetAllTriggersForAccountByType(accountId, triggerType string) ([]models.EventTrigger, error)
	GetDefinitionForTrigger(accountId, triggerType string) (models.TriggerDefinition, error)
	AddTriggers(accountId, projectName string, triggers []*models.EventTrigger, endpoint string) error
	UpdateTriggers(accountId, projectName string, triggers []*models.EventTrigger, endpoint string) error
	DeleteTriggers(accountId, pipelineName, pipelineEndpoint string) (err error)
	DeleteTrigger(accountId string, triggerName, pipeline string) error
	EnableAllScheduledTriggers(pipelineEndpoint string) (err error)
	DisableAllScheduledTriggers(pipelineEndpoint string) (err error)
	StartChecking(store integrationStore.IntegrationStore) error
	StartScheduller() error
	StopScheduler(accId, pipelineName, triggerName string) error
	StartSchedulling(trigger models.EventTrigger) error
	HandleEventBridgeScheduler(pipelineEndpoint string) (err error)
	HandleScheduledTriggers(pipelineEndpoint, accountId string) (err error)
}

func NewTriggerService

func NewTriggerService(store triggerStore.TriggerStore, service utopiopsService.UtopiopsService, execService executionService.ExecutionService, intService integrationService.IntegrationService, pipeStore pipelineStore.PipelineStore, mStore marketplaceStore.MarketplaceStore, rStore redisStore.RedisStore) TriggerService