mirror
/
moonstream
kopia lustrzana https://github.com/bugout-dev/moonstream
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Client cache and keep alive from envs

nb-multi
kompotkot 2024-12-13 10:32:55 +00:00
rodzic 1de7b7fa96
commit 82262d2cac
1 zmienionych plików z 15 dodań i 1 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

16
nodebalancer/cmd/nodebalancer/configs.go
Wyświetl plik

@ -48,13 +48,15 @@ var (
NB_HEALTH_CHECK_CALL_TIMEOUT = time.Second * 2
NB_CACHE_CLEANING_INTERVAL = time.Second * 10
NB_CACHE_CLEANING_INTERVAL_RAW = os.Getenv("NB_CACHE_CLEANING_INTERVAL")
NB_CACHE_ACCESS_ID_LIFETIME = int64(120) // 2 minutes
NB_CACHE_ACCESS_ID_SESSION_LIFETIME = int64(600) // 10 minutes
NB_MAX_COUNTER_NUMBER = uint64(10000000)
// Client configuration
NB_CLIENT_NODE_KEEP_ALIVE = int64(5) // How long to store node in hot list for client in seconds
NB_CLIENT_NODE_KEEP_ALIVE = int64(5) // How long to store node in hot list for client in seconds
NB_CLIENT_NODE_KEEP_ALIVE_RAW = os.Getenv("NB_CLIENT_NODE_KEEP_ALIVE")
NB_ACCESS_ID_HEADER = os.Getenv("NB_ACCESS_ID_HEADER")
NB_DATA_SOURCE_HEADER = os.Getenv("NB_DATA_SOURCE_HEADER")
@ -95,6 +97,18 @@ func CheckEnvVarSet() {
for _, o := range strings.Split(MOONSTREAM_CORS_ALLOWED_ORIGINS, ",") {
CORS_WHITELIST_MAP[o] = true
}
cacheCleaningInterval, err := strconv.Atoi(NB_CACHE_CLEANING_INTERVAL_RAW)
if err != nil {
log.Printf("unable to parse environment variable %s as integer and set to default %d, err: %v", NB_CACHE_CLEANING_INTERVAL_RAW, NB_CACHE_CLEANING_INTERVAL, err)
}
NB_CACHE_CLEANING_INTERVAL = time.Duration(cacheCleaningInterval) * time.Second
clientKeepAlive, err := strconv.Atoi(NB_CLIENT_NODE_KEEP_ALIVE_RAW)
if err != nil {
log.Printf("unable to parse environment variable %s as integer and set to default %d, err: %v", NB_CLIENT_NODE_KEEP_ALIVE_RAW, NB_CLIENT_NODE_KEEP_ALIVE, err)
}
NB_CLIENT_NODE_KEEP_ALIVE = int64(clientKeepAlive)
}
// Nodes configuration