events

Documentation

Index

• Constants
• func IsFinished(log *Log) bool
• type Log
  • func NewErrorLog(err error) *Log
  • func NewFinishLog() *Log
  • func NewLog(content ...string) *Log
  • func NewLogFromBytes(b []byte) *Log
  • func (l *Log) WithContent(s string) *Log
  • func (l *Log) WithError(err error) *Log
  • func (l *Log) WithMetadataEntry(key, value string) *Log
  • func (l *Log) WithSource(s string) *Log
  • func (l *Log) WithType(t string) *Log
  • func (l *Log) WithV1Result(result *testkube.ExecutionResult) *Log
  • func (l *Log) WithVersion(version LogVersion) *Log
• type LogResponse
• type LogVersion
• type Trigger
  • func NewTrigger(id string) Trigger
  • func (t Trigger) GetResourceId() string

Constants

const (
	// v1 - old log format based on shell output of executors {"line":"...", "time":"..."}
	LogVersionV1 LogVersion = "v1"
	// v2 - raw binary format, timestamps are based on Kubernetes logs, line is raw log line
	LogVersionV2 LogVersion = "v2"

	SourceJobPod            = "job-pod"
	SourceScheduler         = "test-scheduler"
	SourceContainerExecutor = "container-executor"
	SourceJobExecutor       = "job-executor"
)

Functions

func IsFinished

func IsFinished(log *Log) bool

Types

type Log

type Log testkube.LogV2

func NewErrorLog

func NewErrorLog(err error) *Log

func NewFinishLog

func NewFinishLog() *Log

func NewLog

func NewLog(content ...string) *Log

func NewLogFromBytes

func NewLogFromBytes(b []byte) *Log

NewLogFromBytes creates new LogResponse from bytes it's aware of new and old log formats default log format will be based on raw bytes with timestamp on the beginning

func (*Log) WithContent

func (l *Log) WithContent(s string) *Log

func (*Log) WithError

func (l *Log) WithError(err error) *Log

func (*Log) WithMetadataEntry

func (l *Log) WithMetadataEntry(key, value string) *Log

func (*Log) WithSource

func (l *Log) WithSource(s string) *Log

func (*Log) WithType

func (l *Log) WithType(t string) *Log

func (*Log) WithV1Result

func (l *Log) WithV1Result(result *testkube.ExecutionResult) *Log

func (*Log) WithVersion

func (l *Log) WithVersion(version LogVersion) *Log

type LogResponse

type LogResponse struct {
	Log   Log
	Error error
}

type LogVersion

type LogVersion string

type Trigger

type Trigger struct {
	ResourceId string `json:"resourceId,omitempty"`
}

Generic event like log-start log-end with resource id

func NewTrigger

func NewTrigger(id string) Trigger

NewTrigger returns Trigger instance

func (Trigger) GetResourceId

func (t Trigger) GetResourceId() string

GetResourceId implements testkube.Trigger interface