podlogs

type ClusterWriter ¶

type ClusterWriter struct {
	Cluster       *apiv1.Cluster
	Options       *corev1.PodLogOptions
	Previous      bool `json:"previous,omitempty"`
	FollowWaiting time.Duration
	// NOTE: the Client argument may be omitted, but it is good practice to pass it
	// Importantly, it makes the logging functions testable
	Client kubernetes.Interface
}

ClusterWriter represents a request to stream a cluster's pod logs.

If the Follow Option is set to true, streaming will sit in a loop looking for any new / regenerated pods and will only exit when there are no pods streaming

func (csr *ClusterWriter) SingleStream(ctx context.Context, writer io.Writer) error

type Writer ¶

type Writer struct {
	Pod    corev1.Pod
	Client kubernetes.Interface
}

Writer represents a request to stream a pod's logs and send them to an io.Writer

func NewPodLogsWriter(pod corev1.Pod, cli kubernetes.Interface) *Writer

func (spl *Writer) Multiple(
	ctx context.Context,
	opts *corev1.PodLogOptions,
	writerConstructor writerConstructor,
	filePathGenerator func(string) string,
) error

func (spl *Writer) Single(ctx context.Context, writer io.Writer, opts *corev1.PodLogOptions) (err error)