Module kflow_wf_sysmon_receiver

This workflow receives system_monitor messages and puts them to postgres tables.

Description

This workflow receives system_monitor messages and puts them to postgres tables.

The following parameters are mandatory:

Type: brod:topic().

Type: binary(). Kafka group consumer ID used by the workflow.

config() = #{kafka_topic := brod:topic(), group_id := binary(), database := epgsql:connect_opts()}

format_function/1	Convert function definition to string.
format_stacktrace/1
nullable/1	Transform undefined to "null".
timestamp/1	erlang timestamp to epgsql timestamp.
to_string/2	Convert arbitrary erlang term to string.
workflow/2	Create a workflow specification.

format_function(X1::{module(), atom(), arity()}) -> string()

Convert function definition to string

format_stacktrace(Stacktrace::list()) -> string()

nullable(A::term()) -> term()

Transform undefined to "null"

timestamp(Timestamp::erlang:timestamp()) -> tuple()

erlang timestamp to epgsql timestamp

to_string(Term::term(), Limit::integer()) -> string()

Convert arbitrary erlang term to string

workflow(Id::atom(), Config::config()) -> kflow:workflow()

Create a workflow specification

Generated by EDoc