Sha256: 5472c1eef8b30b051705d2a601d71a53973f4c9991705a7da6a49a21210b267c
Contents?: true
Size: 1.09 KB
Versions: 12
Compression:
Stored size: 1.09 KB
Contents
module Riak class Client class Node # Represents a single riak node in a cluster. include Util::Translation include Util::Escape VALID_OPTIONS = [:host, :pb_port] # For a score which halves in 10 seconds, choose # ln(1/2)/10 ERRORS_DECAY_RATE = Math.log(0.5)/10 # What IP address or hostname does this node listen on? attr_accessor :host # Which port does the protocol buffers interface listen on? attr_accessor :pb_port # A Decaying rate of errors. attr_reader :error_rate def initialize(client, opts = {}) @client = client @host = opts[:host] || "127.0.0.1" @pb_port = opts[:pb_port] || 8087 @error_rate = Decaying.new end def ==(o) o.kind_of? Node and @host == o.host and @pb_port == o.pb_port end # Can this node be used for protocol buffers requests? def protobuffs? # TODO: Need to sort out capabilities true end def inspect "#<Node #{@host}:#{@pb_port}>" end end end end
Version data entries
12 entries across 12 versions & 2 rubygems