View gist:7c7d39cbec69cea1e56a
1 2 3 4 5 6 7 8 9 10
WARN jepsen.core - Process 251 indeterminate
java.lang.IllegalArgumentException: Key must be integer
at clojure.lang.APersistentVector.assoc(APersistentVector.java:335)
at clojure.lang.APersistentVector.assoc(APersistentVector.java:18)
at clojure.lang.RT.assoc(RT.java:702)
at clojure.core$assoc.invoke(core.clj:187)
at jepsen.disque$dequeue_BANG_.invoke(disque.clj:200)
at jepsen.disque.Client.invoke_BANG_(disque.clj:225)
at jepsen.core$worker$fn__3132$fn__3133.invoke(core.clj:133)
at jepsen.core$worker$fn__3132.invoke(core.clj:131)
View gist:fc58370111490f8d168f
1 2 3 4 5 6 7
Trying ::1...
Connected to localhost.
Escape character is '^]'.
*12
3
-ERR Protocol error: expected '$', got '3'
Connection closed by foreign host.
View gist:9bde5f5dcee13e95c3c7

Job IDs

Disque jobs are uniquely identified by an ID like the following:

DI0f0c644fd3ccb51c2cedbd47fcb6f312646c993c05a0SQ

Job IDs always start with "DI" and end with "SQ" and are always composed of exactly 48 characters.

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.
Something went wrong with that request. Please try again.