Class: Deimos::Utils::LagReporter

Inherits:

Object

• Object
• Deimos::Utils::LagReporter

Extended by:

Mutex_m

Defined in:

sig/defs.rbs

Overview

Class that manages reporting lag.

Defined Under Namespace

Classes: ConsumerGroup, Topic

Class Method Summary

• .heartbeat ⇒ void

  @param payload.

• .message_processed ⇒ void

  offset_lag = event.payload.fetch(:offset_lag) group_id = event.payload.fetch(:group_id) topic = event.payload.fetch(:topic) partition = event.payload.fetch(:partition).

• .offset_seek ⇒ void

  @param payload.

• .reset ⇒ void

  Reset all group information.

Class Method Details

.heartbeat ⇒ void

This method returns an undefined value.

@param payload

Parameters:

• payload (::Hash[untyped, untyped])

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

def self.heartbeat: (::Hash[untyped, untyped] payload) -> void

.message_processed ⇒ void

This method returns an undefined value.

offset_lag = event.payload.fetch(:offset_lag) group_id = event.payload.fetch(:group_id) topic = event.payload.fetch(:topic) partition = event.payload.fetch(:partition)

@param payload

Parameters:

• payload (::Hash[untyped, untyped])

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

def self.message_processed: (::Hash[untyped, untyped] payload) -> void

.offset_seek ⇒ void

This method returns an undefined value.

@param payload

Parameters:

• payload (::Hash[untyped, untyped])

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

def self.offset_seek: (::Hash[untyped, untyped] payload) -> void

.reset ⇒ void

This method returns an undefined value.

Reset all group information.

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

def self.reset: () -> void