anchor.diff:      iolist_to_binary([<<"/v2/canary-fetch/">>, UUID]);
   api_relative_url(_APIVSN, UUID) when is_binary(UUID) ->
       iolist_to_binary([logplex_app:config(api_endpoint_url, ""), <<"/sessions/">>, UUID]).
  -
  -%% end_chunked_response(Socket) ->
  -%%     gen_tcp:close(Socket),
  -%%     ok.
   
   uri_to_binary(Uri) ->
       iolist_to_binary(ex_uri:encode(Uri)).
  
positive.code:     receive
          {logplex_tail_data, Buffer, Data} ->
              Resp:write_chunk(Data),
              %% gen_tcp:send(Socket, Data),
              tail_loop(Socket, Resp, Buffer, Filters, ChannelId, iolist_size(Data) + BytesSent);
          {tcp_data, Socket, _} ->
              inet:setopts(Socket, [{active, once}]),
  
negative.code:                                            logplex_app:config(no_redis_warning)}];
                       _ -> ?HDR
                   end,
          Header = Header0 ++ [{"connection", "close"}],
          Resp = Req:respond({200, Header, chunked}),
  
          inet:setopts(Socket, [{nodelay, true}, {packet_size, 1024 * 1024}, {recbuf, 1024 * 1024}]),
  
          filter_and_send_chunked_logs(Resp, Logs, Filters, Num),
  
          case {proplists:get_value(<<"tail">>, Data, tail_not_requested),
                logplex_channel:lookup_flag(no_tail, ChannelId)} of
              {tail_not_requested, _} ->
                  Resp:write_chunk(<<>>);
              {_, no_tail} ->
                  Resp:write_chunk(no_tail_warning()),
                  Resp:write_chunk(<<>>);
              _ ->
  