Contents

# frozen_string_literal: true

module Karafka
  module Instrumentation
    module Callbacks
      # Callback that is triggered when oauth token needs to be refreshed.
      class OauthbearerTokenRefresh
        # @param bearer [Rdkafka::Consumer, Rdkafka::Admin] given rdkafka instance. It is needed as
        #   we need to have a reference to call `#oauthbearer_set_token` or
        #   `#oauthbearer_set_token_failure` upon the event.
        def initialize(bearer)
          @bearer = bearer
        end

        # @param _rd_config [Rdkafka::Config]
        # @param bearer_name [String] name of the bearer for which we refresh
        def call(_rd_config, bearer_name)
          return unless @bearer.name == bearer_name

          ::Karafka.monitor.instrument(
            'oauthbearer.token_refresh',
            bearer: @bearer,
            caller: self
          )
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
karafka-2.4.0.rc1	lib/karafka/instrumentation/callbacks/oauthbearer_token_refresh.rb
karafka-2.4.0.beta2	lib/karafka/instrumentation/callbacks/oauthbearer_token_refresh.rb
karafka-2.4.0.beta1	lib/karafka/instrumentation/callbacks/oauthbearer_token_refresh.rb