-module(eredis_streams_tools).

-export([failover_pending_timeout/1, now_mcs/0, build_conn/4]).

failover_pending_timeout(#{workers := #{failover_pending_timeout := Timeout}} = _Params) -> Timeout;
failover_pending_timeout(_) -> 121000.

now_mcs() -> os:system_time(microsecond).

build_conn(Pool, Stream, Group, Opts) ->
  #{kind => eredis_streams, pool => Pool, stream => Stream, group => Group, opts => Opts}.