Hauleth
@hauleth.dev
1.1K followers 287 following 648 posts
Dad | Meme Driven Developer | ex-Supabase All opinions aren't my own, these belongs to supreme being chosen at random Sometimes I do some #ElixirLang, #Erlang and #RustLang
Dad | Meme Driven Developer | ex-Supabase All opinions aren't my own, these belongs to supreme being chosen at random Sometimes I do some #ElixirLang, #Erlang and #RustLang
![Window with source code of logger_udp_h.erl module:
%% @doc Implementation of `logger' handler for UDP sinks.
%% @end
-module(logger_udp_h).
-export([adding_handler/1, changing_config/3, filter_config/1, log/2]).
adding_handler(Config) ->
#{config := HConf} = Config,
Type = type_for(HConf),
Sockets = logger_udp_server:get_connections(Type),
Config1 = Config#{config := HConf#{sockets => Sockets}},
{ok, Config1}.
changing_config(_SetOrUpdate, _OldConf, NewConf) ->
#{config := HConf} = NewConf,
Type = type_for(HConf),
Sockets = logger_udp_server:get_connections(Type),
{ok, NewConf#{config => HConf#{sockets => Sockets}}}.
filter_config(Config) ->
#{config := HConf0} = Config,
HConf = maps:remove(sockets, HConf0),
Config#{config := HConf}.
log(LogEvent, Config) ->
#{config := HConf, formatter := {FMod, FConf}} = Config,
Dest = destination(HConf),
#{sockets := Socks} = HConf,
SchedulerId = erlang:system_info(scheduler_id),
Sock = map_get(SchedulerId, Socks),
Message = FMod:format(LogEvent, FConf),
logger_udp_server:send(Sock, Dest, Message),
ok.
-spec type_for(map()) -> logger_udp_server:sock_type().
type_for(#{type := Type}) when Type =:= inet; Type =:= inet6 -> Type;
type_for(#{host := localhost, port := _Port}) -> inet;
type_for(#{host := {_, _, _, _}, port := _Port}) -> inet;
type_for(#{host := {_, _, _, _, _, _, _, _}, port := _Port}) -> inet6;
type_for(#{socket := _Path}) -> local.
%% @doc Returns destination for packets.
-spec destination(map()) -> inet:family_address() |
{inet:ip_address(), inet:port_number()}.
destination(#{socket := Path}) -> {local, Path};
destination(#{host := localhost, port := Port}) -> {inet, {localhost, Port}};
destination(#{host := Host, port := Port}) -> {Host, Port}.](https://cdn.bsky.app/img/feed_thumbnail/plain/did:plc:6psaz6n5fuurrfet67zs4ljf/bafkreictil4jszesskl23z344acny2qmak6m55domstqlvvx3fozldooim)
