stub not implemented api

src/layers/kvs_stream.erl

@@ -107,6 +107,8 @@ add(M,#writer{cache=V1,count=S}=C,Db) ->
     N=sp(sn(M,[]),id(V)), P=sn(V,id(M)), kvs:put([N,P],#kvs{db=Db}),
     C#writer{cache=N,count=S+1}.
 
+cut(Feed) -> cut(Feed, db()).
+cut(_,_) -> ignore.
 remove(Rec,Feed)  -> remove(Rec,Feed,db()).
 remove(_Rec,Feed,Db) ->
    {ok,W=#writer{count=Count}} = kvs:get(writer,Feed,#kvs{db=Db}),

src/stores/kvs_fs.erl

@@ -75,6 +75,8 @@ delete(TableName, Key, _) ->
             file:delete(File);
         {error,X} -> {error,X}
     end.
+delete_range(_,_,_) -> {error, not_found}.
+keys(_,_) -> [].
 
 count(RecordName) -> length(filelib:fold_files(filename:join([dir_name(), RecordName]), "",true, fun(A,Acc)-> [A|Acc] end, [])).
 

src/stores/kvs_mnesia.erl

@@ -47,6 +47,7 @@ delete(Tab, Key, _) ->
         {aborted,Reason} -> {error,Reason};
         {atomic,_Result} -> ok;
         _ -> ok end.
+delete_range(_,_,_) -> {error, not_found}.
 match(Record) -> lists:flatten(many(fun() -> mnesia:match_object(Record) end)).
 index_match(Record, Index) -> lists:flatten(many(fun() -> mnesia:index_match_object(Record, Index) end)).
 count(RecordName) -> mnesia:table_info(RecordName, size).