32 lines
592 B
Go
32 lines
592 B
Go
|
package core
|
||
|
|
|
||
|
|
import (
|
||
|
|
"bytes"
|
||
|
|
"fmt"
|
||
|
|
"net/http"
|
||
|
|
"os"
|
||
|
|
|
||
|
|
logrus "github.com/sirupsen/logrus"
|
||
|
|
)
|
||
|
|
|
||
|
|
type WriteLog struct {
|
||
|
|
Content []byte
|
||
|
|
Tag string
|
||
|
|
}
|
||
|
|
|
||
|
|
func (wg *WriteLog) Process(cr *Core) error {
|
||
|
|
go func() {
|
||
|
|
reqBody := bytes.NewBuffer(wg.Content)
|
||
|
|
cr.Env = os.Getenv("GO_ENV")
|
||
|
|
cr.FluentBitUrl = os.Getenv("TEXUS_FluentBitUrl")
|
||
|
|
fullUrl := "http://" + cr.FluentBitUrl + "/" + wg.Tag
|
||
|
|
res, err := http.Post(fullUrl, "application/json", reqBody)
|
||
|
|
|
||
|
|
fmt.Println("requested, response:", fullUrl, string(wg.Content), res)
|
||
|
|
if err != nil {
|
||
|
|
logrus.Error(err)
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return nil
|
||
|
|
}
|