Class: Deimos::Utils::LagReporter::ConsumerGroup

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

Overview

Class that has a list of topics

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ ConsumerGroup

@param id

Parameters:

  • id (String) 


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

def initialize: (String id) -> void

Instance Attribute Details

#id ⇒ String

Returns the value of attribute id.

Returns:

  • (String) 


911
912
913
 
# File 'sig/defs.rbs', line 911

def id
  @id
end

#topics ⇒ ::Hash[String, Topic]

Returns the value of attribute topics.

Returns:

  • (::Hash[String, Topic]) 


909
910
911
 
# File 'sig/defs.rbs', line 909

def topics
  @topics
end

Instance Method Details

#assign_current_offset ⇒ void

This method returns an undefined value.

@param topic

@param partition

@param offset

Parameters:

  • topic (String)
  • partition (Integer)
  • offset (Integer) 


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

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

#report_lag ⇒ void

This method returns an undefined value.

@param topic

@param partition

Parameters:

  • topic (String)
  • partition (Integer) 


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

def report_lag: (String topic, Integer partition) -> void