Class: Heller::OffsetRequest

Inherits:
Object
  • Object
show all
Defined in:
lib/heller/offset_request.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(topic, partition, time, offsets = 1) ⇒ OffsetRequest

Returns a new instance of OffsetRequest.



19
20
21
 
# File 'lib/heller/offset_request.rb', line 19

def initialize(topic, partition, time, offsets = 1)
  @topic, @partition, @time, @max_offsets = topic, partition, time, offsets
end

Instance Attribute Details

#max_offsets ⇒ Object (readonly)

Returns the value of attribute max_offsets.



5
6
7
 
# File 'lib/heller/offset_request.rb', line 5

def max_offsets
  @max_offsets
end

#partition ⇒ Object (readonly)

Returns the value of attribute partition.



5
6
7
 
# File 'lib/heller/offset_request.rb', line 5

def partition
  @partition
end

#time ⇒ Object (readonly)

Returns the value of attribute time.



5
6
7
 
# File 'lib/heller/offset_request.rb', line 5

def time
  @time
end

#topic ⇒ Object (readonly)

Returns the value of attribute topic.



5
6
7
 
# File 'lib/heller/offset_request.rb', line 5

def topic
  @topic
end

Class Method Details

.current_version ⇒ Object 



15
16
17
 
# File 'lib/heller/offset_request.rb', line 15

def self.current_version
  Kafka::Api::OffsetRequest.current_version
end

.earliest_time ⇒ Object 



11
12
13
 
# File 'lib/heller/offset_request.rb', line 11

def self.earliest_time
  Kafka::Api::OffsetRequest.earliest_time
end

.latest_time ⇒ Object 



7
8
9
 
# File 'lib/heller/offset_request.rb', line 7

def self.latest_time
  Kafka::Api::OffsetRequest.latest_time
end