Module: Karafka::Pro::Cleaner::Messages::Metadata

Defined in:
lib/karafka/pro/cleaner/messages/metadata.rb

Overview

Extensions to the message metadata that allow for granular memory control on a per message basis

Instance Method Summary collapse

Instance Method Details

#clean! ⇒ Object

Cleans the headers and key



56
57
58
59
60
61
 
# File 'lib/karafka/pro/cleaner/messages/metadata.rb', line 56

def clean!
  self.raw_headers = false
  self.raw_key = false
  @key = nil
  @headers = nil
end

#cleaned? ⇒ Boolean

Returns true if the message metadata has been cleaned.

Returns:

  • (Boolean) —

    true if the message metadata has been cleaned



51
52
53
 
# File 'lib/karafka/pro/cleaner/messages/metadata.rb', line 51

def cleaned?
  raw_headers == false
end

#headers ⇒ Object

Returns deserialized headers. By default its a hash with keys and payload being strings.

Returns:

  • (Object) —

    deserialized headers. By default its a hash with keys and payload being strings



46
47
48
 
# File 'lib/karafka/pro/cleaner/messages/metadata.rb', line 46

def headers
  cleaned? ? raise(Errors::MessageCleanedError) : super
end

#key ⇒ Object

Returns deserialized key. By default in the raw string format.

Returns:

  • (Object) —

    deserialized key. By default in the raw string format.



40
41
42
 
# File 'lib/karafka/pro/cleaner/messages/metadata.rb', line 40

def key
  cleaned? ? raise(Errors::MessageCleanedError) : super
end