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.3.4 lib/karafka/messages/metadata.rb
karafka-2.3.3 lib/karafka/messages/metadata.rb
karafka-2.3.2 lib/karafka/messages/metadata.rb
karafka-2.3.1 lib/karafka/messages/metadata.rb
karafka-2.3.0 lib/karafka/messages/metadata.rb
karafka-2.3.0.rc1 lib/karafka/messages/metadata.rb
karafka-2.3.0.alpha2 lib/karafka/messages/metadata.rb
karafka-2.3.0.alpha1 lib/karafka/messages/metadata.rb
karafka-2.2.14 lib/karafka/messages/metadata.rb
karafka-2.2.13 lib/karafka/messages/metadata.rb
karafka-2.2.12 lib/karafka/messages/metadata.rb
karafka-2.2.11 lib/karafka/messages/metadata.rb
karafka-2.2.10 lib/karafka/messages/metadata.rb
karafka-2.2.9 lib/karafka/messages/metadata.rb
karafka-2.2.8 lib/karafka/messages/metadata.rb
karafka-2.2.8.beta1 lib/karafka/messages/metadata.rb
karafka-2.2.7 lib/karafka/messages/metadata.rb
karafka-2.2.6 lib/karafka/messages/metadata.rb
karafka-2.2.5 lib/karafka/messages/metadata.rb
karafka-2.2.4 lib/karafka/messages/metadata.rb