View Source erlmld_noisy_wrk (erlmld v1.1.0)

The default example worker, which prints events and checkpoints after every 10 records.

Link to this section Summary

Link to this section Functions

Link to this function

checkpointed(State, SequenceNumber, Checkpoint)

View Source
Link to this function

initialize(Opaque, ShardId, ISN)

View Source
Link to this function

process_record(State, Stream_record)

View Source