|
|
@@ -471,14 +471,14 @@ func main() { |
|
|
|
|
|
|
|
trackerRedisOptions, err := redis.ParseURL(os.Getenv("REDIS_TRACKER")) |
|
|
|
if err != nil { |
|
|
|
log.Panicf("%s", err) |
|
|
|
log.Panicf("invalid REDIS_TRACKER url: %s", err) |
|
|
|
} |
|
|
|
trackerRedisOptions.ReadTimeout = 15 * time.Minute |
|
|
|
trackerRedisClient := redis.NewClient(trackerRedisOptions) |
|
|
|
|
|
|
|
legacyRedisOptions, err := redis.ParseURL(os.Getenv("REDIS_LEGACY")) |
|
|
|
if err != nil { |
|
|
|
log.Panicf("%s", err) |
|
|
|
log.Panicf("invalid REDIS_LEGACY url: %s", err) |
|
|
|
} |
|
|
|
legacyRedisOptions.ReadTimeout = 15 * time.Minute |
|
|
|
legacyRedisClient := redis.NewClient(legacyRedisOptions) |
|
|
@@ -490,6 +490,16 @@ func main() { |
|
|
|
ReadTimeout: 15 * time.Minute, |
|
|
|
}) |
|
|
|
|
|
|
|
if err := trackerRedisClient.Ping(context.Background()).Err(); err != nil { |
|
|
|
log.Panicf("unable to ping tracker redis: %s", err) |
|
|
|
} |
|
|
|
if err := backfeedRedisClient.Ping(context.Background()).Err(); err != nil { |
|
|
|
log.Panicf("unable to ping backfeed redis: %s", err) |
|
|
|
} |
|
|
|
if err := legacyRedisClient.Ping(context.Background()).Err(); err != nil { |
|
|
|
log.Panicf("unable to ping legacy redis: %s", err) |
|
|
|
} |
|
|
|
|
|
|
|
globalBackfeedManager := &GlobalBackfeedManager{ |
|
|
|
ActiveFeeds: map[string]*ProjectBackfeedManager{}, |
|
|
|
ActiveSlugs: map[string]string{}, |
|
|
|