pools.gearman_cluster.main

glimpse.pools.gearman_cluster.main.KillWorkers(config)

Send a quit command to all workers running on the cluster.

Parameters:config (ConfigParser) – Configuration information for cluster.

glimpse.pools.gearman_cluster.main.LaunchBroker(config)

Start a set of intermediate devices for the cluster on this machine.

This method does not return.

Parameters:config (ConfigParser) – Configuration information for cluster.

glimpse.pools.gearman_cluster.main.LaunchWorker(config, num_processes=None)

Start a cluster worker on the local host.

This method does not return.

Parameters:

• config (ConfigParser) – Configuration information for cluster.
• num_processes (int) – Number of sub-processes to use.

glimpse.pools.gearman_cluster.main.PingWorkers(config, wait_time=None)

Determine the set of active workers and print results to console.

Parameters:

• config (ConfigParser) – Configuration information for cluster.
• wait_time (int) – Amount of time to wait for responses, in seconds.

glimpse.pools.gearman_cluster.main.RestartWorkers(config)

Send a restart command to any workers running on cluster.

Parameters:config (ConfigParser) – Configuration information for cluster.

glimpse.pools.gearman_cluster.main.SendCommand(command_url, command)

Send an arbitrary command to all workers running on the cluster.

Parameters:

• command_url (str) – URL of command channel.
• command – Command to send to workers.