ayo/tavern
6
0
Fork 2
Code Issues Pull Requests Projects Releases Wiki Activity

로비 ccu metric 가져옴

Browse Source
This commit is contained in:
mountain
2023-11-28 01:18:50 +09:00
parent b20de99db2
commit 723bd44079
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/tavern.go
View File

@ -79,8 +79,10 @@ func New(context context.Context, wsh *wshandler.WebsocketHandler) (*Tavern, err
return tv, nil return tv, nil
} }
var ccu = metric.MetricWriterNil
func (tv *Tavern) Cleanup() { func (tv *Tavern) Cleanup() {
metric.ConcurrentUser.Set(0) ccu.Set(0)
tv.mongoClient.Close() tv.mongoClient.Close()
} }
@ -118,6 +120,7 @@ func (tv *Tavern) prepare(ctx context.Context) error {
tv.httpApiBorker.AddHandler(gocommon.MakeHttpApiHandler(instant, "instant")) tv.httpApiBorker.AddHandler(gocommon.MakeHttpApiHandler(instant, "instant"))
tv.wsh.AddHandler(wshandler.MakeWebsocketApiHandler(instant, "instant")) tv.wsh.AddHandler(wshandler.MakeWebsocketApiHandler(instant, "instant"))
ccu = metric.NewMetric(metric.MetricGuage, "concurrent_user", "concurrent user count", map[string]string{"game": "lobby"})
return nil return nil
} }
@ -138,7 +141,7 @@ func (tv *Tavern) LeaveChannel(ctx wshandler.ApiCallContext) {
} }
func (tv *Tavern) ClientConnected(conn *websocket.Conn, callby *wshandler.Sender) { func (tv *Tavern) ClientConnected(conn *websocket.Conn, callby *wshandler.Sender) {
metric.ConcurrentUser.Add(1) ccu.Add(1)
tv.redison.Del(tv.redison.Context(), callby.Accid.Hex()) tv.redison.Del(tv.redison.Context(), callby.Accid.Hex())
_, err := tv.redison.JSONSet(callby.Accid.Hex(), "$", bson.M{"_ts": time.Now().UTC().Unix()}) _, err := tv.redison.JSONSet(callby.Accid.Hex(), "$", bson.M{"_ts": time.Now().UTC().Unix()})
if err != nil { if err != nil {
@ -147,7 +150,7 @@ func (tv *Tavern) ClientConnected(conn *websocket.Conn, callby *wshandler.Sender
} }
func (tv *Tavern) ClientDisconnected(msg string, callby *wshandler.Sender) { func (tv *Tavern) ClientDisconnected(msg string, callby *wshandler.Sender) {
metric.ConcurrentUser.Add(-1) ccu.Add(-1)
tv.redison.Del(tv.redison.Context(), callby.Accid.Hex()).Result() tv.redison.Del(tv.redison.Context(), callby.Accid.Hex()).Result()
} }