Module: Familia

Includes:
Gibbler::Complex
Included in:
Bone, Customer, Limiter, Session
Defined in:
lib/familia.rb,
lib/familia.rb,
lib/familia.rb,
lib/familia/tools.rb,
lib/familia/object.rb,
lib/familia/helpers.rb,
lib/familia/redisobject.rb

Defined Under Namespace

Modules: ClassMethods, Collector, InstanceMethods, Stamps, Status, Tools, VERSION Classes: HashKey, List, NoIndex, NonUniqueKey, NotConnected, Problem, RedisObject, Set, SortedSet, String

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.apiversion(r = nil, &blk) ⇒ Object 



123
124
125
126
127
128
129
130
131
132
133
 
# File 'lib/familia.rb', line 123

def apiversion(r=nil, &blk)  
  if blk.nil?
    @apiversion = r if r; 
  else
    tmp = @apiversion
    @apiversion = r
    blk.call
    @apiversion = tmp
  end
  @apiversion 
end

.clients ⇒ Object (readonly)

Returns the value of attribute clients.



36
37
38
 
# File 'lib/familia.rb', line 36

def clients
  @clients
end

.debug ⇒ Object

Returns the value of attribute debug.



37
38
39
 
# File 'lib/familia.rb', line 37

def debug
  @debug
end

.delim ⇒ Object

Returns the value of attribute delim.



37
38
39
 
# File 'lib/familia.rb', line 37

def delim
  @delim
end

.dump_method ⇒ Object

Returns the value of attribute dump_method.



37
38
39
 
# File 'lib/familia.rb', line 37

def dump_method
  @dump_method
end

.load_method ⇒ Object

Returns the value of attribute load_method.



37
38
39
 
# File 'lib/familia.rb', line 37

def load_method
  @load_method
end

.logger ⇒ Object (readonly)

Returns the value of attribute logger.



36
37
38
 
# File 'lib/familia.rb', line 36

def logger
  @logger
end

.secret ⇒ Object

Returns the value of attribute secret.



37
38
39
 
# File 'lib/familia.rb', line 37

def secret
  @secret
end

.uri ⇒ Object

Returns the value of attribute uri.



36
37
38
 
# File 'lib/familia.rb', line 36

def uri
  @uri
end

Class Method Details

.classes(with_redis_objects = false) ⇒ Object 



43
44
45
 
# File 'lib/familia.rb', line 43

def classes with_redis_objects=false
  with_redis_objects ? [@classes, RedisObject.classes].flatten : @classes
end

.connect(uri = nil) ⇒ Object 



85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'lib/familia.rb', line 85

def connect(uri=nil)
  uri &&= URI.parse uri if String === uri
  uri ||= Familia.uri
  conf = uri.conf
  conf[:thread_safe] = "true" unless conf.has_key?(:thread_safe)
  conf[:thread_safe] = conf[:thread_safe].to_s == "true"
  conf[:logging] = conf[:logging].to_s == "true"
  if conf.has_key?(:logging) && conf[:logging].to_s == "true"
    require 'logger'
    require 'log4r'
    @logger ||= log :DEBUG, "./familia.log"
    conf[:logger] = Familia.logger
  end
  redis = Redis.new conf
  Familia.trace :CONNECT, redis, conf.inspect, caller[0..3] if Familia.debug
  @clients[uri.serverid] = redis
end

.connected?(uri = nil) ⇒ Boolean

Returns:

  • (Boolean) 


108
109
110
111
 
# File 'lib/familia.rb', line 108

def connected?(uri=nil)
  uri &&= URI.parse uri if String === uri
  @clients.has_key?(uri.serverid)
end

.debug? ⇒ Boolean

Returns:

  • (Boolean) 


39
 
# File 'lib/familia.rb', line 39

def debug?() @debug == true end

.default_suffix(a = nil) ⇒ Object 



112
 
# File 'lib/familia.rb', line 112

def default_suffix(a=nil) @suffix = a if a; @suffix end

