Method Multiple

pkg/podlogs/writer.go:96–119

Multiple streams the pod logs, sending each container's stream to a separate writer

(
	ctx context.Context,
	opts *corev1.PodLogOptions,
	writerConstructor writerConstructor,
	filePathGenerator func(string) string,
)

// Multiple streams the pod logs, sending each container's stream to a separate writer
func (spl *Writer) Multiple(
	ctx context.Context,
	opts *corev1.PodLogOptions,
	writerConstructor writerConstructor,
	filePathGenerator func(string) string,
) error {
	if opts.Container != "" {
		return fmt.Errorf("use Single method to handle a single container output")
	}

	for _, container := range spl.Pod.Spec.Containers {
		writer, err := writerConstructor.Create(filePathGenerator(container.Name))
		if err != nil {
			return err
		}
		containerOpts := opts.DeepCopy()
		containerOpts.Container = container.Name

		if err := spl.sendLogsToWriter(ctx, writer, containerOpts); err != nil {
			return err
		}
	}
	return nil
}

func executeGetLogRequest(ctx context.Context, logRequest *rest.Request, writer io.Writer) error {
	logStream, err := logRequest.Stream(ctx)