task

Documentation

Index

• type Registry
  • func NewRegistry(opts options.Opts) *Registry
  • func (tr *Registry) GetTasks() []*Task
  • func (tr *Registry) ReadAll(taskFiles []string) error
  • func (tr *Registry) ReadTasks(taskFile string) error
  • func (tr *Registry) Stop()
• type Task
  • func (tw *Task) Actions() []action.Action
  • func (tw *Task) AddFilters(f ...filter.Filter)
  • func (tw *Task) CalcAutoMergeAfter() time.Duration
  • func (tw *Task) Checksum() string
  • func (tw *Task) Filters() []filter.Filter
  • func (tw *Task) HasReachMaxOpenPRs() bool
  • func (tw *Task) HasReachedChangeLimit() bool
  • func (tw *Task) IncChangeLimitCount()
  • func (tw *Task) IncOpenPRsCount()
  • func (tw *Task) IsWithinSchedule() bool
  • func (tw *Task) OnPrClosed(ctx context.Context) error
  • func (tw *Task) OnPrCreated(ctx context.Context) error
  • func (tw *Task) OnPrMerged(ctx context.Context) error
  • func (tw *Task) RenderBranchName(data template.Data) (string, error)
  • func (tw *Task) RenderPrTitle(data template.Data) (string, error)
  • func (tw *Task) Stop()

Types

type Registry

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

Registry contains all tasks.

func NewRegistry

func NewRegistry(opts options.Opts) *Registry

func (*Registry) GetTasks

func (tr *Registry) GetTasks() []*Task

GetTasks returns all tasks registered with the Registry. Should be called only after ReadAll() has been called at least once.

func (*Registry) ReadAll

func (tr *Registry) ReadAll(taskFiles []string) error

ReadAll takes a list of paths to task files and reads all tasks from the files.

func (*Registry) ReadTasks

func (tr *Registry) ReadTasks(taskFile string) error

ReadTasks reads all tasks defined in taskFile and adds them to the registry.

func (*Registry) Stop

func (tr *Registry) Stop()

Stop notifies every task that this Registry is being stopped. This usually happens at the end of a run. Every task can then execute code to clean itself up.

type Task

type Task struct {
	schema.Task
	// contains filtered or unexported fields
}

func (*Task) Actions

func (tw *Task) Actions() []action.Action

func (*Task) AddFilters

func (tw *Task) AddFilters(f ...filter.Filter)

func (*Task) CalcAutoMergeAfter

func (tw *Task) CalcAutoMergeAfter() time.Duration

func (*Task) Checksum

func (tw *Task) Checksum() string

func (*Task) Filters

func (tw *Task) Filters() []filter.Filter

func (*Task) HasReachMaxOpenPRs

func (tw *Task) HasReachMaxOpenPRs() bool

func (*Task) HasReachedChangeLimit

func (tw *Task) HasReachedChangeLimit() bool

func (*Task) IncChangeLimitCount

func (tw *Task) IncChangeLimitCount()

func (*Task) IncOpenPRsCount

func (tw *Task) IncOpenPRsCount()

func (*Task) IsWithinSchedule

func (tw *Task) IsWithinSchedule() bool

func (*Task) OnPrClosed

func (tw *Task) OnPrClosed(ctx context.Context) error

func (*Task) OnPrCreated

func (tw *Task) OnPrCreated(ctx context.Context) error

func (*Task) OnPrMerged

func (tw *Task) OnPrMerged(ctx context.Context) error

func (*Task) RenderBranchName

func (tw *Task) RenderBranchName(data template.Data) (string, error)

func (*Task) RenderPrTitle

func (tw *Task) RenderPrTitle(data template.Data) (string, error)

func (*Task) Stop

func (tw *Task) Stop()