controller

Documentation

Index

• type Controller
  • func New(fs afero.Fs) *Controller
  • func (c *Controller) Run(_ context.Context, logE *logrus.Entry, cfgFilePath string) error
• type HasLogLevelError
  • func (e *HasLogLevelError) Error() string
  • func (e *HasLogLevelError) Unwrap() error
• type JobPolicy
• type Policy
• type StepPolicy
• type WorkflowPolicy

Types

type Controller

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

func New

func New(fs afero.Fs) *Controller

func (*Controller) Run

func (c *Controller) Run(_ context.Context, logE *logrus.Entry, cfgFilePath string) error

type HasLogLevelError

type HasLogLevelError struct {
	LogLevel logrus.Level
	Err      error
}

func (*HasLogLevelError) Error

func (e *HasLogLevelError) Error() string

func (*HasLogLevelError) Unwrap

func (e *HasLogLevelError) Unwrap() error

type JobPolicy

type JobPolicy interface {
	Name() string
	ID() string
	ApplyJob(logE *logrus.Entry, cfg *config.Config, jobCtx *policy.JobContext, job *workflow.Job) error
}

type Policy

type Policy interface {
	Name() string
	ID() string
}

type StepPolicy

type StepPolicy interface {
	Name() string
	ID() string
	ApplyStep(logE *logrus.Entry, cfg *config.Config, stepCtx *policy.StepContext, step *workflow.Step) error
}

type WorkflowPolicy

type WorkflowPolicy interface {
	Name() string
	ID() string
	ApplyWorkflow(logE *logrus.Entry, cfg *config.Config, wfCtx *policy.WorkflowContext, wf *workflow.Workflow) error
}