View Source EchoPubSub.Producer.Timers (EchoPubSub v0.2.3)

Schedules the producer's :flush_all: batch flushes, retries and follow-ups. One timer at a time.

Summary

Functions

flush_now(state)

Flushes at once, regardless of batch_interval or a pending timer.

flush_soon(state)

Flushes after batch_interval (at once when 0), unless a flush is already pending.

follow_up(state, node)

Flushes soon if node is still behind: writes that landed while it was registering or mid-delivery were skipped by the flush that ran then.

retry(state)

Flushes again after retry_interval ms following a failure, unless a flush is already pending.

Functions

Link to this function

flush_now(state)

View Source 
@spec flush_now(EchoPubSub.Producer.State.t()) :: EchoPubSub.Producer.State.t()

Flushes at once, regardless of batch_interval or a pending timer.

Link to this function

flush_soon(state)

View Source 
@spec flush_soon(EchoPubSub.Producer.State.t()) :: EchoPubSub.Producer.State.t()

Flushes after batch_interval (at once when 0), unless a flush is already pending.

Link to this function

follow_up(state, node)

View Source 
@spec follow_up(EchoPubSub.Producer.State.t(), node()) ::
  EchoPubSub.Producer.State.t()

Flushes soon if node is still behind: writes that landed while it was registering or mid-delivery were skipped by the flush that ran then.

Link to this function

retry(state)

View Source 
@spec retry(EchoPubSub.Producer.State.t()) :: EchoPubSub.Producer.State.t()

Flushes again after retry_interval ms following a failure, unless a flush is already pending.