Documentation
¶
Index ¶
Constants ¶
const ProgramName = "git-trigger-worker"
Variables ¶
This section is empty.
Functions ¶
func OperationParametersForActivity ¶
func OperationParametersForActivity(activity *domain.Activity) *domain.OperationParameters
Types ¶
type DbScheduler ¶
type DbScheduler struct {
// contains filtered or unexported fields
}
func NewDbScheduler ¶
func NewDbScheduler(db *sqlx.DB) *DbScheduler
func (*DbScheduler) FinishTxWith ¶
func (self *DbScheduler) FinishTxWith(fn func(*sqlx.Tx) error) *DbScheduler
FinishTxWith registers fn to run with the current transaction after a new transaction has been acquired.
This method is introduced to inject test data into the transaction in the unit tests.
func (*DbScheduler) InitTxWith ¶
func (self *DbScheduler) InitTxWith(fn func(*sqlx.Tx) error) *DbScheduler
InitTxWith registers fn to run with the current transaction after a new transaction has been acquired.
This method is introduced to inject test data into the transaction in the unit tests.
func (*DbScheduler) ScheduleJob ¶
func (self *DbScheduler) ScheduleJob(forTrigger *domain.GitTrigger, params *domain.OperationParameters) error
type DbTriggerIndex ¶
type DbTriggerIndex struct {
// contains filtered or unexported fields
}
func NewDbTriggerIndex ¶
func NewDbTriggerIndex(db *sqlx.DB) *DbTriggerIndex
func (*DbTriggerIndex) FindTriggersForActivity ¶
func (self *DbTriggerIndex) FindTriggersForActivity(activity *domain.Activity) ([]*domain.GitTrigger, error)
FindTriggersForActivity returns all Git triggers found in the database for the project that is associated with activity.
func (*DbTriggerIndex) InitTxWith ¶
func (self *DbTriggerIndex) InitTxWith(fn func(tx *sqlx.Tx) error) *DbTriggerIndex
InitTxWith registers fn to run with the current transaction after a new transaction has been acquired.
This method is introduced to inject test data into the transaction in the unit tests.
type GitTriggerWorker ¶
type GitTriggerWorker struct {
// contains filtered or unexported fields
}
func NewGitTriggerWorker ¶
func NewGitTriggerWorker(triggerIndex TriggerIndex, scheduler Scheduler) *GitTriggerWorker
func (*GitTriggerWorker) HandleActivity ¶
func (self *GitTriggerWorker) HandleActivity(activity *domain.Activity) error
HandleActivity schedules a job for activity if any matching git trigger is found in the git trigger index.
func (*GitTriggerWorker) Log ¶
func (self *GitTriggerWorker) Log() logger.Logger
func (*GitTriggerWorker) SetLogger ¶
func (self *GitTriggerWorker) SetLogger(l logger.Logger)
type Scheduler ¶
type Scheduler interface {
ScheduleJob(forTrigger *domain.GitTrigger, params *domain.OperationParameters) error
}
type TriggerIndex ¶
type TriggerIndex interface {
FindTriggersForActivity(*domain.Activity) ([]*domain.GitTrigger, error)
}
Source Files