Sha256: dcc225294848942aba8ab67c344817c61867b508bca82210eeeab0c7b61e8a1c
Contents?: true
Size: 720 Bytes
Versions: 6
Compression:
Stored size: 720 Bytes
Contents
require 'json'
module Baleen
module Message
module Response
class RunnerFinish < Base
def initialize(opt = {})
super()
@params[:status_code] = opt[:status_code]
@params[:log ] = opt[:log]
@params[:container_id ] = opt[:container_id]
@params[:file] = opt[:file]
end
end
class JobComplete < Base
include Baleen::Message
def initialize(opt = {})
super()
@params[:status] = opt[:status]
@params[:results] = opt[:results]
end
def result
JSON.parse(@params[:results]).map {|r| symbolize_keys(r) }
end
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems