Contents

require 'java'
require 'logstash-input-nakadi_jars.rb'
java_import org.zalando.stups.tokens.Tokens

class OAuth
  def initialize
    access_token_url = java.net.URI.new("https://token.services.auth.zalando.com/oauth2/access_token?realm=/services")
    token_info_url = java.net.URI.new("https://info.services.auth.zalando.com/oauth2/tokeninfo")
    manager_builder = org.zalando.stups.tokens.Tokens.createAccessTokensWithUri(access_token_url).tokenInfoUri(token_info_url)
    manager_builder.manageToken("nakadi").done
    @manager = manager_builder.start
  end

  def stop
    @manager.stop
  end

  def token
    @manager.get("nakadi")
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
logstash-input-nakadi-elk24-0.3.0	lib/oauth/oauth.rb
logstash-input-nakadi-0.3.0	lib/oauth/oauth.rb
logstash-input-nakadi-0.2.1	lib/oauth/oauth.rb
logstash-input-nakadi-0.1.0	lib/oauth/oauth.rb