Sha256: 2ebc9dc5a393f11de4dbc5f38bceccbcf3d6056b90041625d7f7b007261bcc40

Contents?: true

Size: 496 Bytes

Versions: 8

Compression:

Stored size: 496 Bytes

Contents

# frozen_string_literal: true

require_relative "base"

module Kiev
  module Kafka
    require_relative "kafka/context_extractor"
    require_relative "kafka/context_injector"

    class << self
      # @param [Kafka::FetchedMessage] message
      def extract_context(message)
        Kiev::Kafka::ContextExtractor.new.call(message)
      end

      # @param [Hash] headers
      def inject_context(headers = {})
        Kiev::Kafka::ContextInjector.new.call(headers)
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
kiev-4.9.0 lib/kiev/kafka.rb
kiev-4.8.3 lib/kiev/kafka.rb
kiev-4.8.2 lib/kiev/kafka.rb
kiev-4.8.1 lib/kiev/kafka.rb
kiev-4.8.0 lib/kiev/kafka.rb
kiev-4.7.0 lib/kiev/kafka.rb
kiev-4.6.0 lib/kiev/kafka.rb
kiev-4.5.0 lib/kiev/kafka.rb