class Movie::ClusterRoutersExtension

• Movie::ClusterRoutersExtension
• Movie::Extension
• Reference
• Object

Defined in:

movie/cluster/router/extension.cr

Constant Summary

Log = ::Log.for(self)

Constructors

• .new(system : AbstractActorSystem)

Instance Method Summary

• #group(key : Cluster::ServiceKey(T), settings : Cluster::ClusterRouterSettings = Cluster::ClusterRouterSettings.new, routing_key : Proc(T, String) | Nil = nil) : Cluster::ClusterRouterRef(T) forall T
• #pool(key : Cluster::ServiceKey(T), size : Int32, name_prefix : String = "routee", settings : Cluster::ClusterRouterSettings = Cluster::ClusterRouterSettings.new, routing_key : Proc(T, String) | Nil = nil, &factory : Int32 -> AbstractBehavior(T)) : Cluster::ClusterRouterPool(T) forall T
• #pool_closed(pool : Cluster::ClusterRouterPoolBase) : Nil
• #record_broadcast_delivery(count : Int32) : Nil
• #record_delivery(count : Int32 = 1) : Nil
• #record_listing_update : Nil
• #record_strategy_selection(strategy : Cluster::ClusterRoutingStrategy) : Nil
• #record_unavailable : Nil
• #router_closed(router : Cluster::ClusterRouterRefBase) : Nil
• #start : Bool

  Called when the extension is registered with the system.

• #stats : Cluster::ClusterRouterStats
• #stop : Nil

  Called when the system is shutting down.

Constructor Detail

Instance Method Detail