File: observer_cli.hrl

package info (click to toggle)
rabbitmq-server 4.0.5-13
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 38,332 kB
  • sloc: erlang: 257,826; javascript: 22,466; sh: 3,037; makefile: 2,599; python: 1,966; xml: 646; cs: 335; java: 244; ruby: 212; php: 100; perl: 63; awk: 13
file content (108 lines) | stat: -rw-r--r-- 3,005 bytes parent folder | download | duplicates (3)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
-define(COLUMN, 134).
-define(INIT_TIME_REF, undefined).

-define(MIN_INTERVAL, 1000).
-define(DEFAULT_INTERVAL, 1500).
-define(DISABLE, disable).
-define(ENABLE, enable).

-record(home, {
    func = proc_count :: atom(),
    type = memory :: atom(),
    cur_page = 1 :: pos_integer(),
    pages = [{1, 1}] :: list(),
    interval = ?DEFAULT_INTERVAL :: pos_integer(),
    scheduler_usage = application:get_env(observer_cli, scheduler_usage, ?DISABLE) ::
        ?DISABLE | ?ENABLE
}).

-record(app, {
    type = {proc_count, 1} :: {atom(), pos_integer()},
    cur_page = 1 :: pos_integer(),
    interval = ?DEFAULT_INTERVAL :: pos_integer()
}).

-record(ets, {
    interval = 2000 :: integer(),
    attr = memory :: atom(),
    cur_page = 1 :: integer()
}).

-record(system, {interval = 2000 :: integer()}).

-record(db, {
    interval = ?DEFAULT_INTERVAL :: integer(),
    hide_sys = true :: boolean(),
    cur_page = 1 :: integer(),
    attr = memory :: atom()
}).

-record(help, {interval = ?DEFAULT_INTERVAL :: integer()}).
-record(inet, {
    interval = ?DEFAULT_INTERVAL :: integer(),
    func = inet_count :: atom(),
    type = cnt :: atom(),
    cur_page = 1 :: pos_integer(),
    pages = [{1, 1}] :: list()
}).

-record(process, {interval = ?DEFAULT_INTERVAL :: integer()}).

-record(plug, {cur_index = 1 :: pos_integer(), plugs = [] :: map() | []}).

-record(view_opts, {
    home = #home{} :: home(),
    ets = #ets{} :: ets(),
    sys = #system{} :: system(),
    app = #app{} :: app(),
    db = #db{} :: db(),
    help = #help{} :: help(),
    inet = #inet{} :: inet(),
    process = #process{} :: process(),
    port = ?DEFAULT_INTERVAL :: pos_integer(),
    plug = #plug{} :: plug(),
    auto_row = true :: boolean()
}).

-export_type([view_opts/0]).

-type view_opts() :: #view_opts{}.
-type home() :: #home{}.
-type app() :: #app{}.
-type system() :: #system{}.
-type ets() :: #ets{}.
-type db() :: #db{}.
-type help() :: #help{}.
-type inet() :: #inet{}.
-type process() :: #process{}.
-type plug() :: #plug{}.

-define(CURSOR_TOP, <<"\e[H">>).
-define(CLEAR, <<"\e[H\e[J">>).

-define(RESET_BG, <<"\e[49m">>).
-define(RESET, <<"\e[0m">>).
-define(GRAY_BG, <<"\e[7m">>).
-define(YELLOW, <<"\e[33m">>).
-define(RED, <<"\e[31m">>).
-define(L_RED, <<"\e[48m">>).
-define(GREEN, <<"\e[32;1m">>).
-define(L_GREEN, <<"\e[92m">>).
-define(CHOOSE_BG, <<"\e[42m">>).
-define(RED_BG, <<"\e[48;2;184;0;0m">>).
-define(L_GRAY_BG, <<"\e[48;2;80;80;80m">>).
-define(UNDERLINE, <<"\e[4m">>).

-define(NEW_LINE, "\e[0m\n|").
-define(I, <<" | ">>).
-define(I2, <<"|">>).
-define(W(_C_, _A_, _W_), {width_color, _C_, _A_, _W_}).
-define(W2(_C_, _A_, _W_), {width_color_2, _C_, _A_, _W_}).
-define(W(_A_, _W_), {width, _A_, _W_}).

-define(SELECT(Text), observer_cli_lib:select(Text)).
-define(UNSELECT(Text), observer_cli_lib:unselect(Text)).

-define(render(_FA_), observer_cli_lib:render(_FA_)).
-define(output(_F_, _A_), io:format(iolist_to_binary(_F_), _A_)).
-define(output(_L_), ?output(_L_, [])).