Class: KafkaSyrup::Protocol::ProduceRequest::Topic

Inherits:
Struct
  • Object
show all
Defined in:
lib/kafka_syrup/protocol/produce_request.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#name ⇒ Object

Returns the value of attribute name

Returns:

  • (Object) —

    the current value of name



32
33
34
 
# File 'lib/kafka_syrup/protocol/produce_request.rb', line 32

def name
  @name
end

#partitions ⇒ Object

Returns the value of attribute partitions

Returns:

  • (Object) —

    the current value of partitions



32
33
34
 
# File 'lib/kafka_syrup/protocol/produce_request.rb', line 32

def partitions
  @partitions
end

Instance Method Details

#add_partition(id) ⇒ Object 



33
34
35
36
37
 
# File 'lib/kafka_syrup/protocol/produce_request.rb', line 33

def add_partition(id)
  partition = Partition.new(id, MessageSet.new)
  partitions << partition
  partition
end

#encode ⇒ Object 



39
40
41
42
43
44
 
# File 'lib/kafka_syrup/protocol/produce_request.rb', line 39

def encode
  [
    E.write_string(name),
    E.write_array(partitions)
  ].join
end