module

LavinMQ::Config::Options

Separate module for config option definitions. This keeps the option declarations organized in one place, while config.cr contains the parsing and validation logic. Config class includes this module to inherit all annotated properties.

Constants

DEFAULT_LOG_LEVEL = ::Log::Severity::Info

DEFAULT_PASSWORD_HASH = Auth::Password::SHA256Password.new("+pHuxkR9fCyrrwXjOD4BP4XbzO3l8LJr8YkThMgJ0yVHFRE+")

Instance methods

amqp_bind

Source

amqp_bind=(amqp_bind : String)

Source

amqp_consumer_timeout=(value : UInt64 | Nil)

Source

amqp_default_consumer_prefetch=(value : UInt16)

Source

amqp_port

Source

amqp_port=(amqp_port : Int32)

Source

amqp_set_timestamp=(value : Bool)

Source

amqp_systemd_socket_name

Source

amqp_systemd_socket_name=(amqp_systemd_socket_name : String)

Source

amqp_tls_cert=(value : String)

Source

amqp_tls_key=(value : String)

Source

amqps_port

Source

amqps_port=(amqps_port : Int32)

Source

auth_backends

Source

auth_backends=(auth_backends : Array(String))

bind

bind=(bind : String)

channel_max

channel_max=(channel_max : UInt16)

Source

clustering=(clustering : Bool)

Source

clustering?

Source

clustering_advertised_uri

Source

clustering_advertised_uri=(clustering_advertised_uri : String | Nil)

Source

clustering_bind

Source

clustering_bind=(clustering_bind : String)

Source

clustering_etcd_endpoints

Source

clustering_etcd_endpoints=(clustering_etcd_endpoints : String)

Source

clustering_etcd_lease_ttl

Source

clustering_etcd_lease_ttl=(clustering_etcd_lease_ttl : Int32)

Source

clustering_etcd_prefix

Source

clustering_etcd_prefix=(clustering_etcd_prefix : String)

Source

clustering_on_leader_elected

Source

clustering_on_leader_elected=(clustering_on_leader_elected : String)

Source

clustering_on_leader_lost

Source

clustering_on_leader_lost=(clustering_on_leader_lost : String)

Source

clustering_port

Source

clustering_port=(clustering_port : Int32)

Source

config_file

Source

config_file=(config_file : String)

Source

consumer_timeout

Source

consumer_timeout=(consumer_timeout : UInt64 | Nil)

Source

consumer_timeout_loop_interval

Source

consumer_timeout_loop_interval=(consumer_timeout_loop_interval : Int32)

Source

control_unix_path

Source

control_unix_path=(control_unix_path : String)

Source

data_dir

Source

data_dir=(data_dir : String)

Source

data_dir_lock=(data_dir_lock : Bool)

Source

data_dir_lock?

Source

default_consistent_hash_algorithm

Source

default_consistent_hash_algorithm=(default_consistent_hash_algorithm : ConsistentHashAlgorithm)

Source

default_consumer_prefetch

Source

default_consumer_prefetch=(default_consumer_prefetch : UInt16)

Source

default_mqtt_vhost

Source

default_mqtt_vhost=(default_mqtt_vhost : String)

Source

default_password=(value : LavinMQ::Auth::Password::SHA256Password)

Source

default_password_hash

Source

default_password_hash=(default_password_hash : Auth::Password::SHA256Password)

Source

default_user

Source

default_user=(default_user : String)

Source

default_user_only_loopback=(default_user_only_loopback : Bool)

Source

default_user_only_loopback?

Source

deliver_loop_idle_timeout

Internal: not exposed as configurable, only used for testing

Source

deliver_loop_idle_timeout=(deliver_loop_idle_timeout : Time::Span)

Internal: not exposed as configurable, only used for testing

Source

frame_max

Source

frame_max=(frame_max : UInt32)

Source

free_disk_min

Source

free_disk_min=(free_disk_min : Int64)

Source

free_disk_warn

Source

free_disk_warn=(free_disk_warn : Int64)

Source

guest_only_loopback=(value : Bool)

Source

heartbeat

Source

heartbeat=(heartbeat : UInt16)

Source

http_bind

Source

http_bind=(http_bind : String)

Source

http_port

Source

http_port=(http_port : Int32)

Source

http_systemd_socket_name

Source

http_systemd_socket_name=(http_systemd_socket_name : String)

Source

http_unix_path

Source

http_unix_path=(http_unix_path : String)

Source

https_port

Source

https_port=(https_port : Int32)

Source

load_definitions

Source

load_definitions=(load_definitions : String)

Source

log_exchange=(log_exchange : Bool)

Source

log_exchange?

Source

log_file

Source

log_file=(log_file : String | Nil)

Source

log_level

Source

log_level=(log_level : ::Log::Severity)

Source

max_consumers_per_channel

Source

max_consumers_per_channel=(max_consumers_per_channel : Int32)

Source

max_deleted_definitions

Source

max_deleted_definitions=(max_deleted_definitions : Int32)

Source

max_inflight_messages

Source

max_inflight_messages=(max_inflight_messages : UInt16)

Source

max_message_size

Source

max_message_size=(max_message_size : Int32)

Source

metrics_http_bind

Source

metrics_http_bind=(metrics_http_bind : String)

