def CreateRPC(service='datastore_v3', deadline=None, callback=None, read_policy=None):
 assert (service == 'datastore_v3')
 conn = _GetConnection()
 config = None
 if (deadline is not None):
  config = datastore_rpc.Configuration(deadline=deadline)
 rpc = conn._create_rpc(config)
 rpc.callback = callback
 if (read_policy is not None):
  rpc.read_policy = read_policy
 return rpc

def CreateRPC ( service = 'datastore_v3' , deadline = None , callback = None , read_policy = None ) : assert ( service == 'datastore_v3' ) conn = _GetConnection ( ) config = None if ( deadline is not None ) : config = datastore_rpc . Configuration ( deadline = deadline ) rpc = conn . _create_rpc ( config ) rpc . callback = callback if ( read_policy is not None ) : rpc . read_policy = read_policy return rpc
creates a rpc instance for the given service .