Merge branch 'main' of github.com:flashcatcloud/categraf

conf/logs.toml

@@ -19,17 +19,17 @@ run_path = "/opt/categraf/run"
 open_files_limit = 100
 ## 定期扫描目录下是否有新增日志
 scan_period = 10
-##
-frame_size = 10
+## udp 读buffer的大小
+frame_size = 9000
 ##
 collect_container_all = true
   ## 全局的处理规则
   [[logs.Processing_rules]]
   ## 单个日志采集配置
   [[logs.items]]
-  ## file/journald
+  ## file/journald/tcp/udp
   type = "file"
-  ## type=file时 path必填，type=journald时 port必填
+  ## type=file时 path必填，type=journald/tcp/udp时 port必填
   path = "/opt/tomcat/logs/*.txt"
   source = "tomcat"
   service = "my_service"

logs/diagnostic/message_receiver.go

@@ -7,10 +7,10 @@ package diagnostic
 
 import (
 	"fmt"
-	"os"
 	"sync"
 	"time"
 
+	coreconfig "flashcat.cloud/categraf/config"
 	logsconfig "flashcat.cloud/categraf/config/logs"
 	"flashcat.cloud/categraf/logs/message"
 )
@@ -137,10 +137,7 @@ func shouldHandleMessage(m *message.Message, filters *Filters) bool {
 }
 
 func formatMessage(m *message.Message, redactedMsg []byte) string {
-	hostname, err := os.Hostname()
-	if err != nil {
-		hostname = "unknown"
-	}
+	hostname := coreconfig.Config.GetHostname()
 
 	ts := time.Now().UTC()
 	if !m.Timestamp.IsZero() {

logs/message/message.go

@@ -6,9 +6,9 @@
 package message
 
 import (
-	"os"
 	"time"
 
+	coreconfig "flashcat.cloud/categraf/config"
 	logsconfig "flashcat.cloud/categraf/config/logs"
 )
 
@@ -78,14 +78,5 @@ func (m *Message) GetLatency() int64 {
 
 // GetHostname returns the hostname to applied the given log message
 func (m *Message) GetHostname() string {
-	if m.Lambda != nil {
-		return m.Lambda.ARN
-	}
-	hostname, err := os.Hostname()
-	if err != nil {
-		// this scenario is not likely to happen since
-		// the agent cannot start without a hostname
-		hostname = "unknown"
-	}
-	return hostname
+	return coreconfig.Config.GetHostname()
 }

logs/processor/json.go

@@ -25,8 +25,8 @@ type jsonPayload struct {
 	Message   string `json:"message"`
 	Status    string `json:"status"`
 	Timestamp int64  `json:"timestamp"`
-	Hostname  string `json:"hostname"`
-	Service   string `json:"service"`
+	Hostname  string `json:"agent_hostname"`
+	Service   string `json:"fcservice"`
 	Source    string `json:"fcsource"`
 	Tags      string `json:"fctags"`
 }