core

Documentation

Index

• func Config(config *models.Config)
• func FileExists(file string) bool
• func Inputs(inputMsgs chan<- models.Message, config *models.Config)
• func Outputs(outputMsgs <-chan models.Message, config *models.Config)
• func Params(config *models.Config)
• func Pipeline(inputMsgs <-chan models.Message, outputMsgs chan<- models.Message, ...)
• func Starter(config *models.Config)
• type State
  • func NewState(config *models.Config) (state *State)
  • func (state State) SetLastAlert(pipeline string)
  • func (state State) SetLastRun(pipeline string)
  • func (state State) SetRunning(pipeline string, running bool)
  • func (state State) SetState(pipeline string, success bool)

Functions

func Config

func Config(config *models.Config)

func FileExists

func FileExists(file string) bool

func Inputs

func Inputs(inputMsgs chan<- models.Message, config *models.Config)

func Outputs

func Outputs(outputMsgs <-chan models.Message, config *models.Config)

func Params

func Params(config *models.Config)

func Pipeline

func Pipeline(inputMsgs <-chan models.Message, outputMsgs chan<- models.Message, config *models.Config)

func Starter

func Starter(config *models.Config)

Types

type State

type State struct {
	States map[string]models.State
}

func NewState

func NewState(config *models.Config) (state *State)

func (State) SetLastAlert

func (state State) SetLastAlert(pipeline string)

func (State) SetLastRun

func (state State) SetLastRun(pipeline string)

func (State) SetRunning

func (state State) SetRunning(pipeline string, running bool)

func (State) SetState

func (state State) SetState(pipeline string, success bool)