GenericExecutor behaviour (tellurium v0.7.0) View Source

Implements generic behaviour for message executors

Link to this section Summary

Callbacks

Decode message payload from MessageToHandle.

Extract handler function path (name) from the message.

It's called when handler return (optional).

Link to this section Types

Specs

handler_response() :: any()

Specs

parsed_payload() :: map()

Link to this section Functions

Link to this function

report_to_telemetry(type, handler_path, duration, result)

View Source
Link to this function

requeue_or_ack(msg, error_info, msg_type)

View Source

Link to this section Callbacks

Specs

decode(MessageToHandle.t()) :: parsed_payload()

Decode message payload from MessageToHandle.

Link to this callback

get_handler_path(arg1, parsed_payload)

View Source

Specs

get_handler_path(MessageToHandle.t(), parsed_payload()) :: String.t()

Extract handler function path (name) from the message.

Link to this callback

on_post_process(handler_response, arg2)

View Source

Specs

on_post_process(handler_response(), MessageToHandle.t()) :: any()

It's called when handler return (optional).