@@ -102,19 +102,17 @@ func main() {
102102 return octrace .StartSpan (ctx , name )
103103 })
104104 redisCacheClient := getCacheRedis (ctx , cfg )
105- redisBetaCacheClient := getBetaCacheRedis (ctx , cfg )
106105 experimenter := cmdconfig .Experimenter (ctx , cfg , expg , reporter )
107106 server , err := worker .NewServer (cfg , worker.ServerConfig {
108- DB : db ,
109- IndexClient : indexClient ,
110- ProxyClient : proxyClient ,
111- SourceClient : sourceClient ,
112- RedisCacheClient : redisCacheClient ,
113- RedisBetaCacheClient : redisBetaCacheClient ,
114- Queue : fetchQueue ,
115- Reporter : reporter ,
116- StaticPath : template .TrustedSourceFromFlag (flag .Lookup ("static" ).Value ),
117- GetExperiments : experimenter .Experiments ,
107+ DB : db ,
108+ IndexClient : indexClient ,
109+ ProxyClient : proxyClient ,
110+ SourceClient : sourceClient ,
111+ RedisCacheClient : redisCacheClient ,
112+ Queue : fetchQueue ,
113+ Reporter : reporter ,
114+ StaticPath : template .TrustedSourceFromFlag (flag .Lookup ("static" ).Value ),
115+ GetExperiments : experimenter .Experiments ,
118116 })
119117 if err != nil {
120118 log .Fatal (ctx , err )
@@ -167,10 +165,6 @@ func getCacheRedis(ctx context.Context, cfg *config.Config) *redis.Client {
167165 return getRedis (ctx , cfg .RedisCacheHost , cfg .RedisCachePort , 0 , 6 * time .Second )
168166}
169167
170- func getBetaCacheRedis (ctx context.Context , cfg * config.Config ) * redis.Client {
171- return getRedis (ctx , cfg .RedisBetaCacheHost , cfg .RedisCachePort , 0 , 6 * time .Second )
172- }
173-
174168func getRedis (ctx context.Context , host , port string , writeTimeout , readTimeout time.Duration ) * redis.Client {
175169 if host == "" {
176170 return nil
0 commit comments