stream

Aug 2, 2024

Changes in this version

+ type Reader interface

+ LogFlush func(writer io.Writer)

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

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

+ type Stream struct

+ Client kubernetes.Interface

+ Follow bool

+ Namespace string

+ Since time.Duration

+ Timestamps bool

+ func NewStream(writer io.Writer, reader Reader, namespace string) *Stream

+ func (s *Stream) Start(ctx context.Context) error