#405

Committed 16 Apr 2024 05:58AM UTC coverage: 0.0% (-88.9%) from 88.866%

Build # #405

Build Type

push

Committed by

Commit Message

add encoding to fix coverage report

Run Details

0 of 5353 relevant lines covered (0.0%)

0.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/jetcache-support/jetcache-redis/src/main/java/com/alicp/jetcache/redis/RedisCacheBuilder.java

package com.alicp.jetcache.redis;

import com.alicp.jetcache.CacheConfig;
import com.alicp.jetcache.CacheManager;
import com.alicp.jetcache.external.ExternalCacheBuilder;
import com.alicp.jetcache.support.BroadcastManager;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.UnifiedJedis;
import redis.clients.jedis.util.Pool;

/**
 * Created on 2016/10/7.
 *
 * @author huangli
 */
public class RedisCacheBuilder<T extends ExternalCacheBuilder<T>> extends ExternalCacheBuilder<T> {
    public static class RedisCacheBuilderImpl extends RedisCacheBuilder<RedisCacheBuilderImpl> {
    }

    public static RedisCacheBuilderImpl createRedisCacheBuilder() {
        return new RedisCacheBuilderImpl();
    }

    protected RedisCacheBuilder() {
        buildFunc(config -> new RedisCache((RedisCacheConfig) config));
    }

    @Override
    public RedisCacheConfig getConfig() {
        if (config == null) {
            config = new RedisCacheConfig();
        }
        return (RedisCacheConfig) config;
    }

    @Override
    public boolean supportBroadcast() {
        return true;
    }

    @Override
    public BroadcastManager createBroadcastManager(CacheManager cacheManager) {
        CacheConfig c = getConfig().clone();
        return new RedisBroadcastManager(cacheManager, (RedisCacheConfig) c);
    }

    public T jedisPool(Pool<Jedis> pool) {
        getConfig().setJedisPool(pool);
        return self();
    }

    public void setJedisPool(Pool<Jedis> jedisPool) {
        getConfig().setJedisPool(jedisPool);
    }

    public T jedis(UnifiedJedis jedis) {
        getConfig().setJedis(jedis);
        return self();
    }

    public void setJedis(UnifiedJedis jedis) {
        getConfig().setJedis(jedis);
    }

    public T readFromSlave(boolean readFromSlave) {
        getConfig().setReadFromSlave(readFromSlave);
        return self();
    }

    public void setReadFromSlave(boolean readFromSlave) {
        getConfig().setReadFromSlave(readFromSlave);
    }

    public T jedisSlavePools(Pool<Jedis>... jedisSlavePools) {
        getConfig().setJedisSlavePools(jedisSlavePools);
        return self();
    }

    public void setJedisSlavePools(Pool<Jedis>... jedisSlavePools) {
        getConfig().setJedisSlavePools(jedisSlavePools);
    }

    public T slaves(UnifiedJedis... slaves) {
        getConfig().setSlaves(slaves);
        return self();
    }

    public void setSlaves(UnifiedJedis... slaves) {
        getConfig().setSlaves(slaves);
    }

    public T slaveReadWeights(int... slaveReadWeights) {
        getConfig().setSlaveReadWeights(slaveReadWeights);
        return self();
    }

    public void setSlaveReadWeights(int... slaveReadWeights) {
        getConfig().setSlaveReadWeights(slaveReadWeights);
    }

}

1	package com.alicp.jetcache.redis;
2
3	import com.alicp.jetcache.CacheConfig;
4	import com.alicp.jetcache.CacheManager;
5	import com.alicp.jetcache.external.ExternalCacheBuilder;
6	import com.alicp.jetcache.support.BroadcastManager;
7	import redis.clients.jedis.Jedis;
8	import redis.clients.jedis.UnifiedJedis;
9	import redis.clients.jedis.util.Pool;
10
11	/**
12	* Created on 2016/10/7.
13	*
14	* @author huangli
15	*/
16	public class RedisCacheBuilder<T extends ExternalCacheBuilder<T>> extends ExternalCacheBuilder<T> {
17	public static class RedisCacheBuilderImpl extends RedisCacheBuilder<RedisCacheBuilderImpl> {	×
18	}
19
20	public static RedisCacheBuilderImpl createRedisCacheBuilder() {
21	return new RedisCacheBuilderImpl();	×
22	}
23
24	protected RedisCacheBuilder() {	×
25	buildFunc(config -> new RedisCache((RedisCacheConfig) config));	×
26	}	×
27
28	@Override
29	public RedisCacheConfig getConfig() {
30	if (config == null) {	×
31	config = new RedisCacheConfig();	×
32	}
33	return (RedisCacheConfig) config;	×
34	}
35
36	@Override
37	public boolean supportBroadcast() {
38	return true;	×
39	}
40
41	@Override
42	public BroadcastManager createBroadcastManager(CacheManager cacheManager) {
43	CacheConfig c = getConfig().clone();	×
44	return new RedisBroadcastManager(cacheManager, (RedisCacheConfig) c);	×
45	}
46
47	public T jedisPool(Pool<Jedis> pool) {
48	getConfig().setJedisPool(pool);	×
49	return self();	×
50	}
51
52	public void setJedisPool(Pool<Jedis> jedisPool) {
53	getConfig().setJedisPool(jedisPool);	×
54	}	×
55
56	public T jedis(UnifiedJedis jedis) {
57	getConfig().setJedis(jedis);	×
58	return self();	×
59	}
60
61	public void setJedis(UnifiedJedis jedis) {
62	getConfig().setJedis(jedis);	×
63	}	×
64
65	public T readFromSlave(boolean readFromSlave) {
66	getConfig().setReadFromSlave(readFromSlave);	×
67	return self();	×
68	}
69
70	public void setReadFromSlave(boolean readFromSlave) {
71	getConfig().setReadFromSlave(readFromSlave);	×
72	}	×
73
74	public T jedisSlavePools(Pool<Jedis>... jedisSlavePools) {
75	getConfig().setJedisSlavePools(jedisSlavePools);	×
76	return self();	×
77	}
78
79	public void setJedisSlavePools(Pool<Jedis>... jedisSlavePools) {
80	getConfig().setJedisSlavePools(jedisSlavePools);	×
81	}	×
82
83	public T slaves(UnifiedJedis... slaves) {
84	getConfig().setSlaves(slaves);	×
85	return self();	×
86	}
87
88	public void setSlaves(UnifiedJedis... slaves) {
89	getConfig().setSlaves(slaves);	×
90	}	×
91
92	public T slaveReadWeights(int... slaveReadWeights) {
93	getConfig().setSlaveReadWeights(slaveReadWeights);	×
94	return self();	×
95	}
96
97	public void setSlaveReadWeights(int... slaveReadWeights) {
98	getConfig().setSlaveReadWeights(slaveReadWeights);	×
99	}	×
100
101	}

alibaba / jetcache / #405

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous