kiel.protocol.join_group¶

class kiel.protocol.join_group.GroupProtocol(**kwargs)[source]¶

GroupProtocol =>
  name => String
  version => Int16
  subscription => Array.of(String)
  user_data => Bytes

class kiel.protocol.join_group.JoinGroupRequest(**kwargs)[source]¶

JoinGroupRequest =>
  group_id => String
  session_timeout => Int32
  member_id => String
  protocol_type => String
  group_protocols => [GroupProtocol]

class kiel.protocol.join_group.Member(**kwargs)[source]¶

Member =>
  member_id => String
  metadata => Bytes

class kiel.protocol.join_group.JoinGroupResponse(**kwargs)[source]¶

JoinGroupResponse =>
  error_code => Int16
  generation_id => Int32
  protocol => String
  leader_id => String
  member_id => String
  members => [Member]