reporter

Documentation

Index

• type Config
• type Mailer
• type Reporter
  • func (rp *Reporter) ReportStep(d *dag.DAG, status *model.Status, node *scheduler.Node) error
  • func (rp *Reporter) ReportSummary(status *model.Status, err error)
  • func (rp *Reporter) SendMail(d *dag.DAG, status *model.Status, err error) error

Types

type Config

type Config struct {
	Mailer Mailer
}

Config is the configuration for the reporter.

type Mailer

type Mailer interface {
	SendMail(from string, to []string, subject, body string, attachments []string) error
}

Mailer is a mailer interface.

type Reporter

type Reporter struct {
	*Config
}

Reporter is responsible for reporting the status of the scheduler to the user.

func (*Reporter) ReportStep

func (rp *Reporter) ReportStep(d *dag.DAG, status *model.Status, node *scheduler.Node) error

ReportStep is a function that reports the status of a step.

func (*Reporter) ReportSummary

func (rp *Reporter) ReportSummary(status *model.Status, err error)

ReportSummary is a function that reports the status of the scheduler.

func (*Reporter) SendMail

func (rp *Reporter) SendMail(d *dag.DAG, status *model.Status, err error) error

SendMail is a function that sends a report mail.