class LavinMQ::Server

Included Modules

Defined in:

lavinmq/server.cr

Constant Summary

METRICS = {:user_time, :sys_time, :blocks_out, :blocks_in}
PAGE_SIZE = LibC.getpagesize

Constructors

Instance Method Summary

Instance methods inherited from module LavinMQ::ParameterTarget

add_parameter(parameter : Parameter) add_parameter, apply_parameter(parameter : Parameter | Nil) apply_parameter, delete_parameter(component_name : String | Nil, parameter_name : String) delete_parameter

Constructor Detail

def self.new(data_dir : String) #

[View source]

Instance Method Detail

def add_parameter(parameter : Parameter) #

[View source]
def blocks_in : Int64 #

def blocks_in_log : Deque(Float64) #

def blocks_out : Int64 #

def blocks_out_log : Deque(Float64) #

def close #

[View source]
def closed? : Bool #

[View source]
def connections #

[View source]
def data_dir : String #

[View source]
def delete_parameter(component_name, parameter_name) #

[View source]
def disk_free : Int64 #

[View source]
def disk_free_log : Deque(Int64) #

[View source]
def disk_full? #

[View source]
def disk_total : Int64 #

[View source]
def disk_total_log : Deque(Int64) #

[View source]
def disk_usage_over_warning_level? #

[View source]
def flow(active : Bool) #

[View source]
def flow? : Bool #

[View source]
def followers #

[View source]
def handle_connection(socket, connection_info) #

[View source]
def listen(s : TCPServer) #

[View source]
def listen(s : UNIXServer) #

[View source]
def listen(bind = "::", port = 5672) #

[View source]
def listen_replication(bind, port) #

[View source]
def listen_tls(bind, port, context) #

[View source]
def listen_unix(path : String) #

[View source]
def listeners #

[View source]
def mem_limit : Int64 #

[View source]

[View source]
def restart #

[View source]
def rss : Int64 #

[View source]
def rss_log : Deque(Int64) #

[View source]
def stats_collection_duration_seconds_total : Time::Span #

[View source]
def stats_rates_collection_duration_seconds : Time::Span #

[View source]
def stats_system_collection_duration_seconds : Time::Span #

[View source]
def stop #

[View source]
def sys_time : Int64 #

def sys_time_log : Deque(Float64) #

def system_metrics(statm) #

[View source]
def update_stats_rates #

[View source]
def uptime #

[View source]
def user_time : Int64 #

def user_time_log : Deque(Float64) #

def users : LavinMQ::UserStore #

[View source]
def vhosts : LavinMQ::VHostStore #

[View source]