anchor.diff:                               {need_auth, fun handle_pool_info_streaming/2, [Id]};
                            ["pools", PoolId, "buckets", Id] ->
                                {need_auth_bucket, fun handle_bucket_info/3, [PoolId, Id]};
  +						 ["pools", PoolId, "bucketsStreaming", Id] ->
  +							 {need_auth_bucket, fun handle_bucket_info_streaming/3, [PoolId, Id]};
                            ["pools", PoolId, "buckets", Id, "stats"] ->
                                {need_auth, fun handle_bucket_stats/3, [PoolId, Id]};
                            ["alerts"] ->
  
positive.code: handle_pool_info_streaming(Id, Req) ->
      %% TODO: this shouldn't be timer driven, but rather should register a callback based on some state change in the Erlang OS
      HTTPRes = Req:ok({"application/json; charset=utf-8",
                        [{"Server", "NorthScale menelaus %TODO gitversion%"}],
                        chunked}),
      UserPassword = extract_basic_auth(Req),
      Res = build_pool_info(Id, UserPassword),
  
negative.code:                                                   "/buckets/" ++ Name)},
                               {name, list_to_binary(Name)}]}
                     || Name <- proplists:get_keys(Buckets)],
  	BucketsStreamingInfo = [{struct, [{streamingUri, list_to_binary("/pools/" ++ Id ++
                                                    "/bucketsStreaming/" ++ Name)},
                               {name, list_to_binary(Name)}]}
                     || Name <- proplists:get_keys(Buckets)],
      {struct, [{name, list_to_binary(Id)},
                {nodes, Nodes},
                {buckets, BucketsInfo},
  			  {bucketsStreaming, BucketsStreamingInfo},
                {stats, {struct,
                         [{uri, list_to_binary("/pools/" ++ Id ++ "/stats")}]}}]}.
      %% case Id of
  