vendor/gen-rb/cassandra.rb in cassandra-0.5.6.2 vs vendor/gen-rb/cassandra.rb in cassandra-0.6
- old
+ new
@@ -24,10 +24,11 @@
def recv_get()
result = receive_message(Get_result)
return result.success unless result.success.nil?
raise result.ire unless result.ire.nil?
raise result.nfe unless result.nfe.nil?
+ raise result.ue unless result.ue.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get failed: unknown result')
end
def get_slice(keyspace, key, column_parent, predicate, consistency_level)
send_get_slice(keyspace, key, column_parent, predicate, consistency_level)
@@ -41,10 +42,11 @@
def recv_get_slice()
result = receive_message(Get_slice_result)
return result.success unless result.success.nil?
raise result.ire unless result.ire.nil?
raise result.nfe unless result.nfe.nil?
+ raise result.ue unless result.ue.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_slice failed: unknown result')
end
def multiget(keyspace, keys, column_path, consistency_level)
send_multiget(keyspace, keys, column_path, consistency_level)
@@ -57,10 +59,11 @@
def recv_multiget()
result = receive_message(Multiget_result)
return result.success unless result.success.nil?
raise result.ire unless result.ire.nil?
+ raise result.ue unless result.ue.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'multiget failed: unknown result')
end
def multiget_slice(keyspace, keys, column_parent, predicate, consistency_level)
send_multiget_slice(keyspace, keys, column_parent, predicate, consistency_level)
@@ -73,10 +76,11 @@
def recv_multiget_slice()
result = receive_message(Multiget_slice_result)
return result.success unless result.success.nil?
raise result.ire unless result.ire.nil?
+ raise result.ue unless result.ue.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'multiget_slice failed: unknown result')
end
def get_count(keyspace, key, column_parent, consistency_level)
send_get_count(keyspace, key, column_parent, consistency_level)
@@ -89,10 +93,11 @@
def recv_get_count()
result = receive_message(Get_count_result)
return result.success unless result.success.nil?
raise result.ire unless result.ire.nil?
+ raise result.ue unless result.ue.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_count failed: unknown result')
end
def get_key_range(keyspace, column_family, start, finish, count, consistency_level)
send_get_key_range(keyspace, column_family, start, finish, count, consistency_level)
@@ -105,10 +110,11 @@
def recv_get_key_range()
result = receive_message(Get_key_range_result)
return result.success unless result.success.nil?
raise result.ire unless result.ire.nil?
+ raise result.ue unless result.ue.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_key_range failed: unknown result')
end
def insert(keyspace, key, column_path, value, timestamp, consistency_level)
send_insert(keyspace, key, column_path, value, timestamp, consistency_level)
@@ -124,21 +130,21 @@
raise result.ire unless result.ire.nil?
raise result.ue unless result.ue.nil?
return
end
- def batch_mutate(keyspace, batch_mutations, consistency_level)
- send_batch_mutate(keyspace, batch_mutations, consistency_level)
- recv_batch_mutate()
+ def batch_insert(keyspace, key, cfmap, consistency_level)
+ send_batch_insert(keyspace, key, cfmap, consistency_level)
+ recv_batch_insert()
end
- def send_batch_mutate(keyspace, batch_mutations, consistency_level)
- send_message('batch_mutate', Batch_mutate_args, :keyspace => keyspace, :batch_mutations => batch_mutations, :consistency_level => consistency_level)
+ def send_batch_insert(keyspace, key, cfmap, consistency_level)
+ send_message('batch_insert', Batch_insert_args, :keyspace => keyspace, :key => key, :cfmap => cfmap, :consistency_level => consistency_level)
end
- def recv_batch_mutate()
- result = receive_message(Batch_mutate_result)
+ def recv_batch_insert()
+ result = receive_message(Batch_insert_result)
raise result.ire unless result.ire.nil?
raise result.ue unless result.ue.nil?
return
end
@@ -216,10 +222,12 @@
result.success = @handler.get(args.keyspace, args.key, args.column_path, args.consistency_level)
rescue CassandraThrift::InvalidRequestException => ire
result.ire = ire
rescue CassandraThrift::NotFoundException => nfe
result.nfe = nfe
+ rescue CassandraThrift::UnavailableException => ue
+ result.ue = ue
end
write_result(result, oprot, 'get', seqid)
end
def process_get_slice(seqid, iprot, oprot)
@@ -229,10 +237,12 @@
result.success = @handler.get_slice(args.keyspace, args.key, args.column_parent, args.predicate, args.consistency_level)
rescue CassandraThrift::InvalidRequestException => ire
result.ire = ire
rescue CassandraThrift::NotFoundException => nfe
result.nfe = nfe
+ rescue CassandraThrift::UnavailableException => ue
+ result.ue = ue
end
write_result(result, oprot, 'get_slice', seqid)
end
def process_multiget(seqid, iprot, oprot)
@@ -240,10 +250,12 @@
result = Multiget_result.new()
begin
result.success = @handler.multiget(args.keyspace, args.keys, args.column_path, args.consistency_level)
rescue CassandraThrift::InvalidRequestException => ire
result.ire = ire
+ rescue CassandraThrift::UnavailableException => ue
+ result.ue = ue
end
write_result(result, oprot, 'multiget', seqid)
end
def process_multiget_slice(seqid, iprot, oprot)
@@ -251,10 +263,12 @@
result = Multiget_slice_result.new()
begin
result.success = @handler.multiget_slice(args.keyspace, args.keys, args.column_parent, args.predicate, args.consistency_level)
rescue CassandraThrift::InvalidRequestException => ire
result.ire = ire
+ rescue CassandraThrift::UnavailableException => ue
+ result.ue = ue
end
write_result(result, oprot, 'multiget_slice', seqid)
end
def process_get_count(seqid, iprot, oprot)
@@ -262,10 +276,12 @@
result = Get_count_result.new()
begin
result.success = @handler.get_count(args.keyspace, args.key, args.column_parent, args.consistency_level)
rescue CassandraThrift::InvalidRequestException => ire
result.ire = ire
+ rescue CassandraThrift::UnavailableException => ue
+ result.ue = ue
end
write_result(result, oprot, 'get_count', seqid)
end
def process_get_key_range(seqid, iprot, oprot)
@@ -273,10 +289,12 @@
result = Get_key_range_result.new()
begin
result.success = @handler.get_key_range(args.keyspace, args.column_family, args.start, args.finish, args.count, args.consistency_level)
rescue CassandraThrift::InvalidRequestException => ire
result.ire = ire
+ rescue CassandraThrift::UnavailableException => ue
+ result.ue = ue
end
write_result(result, oprot, 'get_key_range', seqid)
end
def process_insert(seqid, iprot, oprot)
@@ -290,21 +308,21 @@
result.ue = ue
end
write_result(result, oprot, 'insert', seqid)
end
- def process_batch_mutate(seqid, iprot, oprot)
- args = read_args(iprot, Batch_mutate_args)
- result = Batch_mutate_result.new()
+ def process_batch_insert(seqid, iprot, oprot)
+ args = read_args(iprot, Batch_insert_args)
+ result = Batch_insert_result.new()
begin
- @handler.batch_mutate(args.keyspace, args.batch_mutations, args.consistency_level)
+ @handler.batch_insert(args.keyspace, args.key, args.cfmap, args.consistency_level)
rescue CassandraThrift::InvalidRequestException => ire
result.ire = ire
rescue CassandraThrift::UnavailableException => ue
result.ue = ue
end
- write_result(result, oprot, 'batch_mutate', seqid)
+ write_result(result, oprot, 'batch_insert', seqid)
end
def process_remove(seqid, iprot, oprot)
args = read_args(iprot, Remove_args)
result = Remove_result.new()
@@ -375,16 +393,18 @@
class Get_result
include ::Thrift::Struct
SUCCESS = 0
IRE = 1
NFE = 2
+ UE = 3
- ::Thrift::Struct.field_accessor self, :success, :ire, :nfe
+ ::Thrift::Struct.field_accessor self, :success, :ire, :nfe, :ue
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => CassandraThrift::ColumnOrSuperColumn},
IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException},
- NFE => {:type => ::Thrift::Types::STRUCT, :name => 'nfe', :class => CassandraThrift::NotFoundException}
+ NFE => {:type => ::Thrift::Types::STRUCT, :name => 'nfe', :class => CassandraThrift::NotFoundException},
+ UE => {:type => ::Thrift::Types::STRUCT, :name => 'ue', :class => CassandraThrift::UnavailableException}
}
def struct_fields; FIELDS; end
def validate
@@ -422,16 +442,18 @@
class Get_slice_result
include ::Thrift::Struct
SUCCESS = 0
IRE = 1
NFE = 2
+ UE = 3
- ::Thrift::Struct.field_accessor self, :success, :ire, :nfe
+ ::Thrift::Struct.field_accessor self, :success, :ire, :nfe, :ue
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => CassandraThrift::ColumnOrSuperColumn}},
IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException},
- NFE => {:type => ::Thrift::Types::STRUCT, :name => 'nfe', :class => CassandraThrift::NotFoundException}
+ NFE => {:type => ::Thrift::Types::STRUCT, :name => 'nfe', :class => CassandraThrift::NotFoundException},
+ UE => {:type => ::Thrift::Types::STRUCT, :name => 'ue', :class => CassandraThrift::UnavailableException}
}
def struct_fields; FIELDS; end
def validate
@@ -466,15 +488,17 @@
class Multiget_result
include ::Thrift::Struct
SUCCESS = 0
IRE = 1
+ UE = 2
- ::Thrift::Struct.field_accessor self, :success, :ire
+ ::Thrift::Struct.field_accessor self, :success, :ire, :ue
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::MAP, :name => 'success', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRUCT, :class => CassandraThrift::ColumnOrSuperColumn}},
- IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException}
+ IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException},
+ UE => {:type => ::Thrift::Types::STRUCT, :name => 'ue', :class => CassandraThrift::UnavailableException}
}
def struct_fields; FIELDS; end
def validate
@@ -511,15 +535,17 @@
class Multiget_slice_result
include ::Thrift::Struct
SUCCESS = 0
IRE = 1
+ UE = 2
- ::Thrift::Struct.field_accessor self, :success, :ire
+ ::Thrift::Struct.field_accessor self, :success, :ire, :ue
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::MAP, :name => 'success', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => CassandraThrift::ColumnOrSuperColumn}}},
- IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException}
+ IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException},
+ UE => {:type => ::Thrift::Types::STRUCT, :name => 'ue', :class => CassandraThrift::UnavailableException}
}
def struct_fields; FIELDS; end
def validate
@@ -530,11 +556,11 @@
class Get_count_args
include ::Thrift::Struct
KEYSPACE = 1
KEY = 2
COLUMN_PARENT = 3
- CONSISTENCY_LEVEL = 5
+ CONSISTENCY_LEVEL = 4
::Thrift::Struct.field_accessor self, :keyspace, :key, :column_parent, :consistency_level
FIELDS = {
KEYSPACE => {:type => ::Thrift::Types::STRING, :name => 'keyspace'},
KEY => {:type => ::Thrift::Types::STRING, :name => 'key'},
@@ -554,15 +580,17 @@
class Get_count_result
include ::Thrift::Struct
SUCCESS = 0
IRE = 1
+ UE = 2
- ::Thrift::Struct.field_accessor self, :success, :ire
+ ::Thrift::Struct.field_accessor self, :success, :ire, :ue
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::I32, :name => 'success'},
- IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException}
+ IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException},
+ UE => {:type => ::Thrift::Types::STRUCT, :name => 'ue', :class => CassandraThrift::UnavailableException}
}
def struct_fields; FIELDS; end
def validate
@@ -601,15 +629,17 @@
class Get_key_range_result
include ::Thrift::Struct
SUCCESS = 0
IRE = 1
+ UE = 2
- ::Thrift::Struct.field_accessor self, :success, :ire
+ ::Thrift::Struct.field_accessor self, :success, :ire, :ue
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
- IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException}
+ IRE => {:type => ::Thrift::Types::STRUCT, :name => 'ire', :class => CassandraThrift::InvalidRequestException},
+ UE => {:type => ::Thrift::Types::STRUCT, :name => 'ue', :class => CassandraThrift::UnavailableException}
}
def struct_fields; FIELDS; end
def validate
@@ -662,20 +692,22 @@
def validate
end
end
- class Batch_mutate_args
+ class Batch_insert_args
include ::Thrift::Struct
KEYSPACE = 1
- BATCH_MUTATIONS = 2
- CONSISTENCY_LEVEL = 3
+ KEY = 2
+ CFMAP = 3
+ CONSISTENCY_LEVEL = 4
- ::Thrift::Struct.field_accessor self, :keyspace, :batch_mutations, :consistency_level
+ ::Thrift::Struct.field_accessor self, :keyspace, :key, :cfmap, :consistency_level
FIELDS = {
KEYSPACE => {:type => ::Thrift::Types::STRING, :name => 'keyspace'},
- BATCH_MUTATIONS => {:type => ::Thrift::Types::LIST, :name => 'batch_mutations', :element => {:type => ::Thrift::Types::STRUCT, :class => CassandraThrift::BatchMutation}},
+ KEY => {:type => ::Thrift::Types::STRING, :name => 'key'},
+ CFMAP => {:type => ::Thrift::Types::MAP, :name => 'cfmap', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::LIST, :element => {:type => ::Thrift::Types::STRUCT, :class => CassandraThrift::ColumnOrSuperColumn}}},
CONSISTENCY_LEVEL => {:type => ::Thrift::Types::I32, :name => 'consistency_level', :default => 0, :enum_class => CassandraThrift::ConsistencyLevel}
}
def struct_fields; FIELDS; end
@@ -685,10 +717,10 @@
end
end
end
- class Batch_mutate_result
+ class Batch_insert_result
include ::Thrift::Struct
IRE = 1
UE = 2
::Thrift::Struct.field_accessor self, :ire, :ue