pepr

Aug 2, 2024

Changes in this version

+ func IsValidStreamFilter(kind StreamKind) bool

+ type LogEntry struct

+ Hostname string

+ Level int

+ Metadata ...

+ Msg string

+ Name string

+ Namespace string

+ Pid int

+ Res struct{ ... }

+ Time int64

+ Uid string

+ type StreamKind string

+ const AllowStream

+ const AnyStream

+ const DenyStream

+ const FailureStream

+ const MutateStream

+ const OperatorStream

+ const PolicyStream

+ type StreamReader struct

+ FilterStream StreamKind

+ JSON bool

+ Web bool

+ func NewStreamReader(filterNamespace, filterName string) *StreamReader

+ func (p *StreamReader) LogFlush(writer io.Writer)

+ func (p *StreamReader) LogStream(writer io.Writer, logStream io.ReadCloser, timestamp bool) error

+ func (p *StreamReader) PodFilter(pods []corev1.Pod) map[string]string