stream

Documentation

Overview

Package stream contains the logic for streaming logs from from UDS Core

Index

• type Reader
• type Stream
  • func NewStream(writer io.Writer, reader Reader, namespace string) *Stream
  • func (s *Stream) Start(ctx context.Context, k8sContext string) error

Types

type Reader

type Reader interface {
	// PodFilter creates a map of pod and container names to pull logs from
	PodFilter(pods []corev1.Pod) map[string]string

	// LogStream processes the log stream from Pepr and writes formatted output to the writer
	LogStream(writer io.Writer, logStream io.ReadCloser, timestamp bool) error

	// LogFlush to flush the log at a given interval and at the end of the stream
	LogFlush(writer io.Writer)
}

type Stream

type Stream struct {
	Follow     bool
	Timestamps bool
	Namespace  string
	Since      time.Duration
	// Adding for testability :-<
	Client kubernetes.Interface
	// contains filtered or unexported fields
}

func NewStream

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

func (*Stream) Start

func (s *Stream) Start(ctx context.Context, k8sContext string) error

Start starts the stream with the provided context