View gist:af0bf0cc40d86b405b26
1 2 3 4 5 6 7 8 9 10
ddd874d serializeJob(), sds concat logic fixed.
8220a01 NEEDJOBS fixes.
0b05ae6 Put the clusterNode name as first field.
69922f2 Federation: WIP, a few fixes.
a096b52 Federation: clusterSendYourJobs() WIP.
b9ba68c Federation: some API changes needed for YOURJOBS + more.
256fee3 Initially set queue atime to current unix time.
f359e2f Debugging printf() removed from needJobsForQueue().
6b1a575 Federation: more fixes to NEEDJOBS. Still WIP.
58e130f Federation: a few fixes to NEEDJOBS related functions.
View gist:4ad573085c40f98bfcba
1 2 3 4 5 6 7 8
./disque
127.0.0.1:7711> qlen myqueue
(integer) 0
127.0.0.1:7711> getjobs from myqueue
1) 1) "myqueue"
2) "DIf6c5b55b33c9cc2220740102a1935080e4e6863905a0SQ"
3) "myjob"
(4.01s)
View gist:759d189e80220742a4e3
1 2
set foo '{"some_field":"1"}'
eval "return cjson.decode(redis.call('get','foo'))['some_field']" 0
View xmas.c
1 2 3 4 5 6 7 8 9 10
 
#include <stdio.h>
#include <stdlib.h>
int
main()
{int h=9,
d=0,x;while
(h--){for(x=0;
x<39;x++){int a=x
-6;if(a<0)a=-a;printf
View gist:5bd49d78efffda05c3b2
1 2 3 4 5 6 7 8 9 10
127.0.0.1:7711> show DI0f0c644f9970a46cd1b2ce2ead31a30d8ad981d005a0SQ
1) "id"
2) "DI0f0c644f9970a46cd1b2ce2ead31a30d8ad981d005a0SQ"
3) "queue"
4) "myqueue"
5) "state"
6) "queued"
7) "repl"
8) (integer) 3
9) "ttl"
View gist:883ac85fa9d9fa80f74a
1 2 3 4 5 6
dictForeach(d,entry)
printf("%s -> %s\n", dictGetKey(entry), dictGetVal(entry));
dictForeach(d2,entry2)
printf("* %s\n", dictGetKey(entry2));
dictEnd
dictEnd
View gist:d72d58fbcdb278dda0e2
1 2 3 4 5 6 7 8 9 10
127.0.0.1:6379> config set latency-monitor-threshold 10
OK
127.0.0.1:6379> debug sleep .1
OK
127.0.0.1:6379> debug sleep .2
OK
127.0.0.1:6379> debug sleep .3
OK
127.0.0.1:6379> latency doctor
Dave, I have observed latency spikes in this Redis instance.
View gist:6a1cfab86dfed72c92be
1 2 3 4 5 6 7 8 9 10
$LOAD_PATH.unshift("./lib")
 
# This file implements a simple consistency test for Redis (or any other
# Redis environment if you pass a different client object) where a client
# write to the database using INCR in order to increment keys, but actively
# remember the value the key should have. Before every write a read is performed
# to check if the value in the database matches the value expected.
#
# In this way this program can check for lost writes, or acknowledged writes
# that were executed.
View gist:668d3bd20be09188bfc8
1 2 3 4 5 6 7 8 9 10
./redis-cli latency graph aof-write
aof-write - high 16 ms, low 1 ms (all time high 16 ms)
--------------------------------------------------------------------------------
_
_####### _#### #_ #o_# |
o__________o_ _oo|||||||| _o____o_ ___ooo__ _______o__|||||#||#|||| | ___ _ ___
|||||||||||||#|||||||||||_#||||||||#||||||||#|||||||||||||||||||||||_|o|||#|#|||
 
44444444444444444444444442222222222222222221111111111111111111111111111111111111
mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm
View gist:02953dbde8a05ea8d9aa
1 2 3 4 5 6 7 8 9 10
$LOAD_PATH.unshift("./lib")
 
require './lib/redis.rb'
 
Sentinels = [{:host => "127.0.0.1", :port => 26380},
{:host => "127.0.0.1", :port => 26381}]
r = Redis.new(:url => "sentinel://mymaster", :sentinels => Sentinels, :role => :master)
r.ping
(0..1000000).each{|i|
begin
Something went wrong with that request. Please try again.