struct Movie::Cluster::ProtocolMessage

• Movie::Cluster::ProtocolMessage
• Struct
• Value
• Object

Included Modules

• JSON::Serializable

Defined in:

Constructors

• .down_request(cluster_name : String, sender : UniqueAddress, target : UniqueAddress) : self
• .gossip(cluster_name : String, sender : UniqueAddress, members : Array(Member), round : Int64, digest : String) : self
• .gossip_ack(cluster_name : String, sender : UniqueAddress, round : Int64, digest : String) : self
• .gossip_tick(cluster_name : String, sender : UniqueAddress) : self
• .heartbeat(cluster_name : String, sender : UniqueAddress, sequence : Int64) : self
• .heartbeat_ack(cluster_name : String, sender : UniqueAddress, sequence : Int64) : self
• .heartbeat_tick(cluster_name : String, sender : UniqueAddress) : self
• .join(cluster_name : String, sender : UniqueAddress, member : Member) : self
• .join_rejected(cluster_name : String, sender : UniqueAddress, reason : String) : self
• .join_tick(cluster_name : String, sender : UniqueAddress) : self
• .leave_request(cluster_name : String, sender : UniqueAddress) : self
• .new(kind : Kind, cluster_name : String, sender : UniqueAddress, member : Member | Nil = nil, members : Array(Member) = [] of Member, gossip_round : Int64 | Nil = nil, heartbeat_sequence : Int64 | Nil = nil, digest : String | Nil = nil, target : UniqueAddress | Nil = nil, protocol_version : Int32 = 1, minimum_protocol_version : Int32 = 1, app_version : String = "0.1.0", rejection_reason : String | Nil = nil)
• .new(pull : JSON::PullParser)
• .new(*, __pull_for_json_serializable pull : JSON::PullParser)
• .welcome(cluster_name : String, sender : UniqueAddress, members : Array(Member)) : self

Instance Method Summary

• #app_version : String
• #cluster_name : String
• #digest : String | Nil
• #gossip_round : Int64 | Nil
• #heartbeat_sequence : Int64 | Nil
• #kind : Kind
• #member : Member | Nil
• #members : Array(Member)
• #minimum_protocol_version : Int32
• #protocol_version : Int32
• #rejection_reason : String | Nil
• #sender : UniqueAddress
• #target : UniqueAddress | Nil
• #with_compatibility(protocol_version : Int32, minimum_protocol_version : Int32, app_version : String) : self

Constructor Detail

Instance Method Detail