class Movie::Remote::Server

Overview

Server accepts incoming TCP connections from remote actor systems.

movie/remote/server.cr

.new(system : Movie::AbstractActorSystem, host : String, port : Int32, path_registry : Movie::PathRegistry, local_address : Proc(Address), node_uid : String, on_message : Proc(WireEnvelope, InboundConnection, Nil), on_disconnect : Proc(InboundConnection, Nil), settings : AssociationSettings = AssociationSettings.new)

#control_deduplication_stats : ControlDeduplicationStats
#host : String
#local_port : Int32
Returns the actual bound port (useful when binding to port 0).
#port : Int32
#retire_control_node(node_uid : String) : Int32
Releases receiver-side cursors only for a node incarnation that the operator has independently confirmed will never reconnect.
#running? : Bool
#start : Bool
Starts the server.
#stop
Stops the server and closes all connections.

def self.new(system : Movie::AbstractActorSystem, host : String, port : Int32, path_registry : Movie::PathRegistry, local_address : Proc(Address), node_uid : String, on_message : Proc(WireEnvelope, InboundConnection, Nil), on_disconnect : Proc(InboundConnection, Nil), settings : AssociationSettings = AssociationSettings.new) #

[View source]

def control_deduplication_stats : ControlDeduplicationStats #

[View source]

def host : String #

[View source]

def local_port : Int32 #

Returns the actual bound port (useful when binding to port 0).

[View source]

def port : Int32 #

[View source]

def retire_control_node(node_uid : String) : Int32 #

Releases receiver-side cursors only for a node incarnation that the operator has independently confirmed will never reconnect.

[View source]

def running? : Bool #

[View source]

def start : Bool #

Starts the server.

[View source]

def stop #

Stops the server and closes all connections.

[View source]