class Conjur::PolicyLoaderJob
Public Instance Methods
abort()
click to toggle source
# File lib/conjur/policy_loader_job.rb, line 26 def abort self.delete end
follow_output(&block)
click to toggle source
# File lib/conjur/policy_loader_job.rb, line 30 def follow_output &block require 'conjur/event_source' opts = options.dup.tap{|h| h[:headers][:accept] = "text/event-stream"} block_response = lambda do |response| response.error! unless response.code == "200" es = EventSource.new es.json = false es.message{|e| block[e] } response.read_body do |chunk| es.feed chunk end end RestClient::Request.execute( url: self['output'].url, headers: opts[:headers], method: :get, block_response: block_response ) end