engine

Documentation

Index

• func MapEnvs(envs []string) map[string]string
• type DefaultExecuter
  • func (e DefaultExecuter) Execute(ctx context.Context, elk *ox.Elk, name string) (int, error)
• type Engine
  • func (e *Engine) Run(ctx context.Context, task string) error
• type Executer
• type Logger
  • func DefaultLogger() Logger
  • func TimeStampLogger(logger Logger, format string) (Logger, error)
• type TimeStampWriter
  • func (t TimeStampWriter) GetDateFormat(format string) (string, error)
  • func (t TimeStampWriter) Write(p []byte) (int, error)

Functions

func MapEnvs

func MapEnvs(envs []string) map[string]string

MapEnvs map an array of string env

Types

type DefaultExecuter

type DefaultExecuter struct {
	Logger map[string]Logger
}

DefaultExecuter Execute task with a POSIX emulator

func (DefaultExecuter) Execute

func (e DefaultExecuter) Execute(ctx context.Context, elk *ox.Elk, name string) (int, error)

Execute task and returns a PID

type Engine

type Engine struct {
	Elk      *ox.Elk
	Executer Executer
}

Engine is the data structure responsible of processing the content

func (*Engine) Run

func (e *Engine) Run(ctx context.Context, task string) error

Run task declared in ox.yml file

type Executer

type Executer interface {
	Execute(context.Context, *ox.Elk, string) (int, error)
}

Executer runs a task and returns a PID and an error

type Logger

type Logger struct {
	StderrWriter io.Writer
	StdoutWriter io.Writer
	StdinReader  io.Reader
}

Logger is used by the engine to store the output

func DefaultLogger

func DefaultLogger() Logger

DefaultLogger is the standard output for a logger

func TimeStampLogger

func TimeStampLogger(logger Logger, format string) (Logger, error)

TimeStampLogger receives any logger and appends a timestamp in a specific format

type TimeStampWriter

type TimeStampWriter struct {
	TimeStamp func() string
	// contains filtered or unexported fields
}

TimeStampWriter attach a timestamp to each log

func (TimeStampWriter) GetDateFormat

func (t TimeStampWriter) GetDateFormat(format string) (string, error)

GetDateFormat returns a time format from a string

func (TimeStampWriter) Write

func (t TimeStampWriter) Write(p []byte) (int, error)

Writes timestamp to a writer