Sha256: a9c94ce04a771f06646b0aa4df05d4bf6440164f39fe87dacdca3a495809d707
Contents?: true
Size: 665 Bytes
Versions: 8
Compression:
Stored size: 665 Bytes
Contents
require_relative './ts_cell_codec'
require_relative './operator'
class Riak::Client::BeefcakeProtobuffsBackend
def time_series_delete_operator
TimeSeriesDeleteOperator.new(self)
end
class TimeSeriesDeleteOperator < Operator
def delete(table_name, key_components, options = {})
codec = TsCellCodec.new
request_options = options.merge(table: table_name,
key: codec.cells_for(key_components))
request = TsDelReq.new request_options
backend.protocol do |p|
p.write :TsDelReq, request
p.expect :TsDelResp, TsDelResp, empty_body_acceptable: true
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems