watcher

Documentation

Index

• func CheckOutput(line <-chan string)
• func PLEGWatch(out *models.LineInfo)
• type PLEGEvent
  • func Format(inputStr string) (PLEGEvent, error)

Functions

func CheckOutput

func CheckOutput(line <-chan string)

CheckOutput filters through new systemd lines as they're received from a string channel.

func PLEGWatch

func PLEGWatch(out *models.LineInfo)

PLEGWatch initalizes a new JournalReader and starts following systemd output

Types

type PLEGEvent

type PLEGEvent struct {
	ID   string `json:"ID"`
	Type string `json:"Type"`
	Data string `json:"Data"`
}

PLEGEvent represents relevant data from Kubernetes Pod Lifecycle Event Generator messages.

func Format

func Format(inputStr string) (PLEGEvent, error)

Format converts systemd output into a usable, JSON-compatible go struct