3 Commits
1.0.1 ... 1.0.3

Author SHA1 Message Date
8c1bb695b8 fix: enhance logging to handle empty upstream values
All checks were successful
Release Tag / release (push) Successful in 10s
2025-01-23 11:31:28 -06:00
f58951fd92 fix: removed specific to my dev setup config 2025-01-23 11:31:13 -06:00
70786da8c6 fix: improve logging readability and remove configuration messages
All checks were successful
Release Tag / release (push) Successful in 10s
2025-01-23 11:25:18 -06:00
2 changed files with 7 additions and 14 deletions

6
.vscode/launch.json vendored
View File

@@ -17,8 +17,6 @@
"10G",
"--disk-path",
"tmp/disk",
"--upstream",
"http://192.168.2.88:80",
"--verbose",
],
},
@@ -33,8 +31,6 @@
"10G",
"--disk-path",
"tmp/disk",
"--upstream",
"http://192.168.2.88:80",
"--verbose",
],
},
@@ -47,8 +43,6 @@
"args": [
"--memory",
"1G",
"--upstream",
"http://192.168.2.88:80",
"--verbose",
],
}

View File

@@ -79,18 +79,15 @@ func New(address string, memorySize string, memoryMultiplier int, diskSize strin
//memory only mode - no disk
c.SetSlow(mgc)
logger.Logger.Info().Bool("memory", true).Bool("disk", false).Msg("configuration")
} else if disksize != 0 && memorysize == 0 {
// disk only mode
c.SetSlow(dgc)
logger.Logger.Info().Bool("memory", false).Bool("disk", true).Msg("configuration")
} else if disksize != 0 && memorysize != 0 {
// memory and disk mode
c.SetFast(mgc)
c.SetSlow(dgc)
logger.Logger.Info().Bool("memory", true).Bool("disk", true).Msg("configuration")
} else {
// no memory or disk isn't a valid configuration
logger.Logger.Error().Bool("memory", false).Bool("disk", false).Msg("configuration invalid :( exiting")
@@ -122,15 +119,12 @@ func New(address string, memorySize string, memoryMultiplier int, diskSize strin
}
func (sc *SteamCache) Run() {
logger.Logger.Info().Str("address", sc.address).Str("version", version.Version).Msg("listening")
if sc.upstream != "" {
_, err := http.Get(sc.upstream)
if err != nil {
logger.Logger.Error().Err(err).Str("upstream", sc.upstream).Msg("Failed to connect to upstream server")
os.Exit(1)
}
logger.Logger.Info().Str("upstream", sc.upstream).Msg("connected")
}
sc.mu.Lock()
@@ -161,8 +155,12 @@ func (sc *SteamCache) LogStats() {
defer sc.mu.Unlock()
if sc.dirty {
logger.Logger.Info().Msg("") // empty line to separate log entries for better readability
up := sc.upstream
if up == "" {
up = "{host in request}"
}
logger.Logger.Info().Str("address", sc.address).Str("version", version.Version).Str("upstream", up).Msg("listening")
if sc.memory != nil { // only log memory if memory is enabled
lifetimeBytes, lifetimeFiles, reclaimedBytes, deletedFiles, gcTime := sc.memorygc.Stats()
@@ -206,12 +204,13 @@ func (sc *SteamCache) LogStats() {
logger.Logger.Info().
Str("alloc", units.HumanSize(float64(m.Alloc))).
Str("sys", units.HumanSize(float64(m.Sys))).
Msg("go_gc")
Msg("app_gc")
logger.Logger.Info().
Str("hitrate", fmt.Sprintf("%.2f%%", sc.hits.Avg()*100)).
Msg("cache")
logger.Logger.Info().Msg("") // empty line to separate log entries for better readability
sc.dirty = false
}
}