chinnurtb

-module(twitter_stream).
-author("gdamjan@gmail.com").

%% Depends on:
%%  ibrowse for http
%%  couchbeam for couchbeam_json_stream (a fork of damienkatz json_stream_parse)
%%  mochiweb for mochiweb_util:urlencode

-export([start/0]).

chinnurtb

-module(rest).

-include("/opt/local/lib/erlang/lib/stdlib-1.18.2/include/qlc.hrl").
-include("/opt/local/lib/yaws/include/yaws_api.hrl").

-export([out/1, addAirport/4, handle/2 ]).

-define(RECORD_TYPE, airport).
-define(RECORD_KEY_FIELD, code).

chinnurtb

-module(listcask).
-export([list_keys/1]).

list_keys(Vnode) ->

        Fold_data = fun(Handle) ->
            FoldFun = fun(Key, _Ts, _PosInfo, {ok,Acc}) -> {ok,[binary_to_term(Key) | Acc]} end,
            try bitcask_fileops:fold_keys(Handle, FoldFun, {ok,[]}, datafile) of
                {ok,A} -> A;
		{error,E} -> {error, E}

chinnurtb

#!/bin/bash
# ERL_BIN, RIAK_LIB, and BUCKET_LIB can be defaulted here or set
#  in the environment 
#
# Path to the erl binary provided by Riak
ERL_BIN=${ERL_BIN:-"/usr/lib64/riak/erts-5.8.4/bin/erl"}

# Path to riak libraries
RIAK_LIB=${ERL_BIN:-"/usr/lib64/riak/lib"}

chinnurtb

handle_call({lookup_popular_replies, TweetId, AuthorId}, _From, #state{client=Client} = State) ->
  % reduce fun to get valid tweet keys in tweet response bucket phase 3
  Fun = make_local_fun("fun(O, _) -> 
    lists:foldl(fun
      ([LinkedTweet = <<Id:128>>, <<Val:128>>, <<\"reply\">>], Acc) ->
        [{{<<\"tweet_responses_bucket\">>, LinkedTweet}, {Id, Val}} | Acc];
      ({{<<\"tweet_responses_bucket\">>, _}, _} = PreviousPass, Acc) ->
        [PreviousPass | Acc];
      (_, Acc) ->
        Acc

chinnurtb

%% -------------------------------------------------------------------
%%
%% pb_status_monitor: PoolBoy pool monitor
%%
%% Copyright (c) 2013 Basho Technologies, Inc. All Rights Reserved.
%%
%% This file is provided to you under the Apache License,
%% Version 2.0 (the "License"); you may not use this file
%% except in compliance with the License.  You may obtain
%% a copy of the License at

chinnurtb

%% -------------------------------------------------------------------
%%
%% basho_bench: Benchmarking Suite
%%
%% Copyright (c) 2009-2010 Basho Techonologies
%%
%% This file is provided to you under the Apache License,
%% Version 2.0 (the "License"); you may not use this file
%% except in compliance with the License.  You may obtain
%% a copy of the License at

chinnurtb

#!/usr/bin/env escript
%% -*- erlang -*-

-include_lib("kernel/include/file.hrl").
-compile(export_all).
-define(LOG(S), io:format(S)).
-define(LOG(S,A), io:format(S,A)).

main(Dirs) ->
    CodePath = case os:getenv("RIAK_LIB") of

chinnurtb

%% -------------------------------------------------------------------
%%
%% riak_csv_etl: etl tools for csv files in Riak
%%
%% Copyright (c) 2011 Bradley Taylor.  All Rights Reserved.
%%
%% This file is provided to you under the Apache License,
%% Version 2.0 (the "License"); you may not use this file
%% except in compliance with the License.  You may obtain
%% a copy of the License at

chinnurtb

%% -------------------------------------------------------------------
%%
%% riak_kv_vnode: VNode Implementation
%%
%% Copyright (c) 2007-2010 Basho Technologies, Inc.  All Rights Reserved.
%%
%% This file is provided to you under the Apache License,
%% Version 2.0 (the "License"); you may not use this file
%% except in compliance with the License.  You may obtain
%% a copy of the License at