download.go•718 B
package sse
import (
"fmt"
"io"
"github.com/gin-gonic/gin"
"github.com/weibaohui/k8m/pkg/comm/utils/amis"
"k8s.io/klog/v2"
)
func DownloadLog(c *gin.Context, containerName string, stream io.ReadCloser) {
defer func() {
if err := stream.Close(); err != nil {
// 处理关闭流时的错误
klog.V(6).Infof("stream close error:%v", err)
}
}()
name := fmt.Sprintf("%s.log", containerName)
// 设置响应头信息，指定文件下载
c.Writer.Header().Set("Content-Disposition", "attachment; filename="+name)
c.Writer.Header().Set("Content-Type", "text/plain")
// 将日志直接写入响应流
_, err := io.Copy(c.Writer, stream)
if err != nil {
amis.WriteJsonError(c, err)
return
}
}