jrecursive

create circuit mv;
use mv;

create channel mjm;
create device mjpeg-channel as channeler {"channel":"mjm"};

create device mjpeg-5 as mjpeg-reader {"url":"http://155.41.145.37/mjpg/video.mjpg"};
create wire wire-7 from mjpeg-5.images to mjpeg-channel.data;

create device keypoints-1 as motion-vectors {};

jrecursive

create circuit mjpeg;
use mjpeg;

create device mjpeg-1 as mjpeg-reader {"url":"http://155.41.209.57/image"};
create channel mjm;
create device mjpeg-channel as channeler {"channel":"mjm"};
create wire wire-1 from mjpeg-1.images to mjpeg-channel.data;

create device mjpeg-2 as mjpeg-reader {"url":"http://sciencecentercam.fas.harvard.edu/axis-cgi/mjpg/video.cgi?camera=1&resolution=704x480&1366356887565"};
create wire wire-2 from mjpeg-2.images to mjpeg-channel.data;

jrecursive

create circuit test;
use test;

create channel ch1;
create channel ch2;
create channel metrics;

create channel tweets;
create device tweeter-1 as tweeter {"filters":[ "putin", "ukraine", "crimea" ]};
create device tweet-channel as channeler {"channel":"tweets"};

jrecursive

// example breadboard script
//
// the logic behind http://thinkdifferent.ly/stuff/breadboard7.mp4
//
// this same script is generated if you wire your circuit in the UI, but
//  i thought it would be interesting to share how to create circuits from
//  the underlying script (the UI issues these same commands).

// there are a few basic concepts: devices, wires, and channels.  devices
//  are data stream sources, functions, and sinks.  every device has zero

jrecursive

"gadata" : {
    "programs" : [ {
      "generation" : 0,
      "t" : 1369013123711,
      "improvement" : 1.0,
      "velocity" : 0.013888888888888888,
      "program" : [ {
        "position" : 0,
        "shift" : 0
      }, {

jrecursive

INFO: [0:1369008514] optimize: best fitness so far: 0.0

INFO: [0] program: ["[0 : 0]","[1 : 0]","[2 : 0]","[3 : -1]","[4 : 0]","[5 : 0]","[6 : -5]","[7 : 0]","[8 : 0]","[9 : 0]","[10 : 0]","[11 : 0]","[12 : 0]","[13 : 0]","[14 : 0]","[15 : 0]","[16 : 0]","[17 : 0]","[18 : 0]","[19 : 0]"]

INFO: [7:1369008515] optimize: best fitness so far: 52.37442288104053

INFO: [7] program: ["[0 : 0]","[1 : 7]","[2 : 0]","[3 : -1]","[4 : 0]","[5 : 1]","[6 : -5]","[7 : 0]","[8 : 2]","[9 : -2]","[10 : 6]","[11 : 0]","[12 : -1]","[13 : -1]","[14 : 0]","[15 : 7]","[16 : 4]","[17 : 0]","[18 : 0]","[19 : -7]"]

INFO: [8:1369008515] optimize: best fitness so far: 52.67826903488668

jrecursive

ParametricPlot[Evaluate[{{6497/13-1/4 Sin[11/9-(2507 t)/7]-1/7 Sin[1/6-(2375 t)/7]-1/8 Sin[5/9-333 t]-1/4 Sin[7/15-(2375 t)/9]-1/4 Sin[17/12-(3349 t)/13]-4/7 Sin[6/13-(5391 t)/22]-13/27 Sin[14/11-(3217 t)/16]-14/13 Sin[14/9-(377 t)/2]-9/5 Sin[5/14-(1244 t)/9]-10/9 Sin[1/4-(377 t)/5]-16/7 Sin[3/8-(553 t)/11]-31/8 Sin[1/8-(377 t)/10]+616/3 Sin[40/9+(44 t)/7]+89/18 Sin[35/8+(88 t)/7]+145/8 Sin[49/12+(132 t)/7]+174/25 Sin[7/6+(201 t)/8]+36/7 Sin[63/25+(377 t)/12]+64/7 Sin[39/11+(1627 t)/37]+3/7 Sin[48/13+(509 t)/9]+11/3 Sin[23/6+(377 t)/6]+12/5 Sin[18/5+(553 t)/8]+3/8 Sin[85/28+(1307 t)/16]+24/13 Sin[42/11+(2023 t)/23]+5/7 Sin[23/8+(377 t)/4]+13/8 Sin[7/3+(1307 t)/13]+11/10 Sin[83/21+(1175 t)/11]+11/10 Sin[29/14+(1131 t)/10]+5/11 Sin[19/10+(955 t)/8]+4/5 Sin[9/8+(377 t)/3]+10/21 Sin[29/12+(2111 t)/16]+2/7 Sin[3/4+(3324 t)/23]+3/5 Sin[5/4+(754 t)/5]+9/10 Sin[19/6+(1885 t)/12]+7/13 Sin[23/8+(1797 t)/11]+21/22 Sin[17/18+(1866 t)/11]+5/16 Sin[11/5+(2287 t)/13]+2/11 Sin[3/4+(1640 t)/9]+5/9 Sin[13/9+(1753 t)/9]+5/6 Sin

jrecursive

bucket_coverage(Bucket) ->
    VNodeSelector = allup,
    BucketProps = riak_core_bucket:get_bucket(Bucket),
    NVal = proplists:get_value(n_val, BucketProps),
    PVC = 1,
    ReqId = erlang:phash2(erlang:now()),
    NodeCheckService = riak_kv,
    {Nodes, _} = riak_core_coverage_plan:create_plan(VNodeSelector,
                                                     NVal,
                                                     PVC,