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



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

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:

  • true if the message metadata has been cleaned



43
44
45
 
# File 'lib/karafka/pro/cleaner/messages/metadata.rb', line 43

def cleaned?
  raw_headers == false
end

#headers ⇒ Object

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

Returns:

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



38
39
40
 
# File 'lib/karafka/pro/cleaner/messages/metadata.rb', line 38

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

#key ⇒ Object

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

Returns:

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



32
33
34
 
# File 'lib/karafka/pro/cleaner/messages/metadata.rb', line 32

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