Module kflow_wf_sysmon_receiver

Description
Data Types
Function Index
Function Details

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.

Configuration

The following parameters are mandatory:

kafka_topic

Type: brod:topic().

group_id

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

database

Type: epgsql:connect_opts(). See https://github.com/epgsql/epgsql/blob/devel/src/epgsql.erl#L63

Data Types

config()

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

Function Index

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.

Function Details

format_function/1

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

Convert function definition to string

format_stacktrace/1

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

nullable/1

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

Transform undefined to "null"

timestamp/1

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

erlang timestamp to epgsql timestamp

to_string/2

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

Convert arbitrary erlang term to string

workflow/2

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

Create a workflow specification

Generated by EDoc