an all streams all the time db query wrapper, initially supporting only Riak.