Skip to content

Commit

Permalink
whitespace
Browse files Browse the repository at this point in the history
  • Loading branch information
Luke Bakken committed Apr 12, 2016
1 parent 398b7f1 commit 89745b8
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
20 changes: 10 additions & 10 deletions src/riakc_ts.erl
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ query_common(Pid, Query, Interpolations, Cover)
QueryText::binary()) -> {ok, Entries::[term()]} | {error, term()} | {'EXIT', any()}.
get_coverage(Pid, Table, QueryText) ->
server_call(Pid,
#tscoveragereq{query = #tsinterpolation{base=iolist_to_binary(QueryText)},
#tscoveragereq{query = #tsinterpolation{base = iolist_to_binary(QueryText)},
replace_cover=undefined,
table=iolist_to_binary(Table)}).

Expand Down Expand Up @@ -122,10 +122,10 @@ put(Pid, Table, ColumnNames, Measurements)
delete(Pid, Table, Key, Options)
when is_pid(Pid), (is_binary(Table) orelse is_list(Table)),
is_list(Key), is_list(Options) ->
Message = #tsdelreq{table =iolist_to_binary(Table),
key =riak_pb_ts_codec:encode_cells_non_strict(Key),
vclock =proplists:get_value(vclock, Options),
timeout=proplists:get_value(timeout, Options)},
Message = #tsdelreq{table = iolist_to_binary(Table),
key = riak_pb_ts_codec:encode_cells_non_strict(Key),
vclock = proplists:get_value(vclock, Options),
timeout = proplists:get_value(timeout, Options)},
_Response = server_call(Pid, Message).


Expand All @@ -145,9 +145,9 @@ delete(Pid, Table, Key, Options)
get(Pid, Table, Key, Options)
when is_pid(Pid), (is_binary(Table) orelse is_list(Table)),
is_list(Key), is_list(Options) ->
Message = #tsgetreq{table =iolist_to_binary(Table),
key =Key,
timeout=proplists:get_value(timeout, Options)},
Message = #tsgetreq{table = iolist_to_binary(Table),
key = Key,
timeout = proplists:get_value(timeout, Options)},

case server_call(Pid, Message) of
{error, OtherError} ->
Expand All @@ -169,8 +169,8 @@ stream_list_keys(Pid, Table, Timeout) when is_integer(Timeout) ->
stream_list_keys(Pid, Table, Options)
when is_pid(Pid), (is_binary(Table) orelse is_list(Table)), is_list(Options) ->
ReqTimeout = proplists:get_value(timeout, Options),
Req = #tslistkeysreq{table=iolist_to_binary(Table),
timeout=ReqTimeout},
Req = #tslistkeysreq{table = iolist_to_binary(Table),
timeout = ReqTimeout},
ReqId = riakc_pb_socket:mk_reqid(),
gen_server:call(Pid, {req, Req, ?DEFAULT_PB_TIMEOUT, {ReqId, self()}}, infinity).

Expand Down
4 changes: 2 additions & 2 deletions src/riakc_ts_query_operator.erl
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@

serialize(QueryText, Interpolations) ->
Content = #tsinterpolation{
base=iolist_to_binary(QueryText),
interpolations=serialize_interpolations(Interpolations)},
base = iolist_to_binary(QueryText),
interpolations = serialize_interpolations(Interpolations)},
#tsqueryreq{query = Content}.

serialize_interpolations(Interpolations) ->
Expand Down

0 comments on commit 89745b8

Please sign in to comment.