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.40 lib/karafka/messages/metadata.rb
karafka-2.0.39 lib/karafka/messages/metadata.rb
karafka-2.0.38 lib/karafka/messages/metadata.rb
karafka-2.0.37 lib/karafka/messages/metadata.rb
karafka-2.0.36 lib/karafka/messages/metadata.rb
karafka-2.0.35 lib/karafka/messages/metadata.rb
karafka-2.0.34 lib/karafka/messages/metadata.rb
karafka-2.0.33 lib/karafka/messages/metadata.rb
karafka-2.0.32 lib/karafka/messages/metadata.rb
karafka-2.0.31 lib/karafka/messages/metadata.rb
karafka-2.0.30 lib/karafka/messages/metadata.rb
karafka-2.0.29 lib/karafka/messages/metadata.rb
karafka-2.0.28 lib/karafka/messages/metadata.rb
karafka-2.0.27 lib/karafka/messages/metadata.rb
karafka-2.0.26 lib/karafka/messages/metadata.rb
karafka-2.0.24 lib/karafka/messages/metadata.rb
karafka-2.0.23 lib/karafka/messages/metadata.rb
karafka-2.0.22 lib/karafka/messages/metadata.rb
karafka-2.0.21 lib/karafka/messages/metadata.rb
karafka-2.0.20 lib/karafka/messages/metadata.rb