Function executeGetLogRequest

pkg/podlogs/writer.go:121–139

(ctx context.Context, logRequest *rest.Request, writer io.Writer)

}

func executeGetLogRequest(ctx context.Context, logRequest *rest.Request, writer io.Writer) error {
	logStream, err := logRequest.Stream(ctx)
	if err != nil {
		return fmt.Errorf("when opening the log stream: %w", err)
	}
	defer func() {
		innerErr := logStream.Close()
		if err == nil && innerErr != nil {
			err = fmt.Errorf("when closing the log stream: %w", innerErr)
		}
	}()

	_, err = io.Copy(writer, logStream)
	if err != nil {
		return fmt.Errorf("when copying the log stream to the writer: %w", err)
	}
	_, _ = writer.Write([]byte("\n"))
	return nil
}