output

package
v1.6.17 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 18, 2022 License: MIT Imports: 8 Imported by: 35

Documentation

Index

Constants

View Source
const TypeError = "error"
View Source
const TypeLogEvent = "event"
View Source
const TypeLogLine = "line"
View Source
const TypeResult = "result"

Variables

This section is empty.

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(w io.Writer, 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, envMngr secret.Manager) *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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL