abstract class LavinMQ::Federation::Upstream::Link

Included Modules

Direct Known Subclasses

Defined in:

lavinmq/federation/link.cr

Constant Summary

Log = LavinMQ::Log.for("federation.link")

Constructors

Instance Method Summary

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, search_match?(value : String)
search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json

Constructor Detail

def self.new(upstream : Upstream) #

[View source]

Instance Method Detail

def details_tuple #

[View source]
def error : String? #

[View source]
def last_changed : Int64? #

[View source]
abstract def name : String #

[View source]
def run #

[View source]
def search_match?(value : String) : Bool #

[View source]
def search_match?(value : Regex) : Bool #

[View source]
def state : LavinMQ::Federation::Upstream::Link::State #

[View source]
def terminate #

Does not trigger reconnect, but a graceful close


[View source]