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.0.rc6 lib/karafka/messages/metadata.rb
karafka-2.0.0.rc5 lib/karafka/messages/metadata.rb
karafka-2.0.0.rc4 lib/karafka/messages/metadata.rb
karafka-2.0.0.rc3 lib/karafka/messages/metadata.rb
karafka-2.0.0.rc2 lib/karafka/messages/metadata.rb
karafka-2.0.0.rc1 lib/karafka/messages/metadata.rb
karafka-2.0.0.beta5 lib/karafka/messages/metadata.rb
karafka-2.0.0.beta4 lib/karafka/messages/metadata.rb
karafka-2.0.0.beta3 lib/karafka/messages/metadata.rb
karafka-2.0.0.beta2 lib/karafka/messages/metadata.rb
karafka-2.0.0.beta1 lib/karafka/messages/metadata.rb
karafka-2.0.0.alpha6 lib/karafka/messages/metadata.rb
karafka-2.0.0.alpha5 lib/karafka/messages/metadata.rb
karafka-2.0.0.alpha4 lib/karafka/messages/metadata.rb
karafka-2.0.0.alpha3 lib/karafka/messages/metadata.rb
karafka-2.0.0.alpha2 lib/karafka/messages/metadata.rb
karafka-2.0.0.alpha1 lib/karafka/messages/metadata.rb