class Swcdb::Thrift::Gen::Service::Processor

Public Instance Methods

process_compact_columns(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 544
def process_compact_columns(seqid, iprot, oprot)
  args = read_args(iprot, Compact_columns_args)
  result = Compact_columns_result.new()
  begin
    result.success = @handler.compact_columns(args.spec)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'compact_columns', seqid)
end
process_exec_sql(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 467
def process_exec_sql(seqid, iprot, oprot)
  args = read_args(iprot, Exec_sql_args)
  result = Exec_sql_result.new()
  begin
    result.success = @handler.exec_sql(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'exec_sql', seqid)
end
process_list_columns(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 533
def process_list_columns(seqid, iprot, oprot)
  args = read_args(iprot, List_columns_args)
  result = List_columns_result.new()
  begin
    result.success = @handler.list_columns(args.spec)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'list_columns', seqid)
end
process_mng_column(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 522
def process_mng_column(seqid, iprot, oprot)
  args = read_args(iprot, Mng_column_args)
  result = Mng_column_result.new()
  begin
    @handler.mng_column(args.func, args.schema)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'mng_column', seqid)
end
process_scan(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 555
def process_scan(seqid, iprot, oprot)
  args = read_args(iprot, Scan_args)
  result = Scan_result.new()
  begin
    result.success = @handler.scan(args.spec)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'scan', seqid)
end
process_scan_rslt_on(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 599
def process_scan_rslt_on(seqid, iprot, oprot)
  args = read_args(iprot, Scan_rslt_on_args)
  result = Scan_rslt_on_result.new()
  begin
    result.success = @handler.scan_rslt_on(args.spec, args.rslt)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'scan_rslt_on', seqid)
end
process_scan_rslt_on_column(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 566
def process_scan_rslt_on_column(seqid, iprot, oprot)
  args = read_args(iprot, Scan_rslt_on_column_args)
  result = Scan_rslt_on_column_result.new()
  begin
    result.success = @handler.scan_rslt_on_column(args.spec)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'scan_rslt_on_column', seqid)
end
process_scan_rslt_on_fraction(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 588
def process_scan_rslt_on_fraction(seqid, iprot, oprot)
  args = read_args(iprot, Scan_rslt_on_fraction_args)
  result = Scan_rslt_on_fraction_result.new()
  begin
    result.success = @handler.scan_rslt_on_fraction(args.spec)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'scan_rslt_on_fraction', seqid)
end
process_scan_rslt_on_key(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 577
def process_scan_rslt_on_key(seqid, iprot, oprot)
  args = read_args(iprot, Scan_rslt_on_key_args)
  result = Scan_rslt_on_key_result.new()
  begin
    result.success = @handler.scan_rslt_on_key(args.spec)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'scan_rslt_on_key', seqid)
end
process_sql_compact_columns(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 390
def process_sql_compact_columns(seqid, iprot, oprot)
  args = read_args(iprot, Sql_compact_columns_args)
  result = Sql_compact_columns_result.new()
  begin
    result.success = @handler.sql_compact_columns(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_compact_columns', seqid)
end
process_sql_list_columns(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 379
def process_sql_list_columns(seqid, iprot, oprot)
  args = read_args(iprot, Sql_list_columns_args)
  result = Sql_list_columns_result.new()
  begin
    result.success = @handler.sql_list_columns(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_list_columns', seqid)
end
process_sql_mng_column(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 368
def process_sql_mng_column(seqid, iprot, oprot)
  args = read_args(iprot, Sql_mng_column_args)
  result = Sql_mng_column_result.new()
  begin
    @handler.sql_mng_column(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_mng_column', seqid)
end
process_sql_query(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 445
def process_sql_query(seqid, iprot, oprot)
  args = read_args(iprot, Sql_query_args)
  result = Sql_query_result.new()
  begin
    result.success = @handler.sql_query(args.sql, args.rslt)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_query', seqid)
end
process_sql_select(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 401
def process_sql_select(seqid, iprot, oprot)
  args = read_args(iprot, Sql_select_args)
  result = Sql_select_result.new()
  begin
    result.success = @handler.sql_select(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_select', seqid)
end
process_sql_select_rslt_on_column(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 412
def process_sql_select_rslt_on_column(seqid, iprot, oprot)
  args = read_args(iprot, Sql_select_rslt_on_column_args)
  result = Sql_select_rslt_on_column_result.new()
  begin
    result.success = @handler.sql_select_rslt_on_column(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_select_rslt_on_column', seqid)
end
process_sql_select_rslt_on_fraction(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 434
def process_sql_select_rslt_on_fraction(seqid, iprot, oprot)
  args = read_args(iprot, Sql_select_rslt_on_fraction_args)
  result = Sql_select_rslt_on_fraction_result.new()
  begin
    result.success = @handler.sql_select_rslt_on_fraction(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_select_rslt_on_fraction', seqid)
end
process_sql_select_rslt_on_key(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 423
def process_sql_select_rslt_on_key(seqid, iprot, oprot)
  args = read_args(iprot, Sql_select_rslt_on_key_args)
  result = Sql_select_rslt_on_key_result.new()
  begin
    result.success = @handler.sql_select_rslt_on_key(args.sql)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_select_rslt_on_key', seqid)
end
process_sql_update(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 456
def process_sql_update(seqid, iprot, oprot)
  args = read_args(iprot, Sql_update_args)
  result = Sql_update_result.new()
  begin
    @handler.sql_update(args.sql, args.updater_id)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'sql_update', seqid)
end
process_update(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 500
def process_update(seqid, iprot, oprot)
  args = read_args(iprot, Update_args)
  result = Update_result.new()
  begin
    @handler.update(args.cells, args.updater_id)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'update', seqid)
end
process_update_serial(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 511
def process_update_serial(seqid, iprot, oprot)
  args = read_args(iprot, Update_serial_args)
  result = Update_serial_result.new()
  begin
    @handler.update_serial(args.cells, args.updater_id)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'update_serial', seqid)
end
process_updater_close(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 489
def process_updater_close(seqid, iprot, oprot)
  args = read_args(iprot, Updater_close_args)
  result = Updater_close_result.new()
  begin
    @handler.updater_close(args.id)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'updater_close', seqid)
end
process_updater_create(seqid, iprot, oprot) click to toggle source
# File lib/swcdb/thrift/gen/service.rb, line 478
def process_updater_create(seqid, iprot, oprot)
  args = read_args(iprot, Updater_create_args)
  result = Updater_create_result.new()
  begin
    result.success = @handler.updater_create(args.buffer_size)
  rescue ::Swcdb::Thrift::Gen::Exception => e
    result.e = e
  end
  write_result(result, oprot, 'updater_create', seqid)
end