Class: Lacquer::Varnish

Inherits:
Object
  • Object
show all
Defined in:
lib/lacquer/varnish.rb

Instance Method Summary collapse

Instance Method Details

#purge(path) ⇒ Object 



15
16
17
18
19
 
# File 'lib/lacquer/varnish.rb', line 15

def purge(path)
  send_command('url.purge ' << path).all? do |result|
    result =~ /200/
  end
end

#send_command(command) ⇒ Object

Sends commands over telnet to varnish servers listed in the config.



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/lacquer/varnish.rb', line 24

def send_command(command)
  Lacquer.configuration.varnish_servers.collect do |server|
    # RAILS_DEFAULT_LOGGER.debug("POSTEROUS_LACQUER_DEBUG: running(#{command.inspect}) on #{server.inspect}")
    retries = 0
    response = nil
    begin
      retries += 1
      connection = Net::Telnet.new(
        'Host' => server[:host],
        'Port' => server[:port],
        'Timeout' => server[:timeout] || 5)
      connection.cmd(command + "\nquit\n") {|r| response = r.strip}
      connection.close
    rescue Exception => e
      if retries < Lacquer.configuration.retries
        retry
      else
        if Lacquer.configuration.command_error_handler
          Lacquer.configuration.command_error_handler.call({
           :error_class   => "Varnish Error, retried #{Lacquer.configuration.retries} times",
           :error_message => "Error while trying to connect to #{server[:host]}:#{server[:port]}: #{e}",
           :parameters    => server,
           :response      => response})
        else
          raise VarnishError.new("Error while trying to connect to #{server[:host]}:#{server[:port]} #{e}")
        end
      end        
    end
    response
  end
end

#stats ⇒ Object 



3
4
5
6
7
8
9
10
11
12
13
 
# File 'lib/lacquer/varnish.rb', line 3

def stats
  send_command('stats').collect do |stats|
    stats = stats.split("\n")
    stats.shift
  
    stats = stats.collect do |stat|
      stat = stat.strip.match(/(\d+)\s+(.+)$/)
      { :key => stat[2], :value => stat[1] } if stat
    end
  end
end