Sha256: 45159d2a186917f7350a4a0a22fe031603eb406f2c30c30a145ea412f56b1af5

Contents?: true

Size: 362 Bytes

Versions: 97

Compression:

Stored size: 362 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Messages
    # Single message metadata details that can be accessed without the need of deserialization.
    Metadata = Struct.new(
      :timestamp,
      :headers,
      :key,
      :offset,
      :deserializer,
      :partition,
      :received_at,
      :topic,
      keyword_init: true
    )
  end
end

Version data entries

97 entries across 97 versions & 1 rubygems

Version Path
karafka-2.0.19 lib/karafka/messages/metadata.rb
karafka-2.0.18 lib/karafka/messages/metadata.rb
karafka-2.0.17 lib/karafka/messages/metadata.rb
karafka-2.0.16 lib/karafka/messages/metadata.rb
karafka-2.0.15 lib/karafka/messages/metadata.rb
karafka-2.0.14 lib/karafka/messages/metadata.rb
karafka-2.0.13 lib/karafka/messages/metadata.rb
karafka-2.0.12 lib/karafka/messages/metadata.rb
karafka-2.0.11 lib/karafka/messages/metadata.rb
karafka-2.0.10 lib/karafka/messages/metadata.rb
karafka-2.0.9 lib/karafka/messages/metadata.rb
karafka-2.0.8 lib/karafka/messages/metadata.rb
karafka-2.0.7 lib/karafka/messages/metadata.rb
karafka-2.0.6 lib/karafka/messages/metadata.rb
karafka-2.0.5 lib/karafka/messages/metadata.rb
karafka-2.0.4 lib/karafka/messages/metadata.rb
karafka-2.0.3 lib/karafka/messages/metadata.rb
karafka-2.0.2 lib/karafka/messages/metadata.rb
karafka-2.0.1 lib/karafka/messages/metadata.rb
karafka-2.0.0 lib/karafka/messages/metadata.rb