Class: Elasticsearch::Transport::Transport::Connections::Collection

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/elasticsearch/transport/transport/connections/collection.rb

Overview

Wraps the collection of connections for the transport object as an Enumerable object.

See Also:

Constant Summary collapse

DEFAULT_SELECTOR = 
Selector::RoundRobin

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(arguments = {}) ⇒ Collection

Returns a new instance of Collection.

Parameters:

  • arguments (Hash) (defaults to: {}) —

    a customizable set of options

Options Hash (arguments):



23
24
25
26
27
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 23

def initialize(arguments={})
  selector_class = arguments[:selector_class] || DEFAULT_SELECTOR
  @connections   = arguments[:connections]    || []
  @selector      = arguments[:selector]       || selector_class.new(arguments.merge(:connections => self))
end

Instance Attribute Details

#selector ⇒ Object (readonly)

Returns the value of attribute selector.



17
18
19
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 17

def selector
  @selector
end

Instance Method Details

#add(connections) ⇒ self

Add connection(s) to the collection

Parameters:

  • connections (Connection, Array) —

    A connection or an array of connections to add

Returns:

  • (self) 


94
95
96
97
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 94

def add(connections)
  @connections += Array(connections).to_a
  self
end

#all ⇒ Array

Returns an Array of all connections, both dead and alive

Returns:

  • (Array) 


58
59
60
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 58

def all
  @connections
end

#connections ⇒ Array Also known as: alive

Returns an Array of alive connections.

Returns:

  • (Array) 


41
42
43
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 41

def connections
  @connections.reject { |c| c.dead? }
end

#dead ⇒ Array

Returns an Array of dead connections.

Returns:

  • (Array) 


50
51
52
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 50

def dead
  @connections.select { |c| c.dead? }
end

#each(&block) ⇒ Object 



76
77
78
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 76

def each(&block)
  connections.each(&block)
end

#get_connection(options = {}) ⇒ Connection

Returns a connection.

If there are no alive connections, resurrects a connection with least failures. Delegates to selector’s ‘#select` method to get the connection.

Returns:



69
70
71
72
73
74
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 69

def get_connection(options={})
  if connections.empty? && dead_connection = dead.sort { |a,b| a.failures <=> b.failures }.first
    dead_connection.alive!
  end
  selector.select(options)
end

#hosts ⇒ Array

Returns an Array of hosts information in this collection as Hashes.

Returns:

  • (Array) 


33
34
35
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 33

def hosts
  @connections.to_a.map { |c| c.host }
end

#remove(connections) ⇒ self

Remove connection(s) from the collection

Parameters:

  • connections (Connection, Array) —

    A connection or an array of connections to remove

Returns:

  • (self) 


104
105
106
107
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 104

def remove(connections)
  @connections -= Array(connections).to_a
  self
end

#size ⇒ Object 



85
86
87
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 85

def size
  connections.size
end

#slice(*args) ⇒ Object Also known as: [] 



80
81
82
 
# File 'lib/elasticsearch/transport/transport/connections/collection.rb', line 80

def slice(*args)
  connections.slice(*args)
end