Package cobra :: Module cluster
[hide private]
[frames] | no frames]

Module cluster

source code

Cobra's built in clustering framework

Classes [hide private]
  InvalidInProgWorkId
  ClusterWork
Extend this object to create your own work units.
  ClusterCallback
Place one of these in the ClusterServer to get synchronous event information about what's going on in the cluster server.
  VerboseCallback
  ClusterServer
  ClusterClient
Listen for our name (or any name if name=="*") on the cobra cluster multicast address and if we find a server in need, go help.
  ClusterQueen
Functions [hide private]
 
getHostPortFromUri(uri)
Take the server URI and pull out the host and port for use in building the dcode uri.
source code
 
workThread(server, work) source code
 
runAndWaitWork(server, work) source code
 
getAndDoWork(uri, docode=False) source code
Variables [hide private]
  queen_port = 32124
  cluster_port = 32123
  cluster_ip = "224.69.69.69"
  sub_cmd = ...
Variables Details [hide private]

sub_cmd

Value:
"""
import cobra.cluster
cobra.cluster.getAndDoWork("%s", docode=%s)
"""