View Source Hedgex.CaptureConsumer (hedgex v0.3.4)

Summary

Types

options()
state()

Functions

handle_events(events, from, state)

Callback implementation for GenStage.handle_events/3.

handle_info(atom, state)

Callback implementation for GenStage.handle_info/2.

init(opts)

Callback implementation for GenStage.init/1.

start_link(init \\ [])
terminate(_, state)

Callback implementation for GenStage.terminate/2.

Types

Link to this type

options()

View Source 
@type options() :: [
  flush_interval: pos_integer(),
  flush_batch_size: pos_integer(),
  subscribe_to: atom() | {atom(), keyword()}
]
Link to this type

state()

View Source 
@type state() :: %{
  queue: :queue.queue(),
  queue_size: pos_integer() | 0,
  next_flush_timer: reference() | nil,
  flush_interval: pos_integer(),
  flush_batch_size: pos_integer()
}

Functions

Link to this function

handle_events(events, from, state)

View Source

Callback implementation for GenStage.handle_events/3.

Link to this function

handle_info(atom, state)

View Source

Callback implementation for GenStage.handle_info/2.

Link to this function

init(opts)

View Source

Callback implementation for GenStage.init/1.

Link to this function

start_link(init \\ [])

View Source 
@spec start_link(options()) :: GenServer.on_start()
Link to this function

terminate(_, state)

View Source

Callback implementation for GenStage.terminate/2.