nys_etl v0.1.0

NYSETL.Engines.E3.IndexCaseProducer (nys_etl v0.1.0) View Source

Find IndexCase records to process by the CommcareCaseLoader and created or updated in CommCare.

Link to this section Summary

Functions

handle_demand(demand, state)

Callback implementation for GenStage.handle_demand/2.

handle_info(atom, state)

Callback implementation for GenStage.handle_info/2.

init(opts)

Callback implementation for GenStage.init/1.

more_recent_than(query, id)
new(attrs \\ [])
start_link(args)
unprocessed_index_cases(demand, find_with_events_matching, reject_with_events_matching)

Link to this section Functions

Link to this function

handle_demand(demand, state)

View Source

Callback implementation for GenStage.handle_demand/2.

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

more_recent_than(query, id)

View Source
Link to this function

new(attrs \\ [])

View Source
Link to this function

start_link(args)

View Source
Link to this function

unprocessed_index_cases(demand, find_with_events_matching, reject_with_events_matching)

View Source