class
LavinMQ::Server
- LavinMQ::Server
- Reference
- Object
Included Modules
Defined in:
lavinmq/server.crConstant Summary
-
Log =
LavinMQ::Log.for("server") -
METRICS =
{:user_time, :sys_time, :blocks_out, :blocks_in} -
PAGE_SIZE =
LibC.getpagesize
Constructors
Instance Method Summary
- #add_parameter(parameter : Parameter)
- #amqp_url
- #blocks_in : Int64
- #blocks_in_log : Deque(Float64)
- #blocks_out : Int64
- #blocks_out_log : Deque(Float64)
- #close
- #closed? : Bool
- #connections
- #data_dir : String
- #delete_parameter(component_name, parameter_name)
- #deleted_vhosts_messages_acknowledged_total : UInt64
- #deleted_vhosts_messages_acknowledged_total=(deleted_vhosts_messages_acknowledged_total : UInt64)
- #deleted_vhosts_messages_confirmed_total : UInt64
- #deleted_vhosts_messages_confirmed_total=(deleted_vhosts_messages_confirmed_total : UInt64)
-
#deleted_vhosts_messages_delivered_total : UInt64
Message stats for deleted vhosts, required to keep accurate global counters
-
#deleted_vhosts_messages_delivered_total=(deleted_vhosts_messages_delivered_total : UInt64)
Message stats for deleted vhosts, required to keep accurate global counters
- #deleted_vhosts_messages_redelivered_total : UInt64
- #deleted_vhosts_messages_redelivered_total=(deleted_vhosts_messages_redelivered_total : UInt64)
- #disk_free : Int64
- #disk_free_log : Deque(Int64)
- #disk_full?
- #disk_total : Int64
- #disk_total_log : Deque(Int64)
- #disk_usage_over_warning_level?
- #flow(active : Bool)
- #flow? : Bool
- #followers
- #gc_stats : GC::ProfStats
- #handle_connection(socket, connection_info, protocol : Protocol)
- #listen(s : TCPServer, protocol : Protocol)
- #listen(s : UNIXServer, protocol : Protocol)
- #listen(bind = "::", port = 5672, protocol : Protocol = :amqp)
- #listen_clustering(bind, port)
- #listen_clustering(server : TCPServer)
- #listen_tls(s : TCPServer, context, protocol : Protocol)
- #listen_tls(bind, port, context, protocol : Protocol = :amqp)
- #listen_unix(path : String, protocol : Protocol)
- #listeners
- #mem_limit : Int64
- #parameters : LavinMQ::ParameterStore(LavinMQ::Parameter)
- #restart
- #rss : Int64
- #rss_log : Deque(Int64)
- #stats_collection_duration_seconds_total : Time::Span
- #stats_rates_collection_duration_seconds : Time::Span
- #stats_system_collection_duration_seconds : Time::Span
- #stop
- #sys_time : Int64
- #sys_time_log : Deque(Float64)
- #update_stats_rates
- #update_system_metrics(statm)
- #uptime
- #user_time : Int64
- #user_time_log : Deque(Float64)
- #users : LavinMQ::UserStore
- #vhosts : LavinMQ::VHostStore
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(config : Config, replicator : LavinMQ::Clustering::Replicator = Clustering::NoopServer.new)
#
Instance Method Detail
def deleted_vhosts_messages_acknowledged_total=(deleted_vhosts_messages_acknowledged_total : UInt64)
#
def deleted_vhosts_messages_confirmed_total=(deleted_vhosts_messages_confirmed_total : UInt64)
#
def deleted_vhosts_messages_delivered_total : UInt64
#
Message stats for deleted vhosts, required to keep accurate global counters
def deleted_vhosts_messages_delivered_total=(deleted_vhosts_messages_delivered_total : UInt64)
#
Message stats for deleted vhosts, required to keep accurate global counters
def deleted_vhosts_messages_redelivered_total=(deleted_vhosts_messages_redelivered_total : UInt64)
#