Packages

eredis_streams

0.1.0
0.1.0

Redis Streams Handlers

HexDocs

Current section

Files

Jump to
Readme
1 Version
2 Dependencies
0 Dependants
Files
Activity
eredis_streams src eredis_streams_tools.erl
Raw

src/eredis_streams_tools.erl 

-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}.