trigger

Documentation

Overview

Package trigger provides a piped component that detects a list of application should be synced (by new commit, sync command or configuration drift) and then sends request to the control-plane to create a new Deployment.

Index

• type Determiner
  • func NewDeterminer(repo git.Repo, targetCommit string, cg LastTriggeredCommitGetter, ...) *Determiner
  • func (d *Determiner) ShouldTrigger(ctx context.Context, app *model.Application) (bool, error)
• type LastTriggeredCommitGetter
• type Trigger
  • func NewTrigger(apiClient apiClient, gitClient gitClient, appLister applicationLister, ...) (*Trigger, error)
  • func (t *Trigger) GetLastTriggeredCommitGetter() LastTriggeredCommitGetter
  • func (t *Trigger) Run(ctx context.Context) error

Types

type Determiner

type Determiner struct {
	// contains filtered or unexported fields
}

func NewDeterminer

func NewDeterminer(repo git.Repo, targetCommit string, cg LastTriggeredCommitGetter, logger *zap.Logger) *Determiner

func (*Determiner) ShouldTrigger

func (d *Determiner) ShouldTrigger(ctx context.Context, app *model.Application) (bool, error)

ShouldTrigger decides whether a given application should be triggered or not.

type LastTriggeredCommitGetter

type LastTriggeredCommitGetter interface {
	Get(ctx context.Context, applicationID string) (string, error)
}

type Trigger

type Trigger struct {
	// contains filtered or unexported fields
}

func NewTrigger

func NewTrigger(
	apiClient apiClient,
	gitClient gitClient,
	appLister applicationLister,
	commandLister commandLister,
	environmentLister environmentLister,
	notifier notifier,
	cfg *config.PipedSpec,
	gracePeriod time.Duration,
	logger *zap.Logger,
) (*Trigger, error)

NewTrigger creates a new instance for Trigger.

func (*Trigger) GetLastTriggeredCommitGetter

func (t *Trigger) GetLastTriggeredCommitGetter() LastTriggeredCommitGetter

func (*Trigger) Run

func (t *Trigger) Run(ctx context.Context) error

Run starts running Trigger until the specified context has done. This also waits for its cleaning up before returning.