4 Commits

Author SHA1 Message Date
Adrian Zuercher
756985882a remove memory and garbage collection infos 2025-08-24 08:33:25 +02:00
Adrian Zuercher
bcb271ea3e change package name to repo name 2025-08-24 08:12:25 +02:00
Adrian Zuercher
9cea173185 remove log file 2025-08-24 08:02:35 +02:00
Adrian Zuercher
59423a7432 new pubsub with wildcard option 2025-08-24 07:59:50 +02:00
8 changed files with 19 additions and 59 deletions

3
.gitignore vendored
View File

@@ -1 +1,2 @@
.DS_Store .DS_Store
*.log

4
go.mod
View File

@@ -1,9 +1,9 @@
module statusServer module gitea.tecamino.com/paadi/statusServer
go 1.24.0 go 1.24.0
require ( require (
gitea.tecamino.com/paadi/pubSub v1.0.1 gitea.tecamino.com/paadi/pubSub v1.0.2
gitea.tecamino.com/paadi/tecamino-dbm v0.1.1 gitea.tecamino.com/paadi/tecamino-dbm v0.1.1
gitea.tecamino.com/paadi/tecamino-json_data v0.1.0 gitea.tecamino.com/paadi/tecamino-json_data v0.1.0
gitea.tecamino.com/paadi/tecamino-logger v0.2.1 gitea.tecamino.com/paadi/tecamino-logger v0.2.1

4
go.sum
View File

@@ -1,5 +1,5 @@
gitea.tecamino.com/paadi/pubSub v1.0.1 h1:Of91JAVaiaqXhzFjm+jwSJipPbST+A1WQz1DEEhLQm4= gitea.tecamino.com/paadi/pubSub v1.0.2 h1:9Q9KLTIHRSjxrTkDyuF8mDYOLkI8DjjPNSnoS2GKflY=
gitea.tecamino.com/paadi/pubSub v1.0.1/go.mod h1:SBPTSD/JQWRbwqsSNoSPhV81IDTreP0TMyvLhmK3P2M= gitea.tecamino.com/paadi/pubSub v1.0.2/go.mod h1:SBPTSD/JQWRbwqsSNoSPhV81IDTreP0TMyvLhmK3P2M=
gitea.tecamino.com/paadi/tecamino-dbm v0.1.1 h1:vAq7mwUxlxJuLzCQSDMrZCwo8ky5usWi9Qz+UP+WnkI= gitea.tecamino.com/paadi/tecamino-dbm v0.1.1 h1:vAq7mwUxlxJuLzCQSDMrZCwo8ky5usWi9Qz+UP+WnkI=
gitea.tecamino.com/paadi/tecamino-dbm v0.1.1/go.mod h1:+tmf1rjPaKEoNeUcr1vdtoFIFweNG3aUGevDAl3NMBk= gitea.tecamino.com/paadi/tecamino-dbm v0.1.1/go.mod h1:+tmf1rjPaKEoNeUcr1vdtoFIFweNG3aUGevDAl3NMBk=
gitea.tecamino.com/paadi/tecamino-json_data v0.1.0 h1:zp3L8qUvkVqzuesQdMh/SgZZZbX3pGD9NYa6jtz+JvA= gitea.tecamino.com/paadi/tecamino-json_data v0.1.0 h1:zp3L8qUvkVqzuesQdMh/SgZZZbX3pGD9NYa6jtz+JvA=

View File

@@ -3,9 +3,10 @@ package handlers
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"statusServer/models"
"sync" "sync"
"gitea.tecamino.com/paadi/statusServer/models"
json_dataModels "gitea.tecamino.com/paadi/tecamino-json_data/models" json_dataModels "gitea.tecamino.com/paadi/tecamino-json_data/models"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"

View File

@@ -3,7 +3,8 @@ package statusServer
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"statusServer/models"
"gitea.tecamino.com/paadi/statusServer/models"
pubSubModels "gitea.tecamino.com/paadi/pubSub/models" pubSubModels "gitea.tecamino.com/paadi/pubSub/models"
logging "gitea.tecamino.com/paadi/tecamino-logger/logging" logging "gitea.tecamino.com/paadi/tecamino-logger/logging"

View File

@@ -1,15 +1,14 @@
package statusServer package statusServer
import ( import (
"context"
"fmt" "fmt"
"net/http" "net/http"
"runtime"
"statusServer/utils"
"strings" "strings"
"time" "time"
"statusServer/models" "gitea.tecamino.com/paadi/statusServer/utils"
"gitea.tecamino.com/paadi/statusServer/models"
logging "gitea.tecamino.com/paadi/tecamino-logger/logging" logging "gitea.tecamino.com/paadi/tecamino-logger/logging"
"github.com/gin-contrib/cors" "github.com/gin-contrib/cors"
@@ -96,56 +95,12 @@ func NewStatusServer(config models.Config) (*StatusServer, error) {
return s, nil return s, nil
} }
// ServeHttp starts the HTTP server and continuously publishes runtime metrics // ServeHttp starts the HTTP server
// (memory allocation + GC count) to the "info" topic.
//
// It blocks until the HTTP server stops. Resources are cleaned up on shutdown: // It blocks until the HTTP server stops. Resources are cleaned up on shutdown:
// PubSub is closed and a shutdown message is logged. // PubSub is closed and a shutdown message is logged.
func (s *StatusServer) ServeHttp() error { func (s *StatusServer) ServeHttp() error {
s.log.Debug("ServeHttp", "start publishing runtime metrics (memory + GC count)") s.log.Debug("ServeHttp", "start publishing runtime metrics (memory + GC count)")
// create cancellable context for metrics goroutine
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
// metrics publisher goroutine
go func() {
for {
var init bool
var m runtime.MemStats
var oldM uint64
var oldGc uint32
var info struct {
Memory uint64 `json:"memory"`
GC uint32 `json:"gc"`
}
ticker := time.NewTicker(500 * time.Millisecond)
defer ticker.Stop()
for {
select {
case <-ctx.Done():
// stop publishing if context is canceled
return
case <-ticker.C:
// read runtime memory statistics
runtime.ReadMemStats(&m)
info.GC = m.NumGC
// publish only when values changed or first run
if oldGc != m.NumGC || oldM != m.Alloc/1024 || !init {
info.Memory = m.Alloc / 1024
s.pubSub.Publish("info", info)
oldGc = m.NumGC
oldM = m.Alloc / 1024
init = true
}
}
}
}
}()
// log startup // log startup
s.log.Info("ServeHttp", fmt.Sprintf("start listening on %s:%d", s.Ip, s.Port)) s.log.Info("ServeHttp", fmt.Sprintf("start listening on %s:%d", s.Ip, s.Port))

View File

@@ -2,7 +2,8 @@ package statusServer
import ( import (
"fmt" "fmt"
"statusServer/handlers"
"gitea.tecamino.com/paadi/statusServer/handlers"
logging "gitea.tecamino.com/paadi/tecamino-logger/logging" logging "gitea.tecamino.com/paadi/tecamino-logger/logging"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"

View File

@@ -1,11 +1,12 @@
package test package test
import ( import (
"statusServer"
"statusServer/models"
"testing" "testing"
"time" "time"
"gitea.tecamino.com/paadi/statusServer"
"gitea.tecamino.com/paadi/statusServer/models"
"gitea.tecamino.com/paadi/tecamino-logger/logging" "gitea.tecamino.com/paadi/tecamino-logger/logging"
) )