kmsg

type EventDedupWindowFunc func(eventstore.Event) (time.Duration, bool)

type MatchFunc func(line string) (eventName string, message string)

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

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

type OpOption func(*Op)

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

type Watcher interface {
	// Watch starts a goroutine to read from kmsg and provide a channel of messages.
	// Watcher is responsible for closing the channel when the watch is done.
	// Watcher may be canceled by calling 'Close' on the parser.
	//
	// The caller should drain the channel after calling 'Close'.
	Watch() (<-chan Message, error)
	Close() error
}