module TraceView::Inst::Cassandra
Public Instance Methods
add_column_family_with_traceview(cf_def)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 213 def add_column_family_with_traceview(cf_def) return add_column_family_without_traceview(cf_def) unless TraceView.tracing? report_kvs = extract_trace_details(:add_column_family, nil, nil, nil) begin report_kvs[:Cf] = cf_def[:name] if cf_def.is_a?(Hash) && cf_def.key?(:name) rescue => e TraceView.logger.debug "[traceview/debug] #{__method__}:#{File.basename(__FILE__)}:#{__LINE__}: #{e.message}" if TraceView::Config[:verbose] end TraceView::API.trace(:cassandra, report_kvs) do add_column_family_without_traceview(cf_def) end end
add_keyspace_with_traceview(ks_def)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 238 def add_keyspace_with_traceview(ks_def) return add_keyspace_without_traceview(ks_def) unless TraceView.tracing? report_kvs = extract_trace_details(:add_keyspace, nil, nil, nil) report_kvs[:Name] = ks_def.name rescue '' TraceView::API.trace(:cassandra, report_kvs) do add_keyspace_without_traceview(ks_def) end end
count_columns_with_traceview(column_family, key, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 68 def count_columns_with_traceview(column_family, key, *columns_and_options) args = [column_family, key] + columns_and_options return send :count_columns_without_traceview, *args unless TraceView.tracing? report_kvs = extract_trace_details(:count_columns, column_family, key, columns_and_options) TraceView::API.trace(:cassandra, report_kvs) do send :count_columns_without_traceview, *args end end
create_index_with_traceview(keyspace, column_family, column_name, validation_class)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 178 def create_index_with_traceview(keyspace, column_family, column_name, validation_class) unless TraceView.tracing? return create_index_without_traceview(keyspace, column_family, column_name, validation_class) end report_kvs = extract_trace_details(:create_index, column_family, nil, nil) begin report_kvs[:Keyspace] = keyspace.to_s report_kvs[:Column_name] = column_name.to_s report_kvs[:Validation_class] = validation_class.to_s rescue => e TraceView.logger.debug "[traceview/debug] #{__method__}:#{File.basename(__FILE__)}:#{__LINE__}: #{e.message}" if TraceView::Config[:verbose] end TraceView::API.trace(:cassandra, report_kvs) do create_index_without_traceview(keyspace, column_family, column_name, validation_class) end end
drop_column_family_with_traceview(column_family)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 228 def drop_column_family_with_traceview(column_family) return drop_column_family_without_traceview(column_family) unless TraceView.tracing? report_kvs = extract_trace_details(:drop_column_family, column_family, nil, nil) TraceView::API.trace(:cassandra, report_kvs) do drop_column_family_without_traceview(column_family) end end
drop_index_with_traceview(keyspace, column_family, column_name)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 197 def drop_index_with_traceview(keyspace, column_family, column_name) return drop_index_without_traceview(keyspace, column_family, column_name) unless TraceView.tracing? report_kvs = extract_trace_details(:drop_index, column_family, nil, nil) begin report_kvs[:Keyspace] = keyspace.to_s report_kvs[:Column_name] = column_name.to_s rescue => e TraceView.logger.debug "[traceview/debug] #{__method__}:#{File.basename(__FILE__)}:#{__LINE__}: #{e.message}" if TraceView::Config[:verbose] end TraceView::API.trace(:cassandra, report_kvs) do drop_index_without_traceview(keyspace, column_family, column_name) end end
drop_keyspace_with_traceview(keyspace)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 249 def drop_keyspace_with_traceview(keyspace) return drop_keyspace_without_traceview(keyspace) unless TraceView.tracing? report_kvs = extract_trace_details(:drop_keyspace, nil, nil, nil) report_kvs[:Name] = keyspace.to_s rescue '' TraceView::API.trace(:cassandra, report_kvs) do drop_keyspace_without_traceview(keyspace) end end
exists_with_traceview?(column_family, key, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 132 def exists_with_traceview?(column_family, key, *columns_and_options) args = [column_family, key] + columns_and_options return send :exists_without_traceview?, *args unless TraceView.tracing? report_kvs = extract_trace_details(:exists?, column_family, key, columns_and_options) TraceView::API.trace(:cassandra, report_kvs) do send :exists_without_traceview?, *args end end
extract_trace_details(op, column_family, keys, args, options = {})
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 7 def extract_trace_details(op, column_family, keys, args, options = {}) report_kvs = {} begin report_kvs[:Op] = op.to_s report_kvs[:Cf] = column_family.to_s if column_family report_kvs[:Key] = keys.inspect if keys # Open issue - how to handle multiple Cassandra servers report_kvs[:RemoteHost], report_kvs[:RemotePort] = @servers.first.split(':') report_kvs[:Backtrace] = TraceView::API.backtrace if TraceView::Config[:cassandra][:collect_backtraces] if options.empty? && args.is_a?(Array) options = args.last if args.last.is_a?(Hash) end unless options.empty? [:start_key, :finish_key, :key_count, :batch_size, :columns, :count, :start, :stop, :finish, :finished, :reversed, :consistency, :ttl].each do |k| report_kvs[k.to_s.capitalize] = options[k] if options.key?(k) end if op == :get_indexed_slices index_clause = columns_and_options[:index_clause] || {} unless index_clause.empty? [:column_name, :value, :comparison].each do |k| report_kvs[k.to_s.capitalize] = index_clause[k] if index_clause.key?(k) end end end end rescue => e TraceView.logger.debug "[traceview/debug] #{__method__}:#{File.basename(__FILE__)}:#{__LINE__}: #{e.message}" if TraceView::Config[:verbose] end report_kvs end
get_columns_with_traceview(column_family, key, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 80 def get_columns_with_traceview(column_family, key, *columns_and_options) args = [column_family, key] + columns_and_options if TraceView.tracing? && !TraceView.tracing_layer_op?(:multi_get_columns) report_kvs = extract_trace_details(:get_columns, column_family, key, columns_and_options) TraceView::API.trace(:cassandra, report_kvs) do send :get_columns_without_traceview, *args end else send :get_columns_without_traceview, *args end end
get_indexed_slices_with_traceview(column_family, index_clause, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 166 def get_indexed_slices_with_traceview(column_family, index_clause, *columns_and_options) args = [column_family, index_clause] + columns_and_options return send :get_indexed_slices_without_traceview, *args unless TraceView.tracing? report_kvs = extract_trace_details(:get_indexed_slices, column_family, nil, columns_and_options) TraceView::API.trace(:cassandra, report_kvs) do send :get_indexed_slices_without_traceview, *args end end
get_range_batch_with_traceview(column_family, options = {})
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 156 def get_range_batch_with_traceview(column_family, options = {}) return get_range_batch_without_traceview(column_family, options) unless TraceView.tracing? report_kvs = extract_trace_details(:get_range_batch, column_family, nil, nil) TraceView::API.trace(:cassandra, report_kvs, :get_range_batch) do get_range_batch_without_traceview(column_family, options) end end
get_range_single_with_traceview(column_family, options = {})
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 144 def get_range_single_with_traceview(column_family, options = {}) if TraceView.tracing? && !TraceView.tracing_layer_op?(:get_range_batch) report_kvs = extract_trace_details(:get_range_single, column_family, nil, nil) TraceView::API.trace(:cassandra, report_kvs) do get_range_single_without_traceview(column_family, options) end else get_range_single_without_traceview(column_family, options) end end
get_with_traceview(column_family, key, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 106 def get_with_traceview(column_family, key, *columns_and_options) args = [column_family, key] + columns_and_options return send :get_without_traceview, *args unless TraceView.tracing? report_kvs = extract_trace_details(:get, column_family, key, columns_and_options) TraceView::API.trace(:cassandra, report_kvs, :get) do send :get_without_traceview, *args end end
insert_with_traceview(column_family, key, hash, options = {})
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 46 def insert_with_traceview(column_family, key, hash, options = {}) return insert_without_traceview(column_family, key, hash, options = {}) unless TraceView.tracing? report_kvs = extract_trace_details(:insert, column_family, key, hash, options) TraceView::API.trace(:cassandra, report_kvs) do insert_without_traceview(column_family, key, hash, options = {}) end end
multi_get_columns_with_traceview(column_family, key, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 94 def multi_get_columns_with_traceview(column_family, key, *columns_and_options) args = [column_family, key] + columns_and_options return send :multi_get_columns_without_traceview, *args unless TraceView.tracing? report_kvs = extract_trace_details(:multi_get_columns, column_family, key, columns_and_options) TraceView::API.trace(:cassandra, report_kvs, :multi_get_columns) do send :multi_get_columns_without_traceview, *args end end
multi_get_with_traceview(column_family, key, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 118 def multi_get_with_traceview(column_family, key, *columns_and_options) args = [column_family, key] + columns_and_options if TraceView.tracing? && !TraceView.tracing_layer_op?(:get) report_kvs = extract_trace_details(:multi_get, column_family, key, columns_and_options) TraceView::API.trace(:cassandra, report_kvs) do send :multi_get_without_traceview, *args end else send :multi_get_without_traceview, *args end end
remove_with_traceview(column_family, key, *columns_and_options)
click to toggle source
# File lib/traceview/inst/twitter-cassandra.rb, line 56 def remove_with_traceview(column_family, key, *columns_and_options) args = [column_family, key] + columns_and_options return send :remove_without_traceview, *args unless TraceView.tracing? report_kvs = extract_trace_details(:remove, column_family, key, columns_and_options) TraceView::API.trace(:cassandra, report_kvs) do send :remove_without_traceview, *args end end