Class: Flock::Edges::FlockDB::Processor

Inherits:

Object

• Object
• Flock::Edges::FlockDB::Processor

Includes:

Thrift::Processor

Defined in:

lib/flock/gen-rb/flock_d_b.rb

Instance Method Summary

• #process_contains(seqid, iprot, oprot) ⇒ Object
• #process_contains_metadata(seqid, iprot, oprot) ⇒ Object
• #process_count(seqid, iprot, oprot) ⇒ Object
• #process_count2(seqid, iprot, oprot) ⇒ Object
• #process_execute(seqid, iprot, oprot) ⇒ Object
• #process_get(seqid, iprot, oprot) ⇒ Object
• #process_get_metadata(seqid, iprot, oprot) ⇒ Object
• #process_select(seqid, iprot, oprot) ⇒ Object
• #process_select2(seqid, iprot, oprot) ⇒ Object
• #process_select_edges(seqid, iprot, oprot) ⇒ Object

Instance Method Details

#process_contains(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 180

def process_contains(seqid, iprot, oprot)
  args = read_args(iprot, Contains_args)
  result = Contains_result.new()
  begin
    result.success = @handler.contains(args.source_id, args.graph_id, args.destination_id)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'contains', seqid)
end

#process_contains_metadata(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 213

def process_contains_metadata(seqid, iprot, oprot)
  args = read_args(iprot, Contains_metadata_args)
  result = Contains_metadata_result.new()
  begin
    result.success = @handler.contains_metadata(args.source_id, args.graph_id)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'contains_metadata', seqid)
end

#process_count(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 268

def process_count(seqid, iprot, oprot)
  args = read_args(iprot, Count_args)
  result = Count_result.new()
  begin
    result.success = @handler.count(args.operations)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'count', seqid)
end

#process_count2(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 235

def process_count2(seqid, iprot, oprot)
  args = read_args(iprot, Count2_args)
  result = Count2_result.new()
  begin
    result.success = @handler.count2(args.queries)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'count2', seqid)
end

#process_execute(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 257

def process_execute(seqid, iprot, oprot)
  args = read_args(iprot, Execute_args)
  result = Execute_result.new()
  begin
    @handler.execute(args.operations)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'execute', seqid)
end

#process_get(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 191

def process_get(seqid, iprot, oprot)
  args = read_args(iprot, Get_args)
  result = Get_result.new()
  begin
    result.success = @handler.get(args.source_id, args.graph_id, args.destination_id)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'get', seqid)
end

#process_get_metadata(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 202

def process_get_metadata(seqid, iprot, oprot)
  args = read_args(iprot, Get_metadata_args)
  result = Get_metadata_result.new()
  begin
    result.success = @handler.get_metadata(args.source_id, args.graph_id)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'get_metadata', seqid)
end

#process_select(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 279

def process_select(seqid, iprot, oprot)
  args = read_args(iprot, Select_args)
  result = Select_result.new()
  begin
    result.success = @handler.select(args.operations, args.page)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'select', seqid)
end

#process_select2(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 224

def process_select2(seqid, iprot, oprot)
  args = read_args(iprot, Select2_args)
  result = Select2_result.new()
  begin
    result.success = @handler.select2(args.queries)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'select2', seqid)
end

#process_select_edges(seqid, iprot, oprot) ⇒ Object

# File 'lib/flock/gen-rb/flock_d_b.rb', line 246

def process_select_edges(seqid, iprot, oprot)
  args = read_args(iprot, Select_edges_args)
  result = Select_edges_result.new()
  begin
    result.success = @handler.select_edges(args.queries)
  rescue Flock::Edges::FlockException => ex
    result.ex = ex
  end
  write_result(result, oprot, 'select_edges', seqid)
end