Package redis.clients.jedis

Examples of redis.clients.jedis.ShardedJedisPool$ShardedJedisFactory

231
232
233
234
235
236
237
238
239
240
241
242
243
    "redis://:foobared@localhost:6380")));
  shards.add(new JedisShardInfo(new URI(
    "redis://:foobared@localhost:6379")));

  GenericObjectPoolConfig redisConfig = new GenericObjectPoolConfig();
  ShardedJedisPool pool = new ShardedJedisPool(redisConfig, shards);

  Jedis[] jedises = pool.getResource().getAllShards()
    .toArray(new Jedis[2]);

  Jedis jedis = jedises[0];
  assertEquals("PONG", jedis.ping());
  assertEquals("bar", jedis.get("foo"));
View Full Code Here
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
  shards.add(new JedisShardInfo(new URI(
    "redis://:foobared@localhost:6380")));
  shards.add(new JedisShardInfo(new URI(
    "redis://:foobared@localhost:6379")));

  ShardedJedisPool pool = new ShardedJedisPool(config, shards);

  ShardedJedis jedis = pool.getResource();
  jedis.set("pipelined", String.valueOf(0));
  jedis.set("pipelined2", String.valueOf(0));

  ShardedJedisPipeline pipeline = jedis.pipelined();

  pipeline.incr("pipelined");
  pipeline.incr("pipelined2");

  jedis.resetState();

  pipeline = jedis.pipelined();
  pipeline.incr("pipelined");
  pipeline.incr("pipelined2");
  List<Object> results = pipeline.syncAndReturnAll();

  assertEquals(2, results.size());
  pool.returnResource(jedis);
  pool.destroy();
    }
View Full Code Here
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
  shards.add(new JedisShardInfo(new URI(
    "redis://:foobared@localhost:6380")));
  shards.add(new JedisShardInfo(new URI(
    "redis://:foobared@localhost:6379")));

  ShardedJedisPool pool = new ShardedJedisPool(config, shards);

  ShardedJedis jedis = pool.getResource();
  try {
      jedis.set("hello", "jedis");
  } finally {
      jedis.close();
  }

  ShardedJedis jedis2 = pool.getResource();
  try {
      assertEquals(jedis, jedis2);
  } finally {
      jedis2.close();
  }
View Full Code Here
49
50
51
52
53
54
55
    super.init(list);
    SolrParams params = SolrParams.toSolrParams( list );
    List<JedisShardInfo> info = loadShardsInfo(params);
    RedisDirectory.FILE_BUFFER_SIZE = params.getInt("fileBufferSize", RedisDirectory.FILE_BUFFER_SIZE);
    log.info(String.format("File buffer size for Redis shards %d...", RedisDirectory.FILE_BUFFER_SIZE));
    pool = new ShardedJedisPool(new GenericObjectPool.Config(), info);
  }
View Full Code Here
151
152
153
154
155
156
157
158
159
       }

       shardInfos.add(shardInfo);
     }

     pool = new ShardedJedisPool(config, shardInfos);
     executor = Executors.newFixedThreadPool(CMBProperties.getInstance().getRedisFillerThreads());
     logger.info("event=initialize_redis pools_size=" + shardInfos.size() + " max_total=" + config.getMaxTotal() + " server_list=" + serverList);
   }
View Full Code Here
133
134
135
136
137
138
139
140
141
142
               shardInfo = new JedisShardInfo(hostPort[0].trim(), Integer.parseInt(hostPort[1].trim()), 4000);
            }
            shardInfos.add(shardInfo);
        }
       
        pool = new ShardedJedisPool(cfg, shardInfos);
        executor = Executors.newFixedThreadPool(CMBProperties.getInstance().getRedisFillerThreads());
        revisibilityExecutor = Executors.newFixedThreadPool(CMBProperties.getInstance().getRedisRevisibleThreads());
        logger.info("event=initialize_redis pools_size=" + shardInfos.size() + " max_total=" + cfg.getMaxTotal() + " server_list=" + serverList);
    }
View Full Code Here
24
25
26
27
28
29
30
    public static final String QUERIES_RESULT = "r";

    private static ShardedJedisPool pool;

    public static void configure(Config config, List<JedisShardInfo> shards) {
        pool = new ShardedJedisPool(config, shards, Hashing.MURMUR_HASH);
    }
View Full Code Here
TOP

Related Classes of redis.clients.jedis.ShardedJedisPool$ShardedJedisFactory

  • com.comcast.cqs.persistence.RedisCachedCassandraPersistence
  • com.comcast.cqs.persistence.RedisSortedSetPersistence
  • mxp.solr.core.RedisDirectoryFactory
  • redis.clients.jedis.tests.ShardedJedisPoolTest
  • redis.seek.Seek
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.