output

Documentation

Overview

TODO will be moved to testkube lib when completed

Index

• Constants
• func GetExecutionResult(b []byte) (is bool, result testkube.ExecutionResult)
• func ParseRunnerOutput(b []byte) (result testkube.ExecutionResult, logs []string, err error)
• func PrintError(err error)
• func PrintEvent(message string, obj ...interface{})
• func PrintLog(message string)
• func PrintResult(result testkube.ExecutionResult)
• type JSONWrapWriter
  • func NewJSONWrapWriter(writer io.Writer) *JSONWrapWriter
  • func (w *JSONWrapWriter) Write(p []byte) (int, error)
• type Output
  • func GetLogEntry(b []byte) (out Output, err error)
  • func NewOutputError(err error) Output
  • func NewOutputEvent(message string) Output
  • func NewOutputLine(content []byte) Output
  • func NewOutputResult(result testkube.ExecutionResult) Output
  • func (out Output) String() string

Constants

const TypeError = "error"

const TypeLogEvent = "event"

const TypeLogLine = "line"

const TypeResult = "result"

Functions

func GetExecutionResult

func GetExecutionResult(b []byte) (is bool, result testkube.ExecutionResult)

GetExecutionResult tries to unmarshal execution result

func ParseRunnerOutput

func ParseRunnerOutput(b []byte) (result testkube.ExecutionResult, logs []string, err error)

ParseRunnerOutput try to parse possible runner output which is some bunch of json stream like {"type": "line", "message": "runner execution started ------------"} {"type": "line", "message": "GET /results"} {"type": "result", "result": {"id": "2323", "output": "-----"}}

func PrintError

func PrintError(err error)

PrintError - prints error as output json

func PrintEvent

func PrintEvent(message string, obj ...interface{})

PrintEvent - prints event as output json

func PrintLog

func PrintLog(message string)

PrintLog - prints log line as output json

func PrintResult

func PrintResult(result testkube.ExecutionResult)

PrintResult - prints result as output json

Types

type JSONWrapWriter

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

JSONWrapWriter wraps bytes stream into json Output of type line

func NewJSONWrapWriter

func NewJSONWrapWriter(writer io.Writer) *JSONWrapWriter

NewJSONWrapWriter returns new NewJSONWrapWriter instance

func (*JSONWrapWriter) Write

func (w *JSONWrapWriter) Write(p []byte) (int, error)

Write io.Writer method implementation

type Output

type Output testkube.ExecutorOutput

Output generic json based output data structure

func GetLogEntry

func GetLogEntry(b []byte) (out Output, err error)

func NewOutputError

func NewOutputError(err error) Output

NewOutputError returns new Output struct of type error

func NewOutputEvent

func NewOutputEvent(message string) Output

NewOutputEvent returns new Output struct of type event

func NewOutputLine

func NewOutputLine(content []byte) Output

NewOutputLine returns new Output struct of type line

func NewOutputResult

func NewOutputResult(result testkube.ExecutionResult) Output

NewOutputResult returns new Output struct of type result - should be last line in stream as it'll stop listening

func (Output) String

func (out Output) String() string

String