Script cluster_merge :: Class Merger

[frames] | no frames]

Class Merger

Handling the merge.

Instance Methods

[hide private]

__init__(self, clusters, pause_period, groups)
Initialize object with sane defaults and infos required.

Setup(self)
Sets up our end so we can do the merger.

_PrepareAuthorizedKeys(self)
Prepare the authorized_keys on every merging node.

_RunCmd(self, hostname, command, user="root", use_cluster_key=False, strict_host_check=False, private_key=None, batch=True, ask_key=False)
Wrapping SshRunner.Run with default parameters.

_StopMergingInstances(self)
Stop instances on merging clusters.

_DisableWatcher(self)
Disable watch on all merging clusters, including ourself.

_StopDaemons(self)
Stop all daemons on merging nodes.

_FetchRemoteConfig(self)
Fetches and stores remote cluster config from the master.

_KillMasterDaemon(self)
Kills the local master daemon.

_MergeConfig(self)
Merges all foreign config into our own config.

_MergeClusterConfigs(self, my_config, other_config)
Checks that all relevant cluster parameters are compatible

_GetOsHypervisor(self, cluster, os_name, hyp)

_MergeNodeGroups(self, my_config, other_config)
Adds foreign node groups

_StartMasterDaemon(self, no_vote=False)
Starts the local master daemon.

_ReaddMergedNodesAndRedist(self)
Readds all merging nodes and make sure their config is up-to-date.

_StartupAllInstances(self)
Starts up all instances (locally).

_VerifyCluster(self)
Runs gnt-cluster verify to verify the health.

Merge(self)
Does the actual merge.

Cleanup(self)
Clean up our environment.

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, clusters, pause_period, groups)
(Constructor)

Initialize object with sane defaults and infos required.

Parameters:

clusters - The list of clusters to merge in
pause_period - The time watcher shall be disabled for
groups - How to handle group conflicts

Overrides: object.__init__

Setup(self)

Sets up our end so we can do the merger.

This method is setting us up as a preparation for the merger. It makes the initial contact and gathers information needed.

Raises:

errors.RemoteError - for errors in communication/grabbing

_PrepareAuthorizedKeys(self)

Prepare the authorized_keys on every merging node.

This method add our public key to remotes authorized_key for further communication.

_RunCmd(self, hostname, command, user="root", use_cluster_key=False, strict_host_check=False, private_key=None, batch=True, ask_key=False)

Wrapping SshRunner.Run with default parameters.

For explanation of parameters see ganeti.ssh.SshRunner.Run.

_FetchRemoteConfig(self)

Fetches and stores remote cluster config from the master.

This step is needed before we can merge the config.

_KillMasterDaemon(self)

Kills the local master daemon.

Raises:

errors.CommandError - If unable to kill

_MergeNodeGroups(self, my_config, other_config)

Adds foreign node groups

ConfigWriter.AddNodeGroup takes care of making sure there are no conflicts.

_StartMasterDaemon(self, no_vote=False)

Starts the local master daemon.

Parameters:

no_vote - Should the masterd started without voting? default: False

Raises:

errors.CommandError - If unable to start daemon.

_ReaddMergedNodesAndRedist(self)

Readds all merging nodes and make sure their config is up-to-date.

Raises:

errors.CommandError - If anything fails.

_StartupAllInstances(self)

Starts up all instances (locally).

Raises:

errors.CommandError - If unable to start clusters

_VerifyCluster(self)

Runs gnt-cluster verify to verify the health.

Raises:

errors.ProgrammError - If cluster fails on verification

Merge(self)

Does the actual merge.

It runs all the steps in the right order and updates the user about steps taken. Also it keeps track of rollback_steps to undo everything.

Cleanup(self)

Clean up our environment.

This cleans up remote private keys and configs and after that deletes the temporary directory.

Class Merger

__init__(self, clusters, pause_period, groups) (Constructor)

Setup(self)

_PrepareAuthorizedKeys(self)

_RunCmd(self, hostname, command, user="root", use_cluster_key=False, strict_host_check=False, private_key=None, batch=True, ask_key=False)

_FetchRemoteConfig(self)

_KillMasterDaemon(self)

_MergeNodeGroups(self, my_config, other_config)

_StartMasterDaemon(self, no_vote=False)

_ReaddMergedNodesAndRedist(self)

_StartupAllInstances(self)

_VerifyCluster(self)

Merge(self)

Cleanup(self)

init(self, clusters, pause_period, groups)
(Constructor)