kmsg

type Message struct {
	Timestamp      metav1.Time `json:"timestamp"`
	Priority       int         `json:"priority"`
	SequenceNumber int         `json:"sequence_number"`
	Message        string      `json:"message"`
}

type Watcher interface {
	// Watch reads from kmsg and provides a channel of messages.
	// Watch will always close the provided channel before returning.
	// Watch may be canceled by calling 'Close' on the parser.
	//
	// The caller should drain the channel after calling 'Close'.
	Watch(chan<- Message) error
	Close() error
}