Sha256: 4a0b7670ceff5c2d54ce77cab205a64fcb3f2365a6c0929ddfd5a171a2b61036
Contents?: true
Size: 800 Bytes
Versions: 8
Compression:
Stored size: 800 Bytes
Contents
require_relative './ts_cell_codec'
require_relative './operator'
class Riak::Client::BeefcakeProtobuffsBackend
def time_series_put_operator
TimeSeriesPutOperator.new(self)
end
class TimeSeriesPutOperator < Operator
def put(table_name, measurements)
rows = rows_for measurements
request = TsPutReq.new table: table_name, rows: rows
backend.protocol do |p|
p.write :TsPutReq, request
p.expect :TsPutResp, TsPutResp, empty_body_acceptable: true
end
end
private
def rows_for(measurements)
codec = TsCellCodec.new
measurements.map do |measurement|
# expect a measurement to be mappable
TsRow.new(cells: measurement.map do |measure|
codec.cell_for measure
end)
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems