From 8f4ffb617d82b8bfd3192f5b0f7958737bdf3224 Mon Sep 17 00:00:00 2001
From: yanghui <yanghui@aiotlink.com>
Date: 星期日, 25 四月 2021 18:52:49 +0800
Subject: [PATCH] add interface
---
logc.go | 32 +++++++++++++++++++++++++-------
1 files changed, 25 insertions(+), 7 deletions(-)
diff --git a/logc.go b/logc.go
index 9a978df..f1c161f 100644
--- a/logc.go
+++ b/logc.go
@@ -2,9 +2,6 @@
import (
"basic.com/valib/bhomebus.git"
- "bytes"
- "net/url"
-
"encoding/json"
"fmt"
uuid "github.com/satori/go.uuid"
@@ -41,16 +38,41 @@
Info string `gorm:"column:info" json:"info"` // 璇︽儏
}
+type LogRegister struct {
+ Nodes []bhomebus.NetNode
+ Topic string
+ Reply *bhomeclient.Reply
+ Payload []byte
+}
+
+type LogReportCallback func(*LogRegister)
+
var (
msgChan chan []byte
bhSock *bhomebus.Socket
pubFn func(nodes []bhomebus.NetNode, topic string, data []byte, milliseconds int) int
ProcName string
ProcID string
+
+ logCallback LogReportCallback
)
func init() {
+}
+
+func Init(flogWriter LogReportCallback, procId string, procName string) bool {
+ msgChan = make(chan []byte, 100)
+ ProcName = procName
+ ProcID = procId
+ logCallback = flogWriter
+ if logCallback == nil {
+ return false
+ }
+
+ go saveLoop()
+
+ return true
}
func InitBySock(sock *bhomebus.Socket, procId string, procName string) bool {
@@ -141,8 +163,4 @@
time.Sleep(10*time.Millisecond)
}
}
-}
-
-func Log(userName, method, path, contentType, module string, body *bytes.Buffer, values url.Values) {
-
}
--
Gitblit v1.8.0