mirror of
https://github.com/jimeh/redistat.git
synced 2026-02-19 13:26:39 +00:00
Jim Myhrberg
18e6125c6a
the code, so models can connect to specific Redis servers. I believe a lot of the code needs some restructuring at some point down the line to handle multiple connections in a cleaner way, but for now it'll do.
69 lines
1.4 KiB
Ruby
69 lines
1.4 KiB
Ruby
module Redistat
|
|
module Model
|
|
include Redistat::Database
|
|
|
|
def self.included(base)
|
|
base.extend(self)
|
|
end
|
|
|
|
def store(label, stats = {}, date = nil, meta = {}, opts = {})
|
|
Event.new(name, label, date, stats, options.merge(opts), meta).save
|
|
end
|
|
alias :event :store
|
|
|
|
def connect_to(opts = {})
|
|
Connection.create(opts.merge(:ref => name))
|
|
options[:connection_ref] = name
|
|
end
|
|
|
|
def connection
|
|
db(options[:connection_ref])
|
|
end
|
|
alias :redis :connection
|
|
|
|
def fetch(label, from, till, opts = {})
|
|
Finder.find({
|
|
:scope => name,
|
|
:label => label,
|
|
:from => from,
|
|
:till => till
|
|
}.merge(options.merge(opts)))
|
|
end
|
|
alias :lookup :fetch
|
|
|
|
def hashed_label(boolean = nil)
|
|
if !boolean.nil?
|
|
options[:hashed_label] = boolean
|
|
else
|
|
options[:hashed_label] || nil
|
|
end
|
|
end
|
|
|
|
def depth(depth = nil)
|
|
if !depth.nil?
|
|
options[:depth] = depth
|
|
else
|
|
options[:depth] || nil
|
|
end
|
|
end
|
|
|
|
def store_event(boolean = nil)
|
|
if !boolean.nil?
|
|
options[:store_event] = boolean
|
|
else
|
|
options[:store_event] || nil
|
|
end
|
|
end
|
|
|
|
def options
|
|
@options ||= {}
|
|
end
|
|
|
|
private
|
|
|
|
def name
|
|
@name ||= self.to_s
|
|
end
|
|
|
|
end
|
|
end |