ElasticsearchElixirBulkProcessor.Bulk.QueueStage (Elasticsearch Elixir Bulk Processor v0.1.8)

Link to this section Summary

Functions

add(events)

handle_cast(arg, state)

Callback implementation for GenStage.handle_cast/2.

handle_demand(_, state)

Callback implementation for GenStage.handle_demand/2.

init(atom)

Callback implementation for GenStage.init/1.

start_link(_)

Link to this section Functions

Link to this function

add(events)

Link to this function

handle_cast(arg, state)

Callback implementation for GenStage.handle_cast/2.

Link to this function

handle_demand(_, state)

Callback implementation for GenStage.handle_demand/2.

Link to this function

init(atom)

Callback implementation for GenStage.init/1.

Link to this function

start_link(_)