erlmld v1.1.1

View Source erlmld_noisy_wrk (erlmld v1.1.1)

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

Link to this section Summary

Functions

checkpointed(State, SequenceNumber, Checkpoint)
initialize(Opaque, ShardId, ISN)
process_record(State, Stream_record)
ready(State)
shutdown(State, Reason)

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
Link to this function

ready(State)

View Source
Link to this function

shutdown(State, Reason)

View Source