Class: Mongo::Cluster::Topology::ReplicaSet

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/mongo/cluster/topology/replica_set.rb

Overview

Defines behaviour when a cluster is in replica set topology.

Since:

  • 2.0.0

Constant Summary collapse

REPLICA_SET_NAME =

Constant for the replica set name configuration option.

Since:

  • 2.0.0

:replica_set.freeze
NAME =

The display name for the topology.

Since:

  • 2.0.0

'Replica Set'.freeze

Constants included from Loggable

Loggable::PREFIX

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Loggable

#log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger

Constructor Details

#initialize(options, seeds = []) ⇒ ReplicaSet

Initialize the topology with the options.

Examples:

Initialize the topology.

ReplicaSet.new(options)

Parameters:

  • options (Hash) —

    The options.

Since:

  • 2.0.0



90
91
92
93
94
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 90

def initialize(options, seeds = [])
  @options = options
  @max_election_id = nil
  @max_set_version = nil
end

Instance Attribute Details

#options ⇒ Hash (readonly)

Returns options The options.

Returns:

  • (Hash) —

    options The options.

Since:

  • 2.0.0



31
32
33
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 31

def options
  @options
end

Instance Method Details

#add_hosts?(description, servers) ⇒ true, false

Whether a server description’s hosts may be added to the cluster.

Examples:

Check if a description’s hosts may be added to the cluster.

topology.add_hosts?(description, servers)

Parameters:

Returns:

  • (true, false) —

    Whether a description’s hosts may be added.

Since:

  • 2.0.6



146
147
148
149
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 146

def add_hosts?(description, servers)
  !!(member_of_this_set?(description) &&
      (!has_primary?(servers) || description.primary?))
end

#display_name ⇒ String

Get the display name.

Examples:

Get the display name.

ReplicaSet.display_name

Returns:

  • (String) —

    The display name.

Since:

  • 2.0.0



46
47
48
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 46

def display_name
  NAME
end

#elect_primary(description, servers) ⇒ ReplicaSet

Elect a primary server within this topology.

Examples:

Elect a primary server.

topology.elect_primary(description, servers)

Parameters:

  • description (Server::Description) —

    The description of the elected primary.

  • servers (Array<Server>) —

    The list of known servers to the cluster.

Returns:

Since:

  • 2.0.0



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 61

def elect_primary(description, servers)
  if description.replica_set_name == replica_set_name
    unless detect_stale_primary!(description)
      log_debug("Server #{description.address.to_s} elected as primary in #{replica_set_name}.")
      servers.each do |server|
        if server.primary? && server.address != description.address
          server.description.unknown!
        end
      end
      update_max_election_id(description)
      update_max_set_version(description)
    end
  else
    log_warn(
      "Server #{description.address.to_s} has incorrect replica set name: " +
      "'#{description.replica_set_name}'. The current replica set name is '#{replica_set_name}'."
    )
  end
  self
end

#remove_hosts?(description) ⇒ true, false

Whether a description can be used to remove hosts from the cluster.

Examples:

Check if a description can be used to remove hosts from the cluster.

topology.remove_hosts?(description)

Parameters:

Returns:

  • (true, false) —

    Whether hosts may be removed from the cluster.

Since:

  • 2.0.6



161
162
163
164
165
166
167
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 161

def remove_hosts?(description)
  !description.config.empty? &&
    (description.primary? ||
      description.me_mismatch? ||
        description.hosts.empty? ||
          !member_of_this_set?(description))
end

#remove_server?(description, server) ⇒ true, false

Whether a specific server in the cluster can be removed, given a description.

Examples:

Check if a specific server can be removed from the cluster.

topology.remove_server?(description, server)

Parameters:

Returns:

  • (true, false) —

    Whether the server can be removed from the cluster.

Since:

  • 2.0.6



180
181
182
183
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 180

def remove_server?(description, server)
  remove_self?(description, server) ||
    (member_of_this_set?(description) && !description.lists_server?(server))
end

#replica_set? ⇒ true

A replica set topology is a replica set.

Examples:

Is the topology a replica set?

ReplicaSet.replica_set?

Returns:

  • (true) —

    Always true.

Since:

  • 2.0.0



104
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 104

def replica_set?; true; end

#replica_set_name ⇒ String

Get the replica set name configured for this topology.

Examples:

Get the replica set name.

topology.replica_set_name

Returns:

  • (String) —

    The name of the configured replica set.

Since:

  • 2.0.0



114
115
116
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 114

def replica_set_name
  @replica_set_name ||= options[REPLICA_SET_NAME]
end

#servers(servers) ⇒ Array<Server>

Select appropriate servers for this topology.

Examples:

Select the servers.

ReplicaSet.servers(servers)

Parameters:

  • servers (Array<Server>) —

    The known servers.

Returns:

  • (Array<Server>) —

    The servers in the replica set.

Since:

  • 2.0.0



128
129
130
131
132
133
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 128

def servers(servers)
  servers.select do |server|
    (replica_set_name.nil? || server.replica_set_name == replica_set_name) &&
      server.primary? || server.secondary?
  end
end

#sharded? ⇒ false

A replica set topology is not sharded.

Examples:

Is the topology sharded?

ReplicaSet.sharded?

Returns:

  • (false) —

    Always false.

Since:

  • 2.0.0



193
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 193

def sharded?; false; end

#single? ⇒ false

A replica set topology is not single.

Examples:

Is the topology single?

ReplicaSet.single?

Returns:

  • (false) —

    Always false.

Since:

  • 2.0.0



203
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 203

def single?; false; end

#standalone_discovered ⇒ Topology::ReplicaSet

Notify the topology that a standalone was discovered.

Examples:

Notify the topology that a standalone was discovered.

topology.standalone_discovered

Returns:

Since:

  • 2.0.6



223
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 223

def standalone_discovered; self; end

#unknown? ⇒ false

A replica set topology is not unknown.

Examples:

Is the topology unknown?

ReplicaSet.unknown?

Returns:

  • (false) —

    Always false.

Since:

  • 2.0.0



213
 
# File 'lib/mongo/cluster/topology/replica_set.rb', line 213

def unknown?; false; end