class AvalancheMQ::Server

Included Modules

Defined in:

avalanchemq/server.cr

Constant Summary

METRICS = {:user_time, :sys_time, :blocks_out, :blocks_in}
SERVER_METRICS = {:connection_created, :connection_closed, :channel_created, :channel_closed, :queue_declared, :queue_deleted}

Constructors

Instance Method Summary

Instance methods inherited from module AvalancheMQ::ParameterTarget

add_parameter(p : Parameter) add_parameter, apply_parameter(p : Parameter | Nil) apply_parameter, delete_parameter(component : String | Nil, name : String) delete_parameter

Constructor Detail

def self.new(data_dir : String, log : Logger) #

[View source]

Instance Method Detail

def ack_count : UInt64 #

def add_parameter(p : Parameter) #

[View source]
def blocks_in : Int64 #

def blocks_in_log : Deque(Float64) #

def blocks_out : Int64 #

def blocks_out_log : Deque(Float64) #

def channel_closed_count : UInt64 #

def channel_closed_log : Deque(Float64) #

[View source]
def channel_closed_rate : Float64 #

def channel_created_count : UInt64 #

def channel_created_log : Deque(Float64) #

[View source]
def channel_created_rate : Float64 #

def close #

[View source]
def closed? : Bool #

[View source]
def confirm_count : UInt64 #

def connection_closed_count : UInt64 #

def connection_closed_log : Deque(Float64) #

[View source]
def connection_closed_rate : Float64 #

def connection_created_count : UInt64 #

def connection_created_log : Deque(Float64) #

[View source]
def connection_created_rate : Float64 #

def connections #

[View source]
def data_dir : String #

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

[View source]
def deliver_count : UInt64 #

def disk_free : Int64 #

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

[View source]
def disk_total : Int64 #

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

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

[View source]
def flow? : Bool #

[View source]
def get_count : UInt64 #

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_tls(bind, port, context) #

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

[View source]
def listeners #

[View source]
def log : Logger #

[View source]
def parameters : AvalancheMQ::ParameterStore(AvalancheMQ::Parameter) #

[View source]
def publish_count : UInt64 #

def queue_declared_count : UInt64 #

def queue_declared_log : Deque(Float64) #

[View source]
def queue_declared_rate : Float64 #

def queue_deleted_count : UInt64 #

def queue_deleted_log : Deque(Float64) #

[View source]
def queue_deleted_rate : Float64 #

def redeliver_count : UInt64 #

def reject_count : UInt64 #

def rss : Int64 #

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

[View source]
def stats_details #

[View source]
def stop_shovels #

[View source]
def sys_time : Int64 #

def sys_time_log : Deque(Float64) #

def update_rates #

[View source]
def update_stats_rates #

[View source]
def uptime #

[View source]
def user_time : Int64 #

def user_time_log : Deque(Float64) #

def users : AvalancheMQ::UserStore #

[View source]
def vhost_connections(vhost_name) #

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

[View source]