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