新增日志传输存储类型

package/gamelog/sdk.go

@@ -18,8 +18,9 @@ import (
 )
 
 type sendBody struct {
-	Pid  string  `json:"pid"`
-	Data [][]any `json:"data"`
+	Pid      string  `json:"pid"`
+	Data     [][]any `json:"data"`
+	SaveType int     `json:"save_type" dc:"0=文件存储, 1=kafka存储"`
 }
 
 // todo 游戏日志对象
@@ -41,7 +42,8 @@ type SDKConfig struct {
 	RetryN        int    // 每N次重试
 	ChanSize      int    // 信道大小, 默认1000
 
-	reportN int
+	reportN      int
+	SendSaveType int // 发送存储类型, 默认不设置为0代表文件存储, 1代表走kafka可实同步日志
 }
 
 type SDK struct {
@@ -379,8 +381,9 @@ func (sdk *SDK) send(logs []GameLog) {
 	}
 	// json化
 	sbody := sendBody{
-		Pid:  sdk.sdkConfig.Pid,
-		Data: data,
+		Pid:      sdk.sdkConfig.Pid,
+		Data:     data,
+		SaveType: sdk.sdkConfig.SendSaveType,
 	}
 	jsonBody, err := json.Marshal(sbody)
 	if err != nil {

package/gamelog/test/gamelog_test.go

@@ -21,8 +21,9 @@ func TestGamelog(t *testing.T) {
 		FlushInterval: 5,            // 上报间隔
 		DiskBakPath:   "gamelog",    // 本地磁盘备份, 用于意外情况下临时保存日志, 请确保该目录持久化(容器内要挂载). 每次启动时或每N次上报时加载到失败队列
 		// 可填
-		RetryN:   2,   // 默认每10次, 上传检查一次磁盘的失败数据
-		ChanSize: 500, // 默认1000, 信道size
+		RetryN:       2,   // 默认每10次, 上传检查一次磁盘的失败数据
+		ChanSize:     500, // 默认1000, 信道size
+		SendSaveType: 1,   // 发送存储类型, 默认不设置为0代表文件存储, 1代表走kafka可实同步日志
 	})
 
 	// 随机测试事件和属性