Source

metrics_http_port

Source

metrics_http_port=(metrics_http_port : Int32)

Source

mgmt_tls_cert=(value : String)

Source

mgmt_tls_key=(value : String)

Source

mqtt_bind

Source

mqtt_bind=(mqtt_bind : String)

Source

mqtt_client_id_validation

Source

mqtt_client_id_validation=(mqtt_client_id_validation : MQTT::ClientIdValidation)

Source

mqtt_max_packet_size

Source

mqtt_max_packet_size=(mqtt_max_packet_size : UInt32)

Source

mqtt_permission_check_enabled=(mqtt_permission_check_enabled : Bool)

Source

mqtt_permission_check_enabled?

Source

mqtt_port

Source

mqtt_port=(mqtt_port : Int32)

Source

mqtt_unix_path

Source

mqtt_unix_path=(mqtt_unix_path : String)

Source

mqtts_port

Source

mqtts_port=(mqtts_port : Int32)

Source

oauth_additional_scopes_keys

Source

oauth_additional_scopes_keys=(oauth_additional_scopes_keys : Array(String))

Source

oauth_audience

Source

oauth_audience=(oauth_audience : String | Nil)

Source

oauth_client_id

Source

oauth_client_id=(oauth_client_id : String | Nil)

Source

oauth_issuer_url

Source

oauth_issuer_url=(oauth_issuer_url : URI | Nil)

Source

oauth_jwks_cache_ttl

Source

oauth_jwks_cache_ttl=(oauth_jwks_cache_ttl : Time::Span)

Source

oauth_mgmt_base_url

Source

oauth_mgmt_base_url=(oauth_mgmt_base_url : URI | Nil)

Source

oauth_mgmt_scopes

Source

oauth_mgmt_scopes=(oauth_mgmt_scopes : String)

Source

oauth_preferred_username_claims

Source

oauth_preferred_username_claims=(oauth_preferred_username_claims : Array(String))

Source

oauth_resource_server_id

Source

oauth_resource_server_id=(oauth_resource_server_id : String | Nil)

Source

oauth_scope_prefix

Source

oauth_scope_prefix=(oauth_scope_prefix : String | Nil)

Source

oauth_verify_aud=(oauth_verify_aud : Bool)

Source

oauth_verify_aud?

Source

pidfile

Source

pidfile=(pidfile : String)

Source

proxy_protocol_trusted_sources

Source

proxy_protocol_trusted_sources=(proxy_protocol_trusted_sources : Array(LavinMQ::IPMatcher))

Source

raise_gc_warn=(raise_gc_warn : Bool)

Source

raise_gc_warn?

Source

segment_size

Source

segment_size=(segment_size : Int32)

Source

set_timestamp=(set_timestamp : Bool)

Source

set_timestamp?

Source

socket_buffer_size

Source

socket_buffer_size=(socket_buffer_size : Int32)

Source

stats_interval

Source

stats_interval=(stats_interval : Int32)

Source

stats_log_size

Source

stats_log_size=(stats_log_size : Int32)

Source

sync=(sync : Bool)

Source

sync?

Source

syncfs_threshold

Syncing each file costs a device flush, while syncfs also writes out every other dirty page on the filesystem (e.g. ack files)

Source

syncfs_threshold=(syncfs_threshold : Int32)

Syncing each file costs a device flush, while syncfs also writes out every other dirty page on the filesystem (e.g. ack files)

Source

tcp_keepalive

Source

tcp_keepalive=(tcp_keepalive : Tuple(Int32, Int32, Int32) | Nil)

Source

tcp_nodelay=(tcp_nodelay : Bool)

Source

tcp_nodelay?

Source

tcp_proxy_protocol=(tcp_proxy_protocol : Bool)

Source

tcp_proxy_protocol?

Source

tcp_recv_buffer_size

Source

tcp_recv_buffer_size=(tcp_recv_buffer_size : Int32 | Nil)

Source

tcp_send_buffer_size

Source

tcp_send_buffer_size=(tcp_send_buffer_size : Int32 | Nil)

Source

tcp_send_timeout

A client that doesn't read for this long is disconnected

Source

tcp_send_timeout=(tcp_send_timeout : Int32)

A client that doesn't read for this long is disconnected

Source

tls_cert_path

Source

tls_cert_path=(tls_cert_path : String)

Source

tls_ciphers

Source

tls_ciphers=(tls_ciphers : String)

Source

tls_ciphersuites

Source

tls_ciphersuites=(tls_ciphersuites : String)

Source

tls_key_path

Source

tls_key_path=(tls_key_path : String)

Source

tls_keylog_file

Source

tls_keylog_file=(tls_keylog_file : String)

Source

tls_ktls=(tls_ktls : Bool)

Source

tls_ktls?

Source

tls_min_version

Source

tls_min_version=(tls_min_version : String)

Source

tls_prefer_server_ciphers=(tls_prefer_server_ciphers : Bool)

Source

tls_prefer_server_ciphers?

Source

unix_path

Source

unix_path=(unix_path : String)

Source

yield_each_delivered_bytes

Source

yield_each_delivered_bytes=(yield_each_delivered_bytes : Int32)

Source

yield_each_received_bytes

Source

yield_each_received_bytes=(yield_each_received_bytes : Int32)

Source