class LavinMQ::MQTT::RetainStore

• LavinMQ::MQTT::RetainStore
• Reference
• Object

Defined in:

lavinmq/mqtt/retain_store.cr

Constant Summary

INDEX_FILE_NAME = "index"

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

MESSAGE_FILE_SUFFIX = ".msg"

Constructors

• .new(dir : String, replicator : Clustering::Replicator, index : LavinMQ::MQTT::TopicTree(String) = IndexTree.new)

Instance Method Summary

• #close
• #each(subscription : String, &block : String, ::IO, UInt64 -> Nil) : Nil
• #make_file_name(topic : String) : String
• #retain(topic : String, body_io : ::IO, size : UInt64) : Nil
• #retained_messages

Constructor Detail

Instance Method Detail