Compare commits
3 Commits
1.0.1
...
8c1bb695b8
| Author | SHA1 | Date | |
|---|---|---|---|
| 8c1bb695b8 | |||
| f58951fd92 | |||
| 70786da8c6 |
6
.vscode/launch.json
vendored
6
.vscode/launch.json
vendored
@@ -17,8 +17,6 @@
|
|||||||
"10G",
|
"10G",
|
||||||
"--disk-path",
|
"--disk-path",
|
||||||
"tmp/disk",
|
"tmp/disk",
|
||||||
"--upstream",
|
|
||||||
"http://192.168.2.88:80",
|
|
||||||
"--verbose",
|
"--verbose",
|
||||||
],
|
],
|
||||||
},
|
},
|
||||||
@@ -33,8 +31,6 @@
|
|||||||
"10G",
|
"10G",
|
||||||
"--disk-path",
|
"--disk-path",
|
||||||
"tmp/disk",
|
"tmp/disk",
|
||||||
"--upstream",
|
|
||||||
"http://192.168.2.88:80",
|
|
||||||
"--verbose",
|
"--verbose",
|
||||||
],
|
],
|
||||||
},
|
},
|
||||||
@@ -47,8 +43,6 @@
|
|||||||
"args": [
|
"args": [
|
||||||
"--memory",
|
"--memory",
|
||||||
"1G",
|
"1G",
|
||||||
"--upstream",
|
|
||||||
"http://192.168.2.88:80",
|
|
||||||
"--verbose",
|
"--verbose",
|
||||||
],
|
],
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -79,18 +79,15 @@ func New(address string, memorySize string, memoryMultiplier int, diskSize strin
|
|||||||
//memory only mode - no disk
|
//memory only mode - no disk
|
||||||
|
|
||||||
c.SetSlow(mgc)
|
c.SetSlow(mgc)
|
||||||
logger.Logger.Info().Bool("memory", true).Bool("disk", false).Msg("configuration")
|
|
||||||
} else if disksize != 0 && memorysize == 0 {
|
} else if disksize != 0 && memorysize == 0 {
|
||||||
// disk only mode
|
// disk only mode
|
||||||
|
|
||||||
c.SetSlow(dgc)
|
c.SetSlow(dgc)
|
||||||
logger.Logger.Info().Bool("memory", false).Bool("disk", true).Msg("configuration")
|
|
||||||
} else if disksize != 0 && memorysize != 0 {
|
} else if disksize != 0 && memorysize != 0 {
|
||||||
// memory and disk mode
|
// memory and disk mode
|
||||||
|
|
||||||
c.SetFast(mgc)
|
c.SetFast(mgc)
|
||||||
c.SetSlow(dgc)
|
c.SetSlow(dgc)
|
||||||
logger.Logger.Info().Bool("memory", true).Bool("disk", true).Msg("configuration")
|
|
||||||
} else {
|
} else {
|
||||||
// no memory or disk isn't a valid configuration
|
// no memory or disk isn't a valid configuration
|
||||||
logger.Logger.Error().Bool("memory", false).Bool("disk", false).Msg("configuration invalid :( exiting")
|
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() {
|
func (sc *SteamCache) Run() {
|
||||||
logger.Logger.Info().Str("address", sc.address).Str("version", version.Version).Msg("listening")
|
|
||||||
|
|
||||||
if sc.upstream != "" {
|
if sc.upstream != "" {
|
||||||
_, err := http.Get(sc.upstream)
|
_, err := http.Get(sc.upstream)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Logger.Error().Err(err).Str("upstream", sc.upstream).Msg("Failed to connect to upstream server")
|
logger.Logger.Error().Err(err).Str("upstream", sc.upstream).Msg("Failed to connect to upstream server")
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
logger.Logger.Info().Str("upstream", sc.upstream).Msg("connected")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
sc.mu.Lock()
|
sc.mu.Lock()
|
||||||
@@ -161,8 +155,12 @@ func (sc *SteamCache) LogStats() {
|
|||||||
defer sc.mu.Unlock()
|
defer sc.mu.Unlock()
|
||||||
if sc.dirty {
|
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
|
if sc.memory != nil { // only log memory if memory is enabled
|
||||||
lifetimeBytes, lifetimeFiles, reclaimedBytes, deletedFiles, gcTime := sc.memorygc.Stats()
|
lifetimeBytes, lifetimeFiles, reclaimedBytes, deletedFiles, gcTime := sc.memorygc.Stats()
|
||||||
|
|
||||||
@@ -206,12 +204,13 @@ func (sc *SteamCache) LogStats() {
|
|||||||
logger.Logger.Info().
|
logger.Logger.Info().
|
||||||
Str("alloc", units.HumanSize(float64(m.Alloc))).
|
Str("alloc", units.HumanSize(float64(m.Alloc))).
|
||||||
Str("sys", units.HumanSize(float64(m.Sys))).
|
Str("sys", units.HumanSize(float64(m.Sys))).
|
||||||
Msg("go_gc")
|
Msg("app_gc")
|
||||||
|
|
||||||
logger.Logger.Info().
|
logger.Logger.Info().
|
||||||
Str("hitrate", fmt.Sprintf("%.2f%%", sc.hits.Avg()*100)).
|
Str("hitrate", fmt.Sprintf("%.2f%%", sc.hits.Avg()*100)).
|
||||||
Msg("cache")
|
Msg("cache")
|
||||||
|
|
||||||
|
logger.Logger.Info().Msg("") // empty line to separate log entries for better readability
|
||||||
sc.dirty = false
|
sc.dirty = false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user