Home
last modified time | relevance | path

Searched refs:cluster (Results 1 – 22 of 22) sorted by relevance

/redis-3.2.3/utils/create-cluster/
H A DREADME2 instances configured to run in cluster mode. Its main goal is to allow manual
3 testing in a condition which is not easy to replicate with the Redis cluster
13 To create a cluster, follow this steps:
15 1. Edit create-cluster and change the start / end port, depending on the
17 2. Use "./create-cluster start" in order to run the instances.
18 3. Use "./create-cluster create" in order to execute redis-trib create, so that
19 an actual Redis cluster will be created.
22 In order to stop a cluster:
24 1. Use "./craete-cluster stop" to stop all the instances. After you stopped the instances you can u…
25 2. Use "./create-cluster clean" to remove all the AOF / log files to restat with a clean environmen…
[all …]
H A Dcreate-cluster25 …../../src/redis-server --port $PORT --cluster-enabled yes --cluster-config-file nodes-${PORT}.conf…
57 ../../src/redis-cli -p $PORT cluster nodes | head -30
/redis-3.2.3/src/
H A Dcluster.c402 server.cluster->myself = NULL; in clusterInit()
405 server.cluster->size = 1; in clusterInit()
418 memset(server.cluster->slots,0, sizeof(server.cluster->slots)); in clusterInit()
476 server.cluster->mf_end = 0; in clusterInit()
937 if (max < server.cluster->currentEpoch) max = server.cluster->currentEpoch; in clusterGetMaxEpoch()
2494 if (server.cluster->lastVoteEpoch == server.cluster->currentEpoch) { in clusterSendFailoverAuthIfNeeded()
2562 server.cluster->lastVoteEpoch = server.cluster->currentEpoch; in clusterSendFailoverAuthIfNeeded()
2838 server.cluster->failover_auth_epoch = server.cluster->currentEpoch; in clusterHandleSlaveFailover()
3029 if (server.cluster->mf_end && server.cluster->mf_end < mstime()) { in manualFailoverCheckTimeout()
3514 server.cluster->size = 0; in clusterUpdateState()
[all …]
H A Dredis-trib.rb127 nodes = @r.cluster("nodes").split("\n")
212 @r.cluster("addslots",*new)
271 @r.cluster("nodes").each_line{|l|
463 node.r.cluster("addslots",slot)
474 nodes[0].r.cluster("addslots",slot)
487 target.r.cluster('addslots',slot)
572 owner.r.cluster("addslots",slot)
576 owner.r.cluster("bumpepoch")
596 n.r.cluster('delslots',slot)
601 owner.r.cluster('bumpepoch')
[all …]
H A Ddb.c1243 zslInsert(server.cluster->slots_to_keys,hashslot,key); in slotToKeyAdd()
1250 zslDelete(server.cluster->slots_to_keys,hashslot,key); in slotToKeyDel()
1254 zslFree(server.cluster->slots_to_keys); in slotToKeyFlush()
1255 server.cluster->slots_to_keys = zslCreate(); in slotToKeyFlush()
1266 n = zslFirstInRange(server.cluster->slots_to_keys, &range); in getKeysInSlot()
1284 n = zslFirstInRange(server.cluster->slots_to_keys, &range); in delKeysInSlot()
1297 zskiplist *zsl = server.cluster->slots_to_keys; in countKeysInSlot()
H A DMakefile.dep26 cluster.o: cluster.c server.h fmacros.h config.h solarisfixes.h \
30 cluster.h
35 cluster.h
45 cluster.h
123 rand.h cluster.h ../deps/lua/src/lauxlib.h ../deps/lua/src/lua.h \
136 cluster.h slowlog.h bio.h asciilogo.h
H A DMakefile120 …_hash.o config.o aof.o pubsub.o multi.o debug.o sort.o intset.o syncio.o cluster.o crc16.o endianc…
H A Dserver.h946 struct clusterState *cluster; /* State of the cluster */ member
H A Dscripting.c523 server.cluster->myself) in luaRedisGenericCommand()
H A Dserver.c2392 if (n == NULL || n != server.cluster->myself) { in processCommand()
/redis-3.2.3/tests/cluster/
H A Dcluster.tcl9 set lines [split [R $id cluster nodes] "\r\n"]
47 get_info_field [R $n cluster info] $field
61 R $j cluster addslots {*}[set slots_${j}]
97 R $slave_id cluster replicate [dict get $master_myself id]
122 set cluster [redis_cluster 127.0.0.1:$port]
124 $cluster set key.$j $prefix.$j
127 assert {[$cluster get key.$j] eq "$prefix.$j"}
129 $cluster close
/redis-3.2.3/tests/cluster/tests/
H A D10-manual-failover.tcl33 set cluster [redis_cluster 127.0.0.1:[get_instance_attrib redis 0 port]]
48 $cluster rpush $key $ele
50 $cluster eval {redis.call("rpush",KEYS[1],ARGV[1])} 1 $key $ele
58 if {$j == $numops/2} {R 5 cluster failover}
85 assert {[$cluster lrange $key 0 -1] eq $value}
131 R 5 cluster failover
178 R 5 cluster failover force
H A D03-failover-loop.tcl17 set cluster [redis_cluster 127.0.0.1:[get_instance_attrib redis 0 port]]
54 catch {$cluster set $key:$i $val:$i} err
84 catch {$cluster set $key:$i:2 $val:$i:2} err
103 catch {$cluster get $key:$i} err
105 catch {$cluster get $key:$i:2} err
H A D04-resharding.tcl56 set cluster [redis_cluster 127.0.0.1:[get_instance_attrib redis 0 port]]
95 $cluster rpush $key $ele
97 $cluster eval {redis.call("rpush",KEYS[1],ARGV[1])} 1 $key $ele
118 assert {[$cluster lrange $key 0 -1] eq $value}
136 assert {[$cluster lrange $key 0 -1] eq $value}
H A D11-manual-takeover.tcl28 R 5 cluster failover takeover
29 R 6 cluster failover takeover
30 R 7 cluster failover takeover
H A D05-slave-selection.tcl35 set cluster [redis_cluster 127.0.0.1:[get_instance_attrib redis 0 port]]
39 $cluster set $j $j
55 $cluster set $j $j
/redis-3.2.3/tests/cluster/tests/includes/
H A Dinit-tests.tcl37 R $id cluster reset hard
38 R $id cluster set-config-epoch [expr {$id+1}]
56 R $a cluster meet 127.0.0.1 $b_port
/redis-3.2.3/utils/
H A Dcluster_fail_time.tcl22 set output [exec redis-cli -p $::other_port cluster nodes]
32 set output [exec redis-cli -p $::other_port cluster nodes]
/redis-3.2.3/
H A Druntest-cluster14 $TCLSH tests/cluster/run.tcl $*
H A D00-RELEASENOTES364 src/cluster.c | 2 +-
769 * There was a problem in the way a cluster instance loaded the AOF that
890 tests/cluster/tests/12-replica-migration-2.tcl | 14 +++++++-------
900 with the logic of always allowing, while the cluster is down, commands
905 src/cluster.c | 13 +++++++++++--
916 src/cluster.c | 2 +-
951 tests/cluster/tests/12-replica-migration-2.tcl | 5 ++++-
1148 1/5 of all the cluster slots from master 0 to the other 4 masters and
1174 src/cluster.c | 36 +++++++++++++++++++++++++++++++++++-
1581 src/cluster.c | 8 ++++++--
[all …]
H A DREADME.md12 …l to find in a database, like replication, tunable levels of durability, cluster, high availabilit…
/redis-3.2.3/tests/support/
H A Dcluster.tcl65 set nodes_descr [$r cluster nodes]