.default_suffix=(a) ⇒ Object 



113
 
# File 'lib/familia.rb', line 113

def default_suffix=(a) @suffix = a end

.included(obj) ⇒ Object 



159
160
161
162
163
164
165
 
# File 'lib/familia.rb', line 159

def self.included(obj)
  obj.send :include, Familia::InstanceMethods
  obj.send :include, Gibbler::Complex
  obj.extend Familia::ClassMethods
  obj.class_zset :instances, :class => obj, :reference => true
  Familia.classes << obj
end

.index(r = nil) ⇒ Object 



114
 
# File 'lib/familia.rb', line 114

def index(r=nil)  @index = r if r; @index end

.index=(r) ⇒ Object 



115
 
# File 'lib/familia.rb', line 115

def index=(r) @index = r; r end

.info(*msg) ⇒ Object 



40
41
42
 
# File 'lib/familia.rb', line 40

def info *msg
  STDERR.puts *msg
end

.join(*r) ⇒ Object 



116
 
# File 'lib/familia.rb', line 116

def join(*r) r.join(Familia.delim) end

.ld(*msg) ⇒ Object 



46
47
48
 
# File 'lib/familia.rb', line 46

def ld *msg
  info *msg if debug?
end

.log(level, path) ⇒ Object 



79
80
81
82
83
84
 
# File 'lib/familia.rb', line 79

def log(level, path)
  logger = Log4r::Logger.new('familia')
  logger.outputters = Log4r::FileOutputter.new 'familia', :filename => path
  logger.level = Log4r.const_get(level)
  logger
end

.now(n = Time.now) ⇒ Object 



134
135
136
 
# File 'lib/familia.rb', line 134

def now n=Time.now
  n.utc.to_i
end

.qnow(quantum = 10.minutes, now = Familia.now) ⇒ Object

A quantized timestamp e.g. 12:32 -> 12:30



140
141
142
143
 
# File 'lib/familia.rb', line 140

def qnow quantum=10.minutes, now=Familia.now
  rounded = now - (now % quantum)
  Time.at(rounded).utc.to_i
end

.reconnect_all! ⇒ Object 



102
103
104
105
106
107
 
# File 'lib/familia.rb', line 102

def reconnect_all!
  Familia.classes.each do |klass|
    klass.redis.client.reconnect
    Familia.info "#{klass} ping: #{klass.redis.ping}" if debug?
  end
end

.redis(uri = nil) ⇒ Object

A convenience method for returning the appropriate Redis connection. If uri is an Integer, we’ll treat it as a database number. If it’s a String, we’ll treat it as a full URI (e.g. redis://1.2.3.4/15). Otherwise we’ll return the default connection.



67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/familia.rb', line 67

def redis(uri=nil)
  if Integer === uri
    tmp = Familia.uri
    tmp.db = uri
    uri = tmp
  elsif String === uri
    uri &&= URI.parse uri
  end
  uri ||= Familia.uri
  connect(uri) unless @clients[uri.serverid] 
  @clients[uri.serverid]
end

.rediskey(*args) ⇒ Object 



118
119
120
121
122
 
# File 'lib/familia.rb', line 118

def rediskey *args
  el = args.flatten.compact
  el.unshift @apiversion unless @apiversion.nil?
  el.join(Familia.delim)
end

.split(r) ⇒ Object 



117
 
# File 'lib/familia.rb', line 117

def split(r) r.split(Familia.delim) end

.trace(label, redis_client, ident, context = nil) ⇒ Object 



49
50
51
52
53
54
55
56
57
 
# File 'lib/familia.rb', line 49

def trace label, redis_client, ident, context=nil
  return unless Familia.debug?
  info "[%s] %s/%s" % [label, redis_client.uri, ident] 
  if context
    context = [context].flatten
    context.reject! { |line| line =~ /lib\/familia/ }
    info "   %s" % context[0..6].join("\n   ") 
  end
end