@@ -32,47 +32,53 @@ defmodule Membrane.OpenTelemetry.Plugs.Launch do
32
32
end
33
33
34
34
defp attach_telemetry_handlers ( ) do
35
- :ok = :telemetry . attach (
36
- { __MODULE__ , :start_span } ,
37
- [ :membrane , :handle_init , :start ] ,
38
- & HandlerFunctions . start_span / 4 ,
39
- nil
40
- )
35
+ :ok =
36
+ :telemetry . attach (
37
+ { __MODULE__ , :start_span } ,
38
+ [ :membrane , :handle_init , :start ] ,
39
+ & HandlerFunctions . start_span / 4 ,
40
+ nil
41
+ )
41
42
42
43
@ all_callbacks
43
44
|> Enum . each ( fn callback ->
44
- :ok = :telemetry . attach (
45
- { __MODULE__ , callback , :start } ,
46
- [ :membrane , callback , :start ] ,
47
- & HandlerFunctions . callback_start / 4 ,
48
- nil
49
- )
45
+ :ok =
46
+ :telemetry . attach (
47
+ { __MODULE__ , callback , :start } ,
48
+ [ :membrane , callback , :start ] ,
49
+ & HandlerFunctions . callback_start / 4 ,
50
+ nil
51
+ )
50
52
51
- :ok = :telemetry . attach (
52
- { __MODULE__ , callback , :stop } ,
53
- [ :membrane , callback , :stop ] ,
54
- & HandlerFunctions . callback_stop / 4 ,
55
- nil
56
- )
53
+ :ok =
54
+ :telemetry . attach (
55
+ { __MODULE__ , callback , :stop } ,
56
+ [ :membrane , callback , :stop ] ,
57
+ & HandlerFunctions . callback_stop / 4 ,
58
+ nil
59
+ )
57
60
end )
58
61
59
- :ok = :telemetry . attach (
60
- { __MODULE__ , :end_span } ,
61
- [ :membrane , :handle_start_of_stream , :stop ] ,
62
- & HandlerFunctions . end_span / 4 ,
63
- nil
64
- )
62
+ :ok =
63
+ :telemetry . attach (
64
+ { __MODULE__ , :end_span } ,
65
+ [ :membrane , :handle_start_of_stream , :stop ] ,
66
+ & HandlerFunctions . end_span / 4 ,
67
+ nil
68
+ )
65
69
end
66
70
67
71
defp detach_telemetry_handlers ( ) do
68
72
@ all_callbacks
69
- |> Enum . flat_map ( fn callback -> [
70
- { __MODULE__ , callback , :start } ,
71
- { __MODULE__ , callback , :stop }
72
- ] end )
73
+ |> Enum . flat_map ( fn callback ->
74
+ [
75
+ { __MODULE__ , callback , :start } ,
76
+ { __MODULE__ , callback , :stop }
77
+ ]
78
+ end )
73
79
|> Enum . concat ( [
74
80
{ __MODULE__ , :start_span } ,
75
- { __MODULE__ , :end_span } ,
81
+ { __MODULE__ , :end_span }
76
82
] )
77
83
|> Enum . each ( fn handler_id ->
78
84
:ok = :telemetry . detach ( handler_id )
0 commit comments