class

LavinMQ::Server

Inherits LavinMQ::ParameterTarget < Reference < Object

Constants

Log = LavinMQ::Log.for("server")

METRICS = {:user_time, :sys_time, :blocks_out, :blocks_in}

PAGE_SIZE = LibC.getpagesize

PROCESS_START = Time.instant

Constructors

new(config : Config, replicator : LavinMQ::Clustering::Replicator | Nil = nil, authenticator : Auth::Authenticator | Nil = nil)

Source

Instance methods

add_parameter(parameter : Parameter, save = true)

Source

all_followers

Source

authenticator

Source

blocks_in

blocks_in_log

blocks_out

blocks_out_log

closed?

connections

data_dir

delete_parameter(component_name, parameter_name)

disk_free

disk_free_log

disk_full?

disk_recovered?

Free disk space required before publishing is resumed after a disk alarm

Source

disk_total

Source

disk_total_log

Source

disk_usage_over_warning_level?

flow(active : Bool)

flow?

followers

gc_stats

listen_clustering(server : TCPServer)

mem_limit

parameters

persister

rss

rss_log

save_parameters!

Persist the global parameter store; used to flush after a bulk import that created parameters with save: false.

Source

start_log_exchange

Source

stats_collection_duration_seconds_total

Source

stats_rates_collection_duration_seconds

Source

stats_system_collection_duration_seconds

Source

stop

Source

syncing_followers

Source

sys_time

sys_time_log

update_stats_rates

Source

update_system_metrics(statm)

Source

uptime

Source

user_time

user_time_log

users

Source

vhosts

Source