Class: Deimos::Utils::LagReporter::Topic

Inherits:
Object
  • Object
show all
Defined in:
sig/defs.rbs

Overview

Topic which has a hash of partition => last known current offsets

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Topic

@param topic_name

@param group

Parameters:



919
 
# File 'sig/defs.rbs', line 919

def initialize: (String topic_name, ConsumerGroup group) -> void

Instance Attribute Details

#consumer_group ⇒ ConsumerGroup

Returns the value of attribute consumer_group.

Returns:



938
939
940
 
# File 'sig/defs.rbs', line 938

def consumer_group
  @consumer_group
end

#partition_current_offsets ⇒ ::Hash[Integer, Integer]

Returns the value of attribute partition_current_offsets.

Returns:

  • (::Hash[Integer, Integer]) 


936
937
938
 
# File 'sig/defs.rbs', line 936

def partition_current_offsets
  @partition_current_offsets
end

#topic_name ⇒ String

Returns the value of attribute topic_name.

Returns:

  • (String) 


934
935
936
 
# File 'sig/defs.rbs', line 934

def topic_name
  @topic_name
end

Instance Method Details

#assign_current_offset ⇒ void

This method returns an undefined value.

@param partition

@param offset

Parameters:

  • partition (Integer)
  • offset (Integer) 


924
 
# File 'sig/defs.rbs', line 924

def assign_current_offset: (Integer partition, Integer offset) -> void

#compute_lag ⇒ Integer

@param partition

@param offset

Parameters:

  • partition (Integer)
  • offset (Integer)

Returns:

  • (Integer) 


929
 
# File 'sig/defs.rbs', line 929

def compute_lag: (Integer partition, Integer offset) -> Integer

#report_lag ⇒ void

This method returns an undefined value.

@param partition

Parameters:

  • partition (Integer) 


932
 
# File 'sig/defs.rbs', line 932

def report_lag: (Integer partition) -> void