org.gridbus.broker.common
Class BrokerStorage

java.lang.Object
  extended by org.gridbus.broker.common.BrokerStorage

public final class BrokerStorage
extends java.lang.Object

Author:
Krishna

Method Summary
 void addCredentialMappings(java.lang.String applicationId, java.lang.String credentialID, java.lang.String serviceMappingID)
           
 void addCredentials(java.lang.String applicationId, UserCredential uc)
          Gets appropriate user-credentials from the in-memory collection of credentials.
protected  java.lang.Object clone()
           
 ApplicationContext getApplication(java.lang.String applicationID)
           
 ApplicationContext getApplication(java.lang.String username, java.lang.String appname)
           
 int getCount(java.lang.String hql)
          Gets an integer count returned by the given HQL query.
 UserCredential getCredentialsForService(java.lang.String applicationId, Service s)
          Returns the appropriate credentials from the in-memory credential store for the given service entity
 java.util.List getDataConstraints(java.lang.String applicationID)
           
 Job getJob(java.lang.String applicationID, java.lang.String jobName)
           
 long getJobCount(java.lang.String applicationID, int jobStatus, int jobType, java.lang.String serverName)
          Returns the total number of jobs with the given status, on the given server.
 java.util.List getJobs(java.lang.String applicationID, int[] jobStates, int jobType, java.lang.String serverName)
           
 java.util.List getJobs(java.lang.String applicationID, int jobStatus, int jobType, java.lang.String serverName)
           
 JobStatistics getJobStatistics(java.lang.String applicationId, java.lang.String serverName)
           
 JobStatistics getJobStatistics(java.lang.String applicationId, java.lang.String serverName, int jobType)
           
 java.util.List getList(java.lang.String hqlQuery)
           
 java.util.List getList(java.lang.String hqlQuery, int limit)
           
 Qos getQos(java.lang.String appId)
           
 org.gridbus.scs.common.SCSJob getSCSJob(java.lang.String applicationID, java.lang.String jobName)
           
 long getSCSJobCount(java.lang.String applicationID, int jobStatus, int jobType, java.lang.String serverName)
           
 java.util.List getSCSJobs(java.lang.String applicationID, int[] jobStates, int jobType, java.lang.String serverName)
           
 java.util.List getSCSJobs(java.lang.String applicationID, int jobStatus, int jobType, java.lang.String serverName)
           
 Service getService(java.lang.String applicationID, int serviceType, java.lang.String name)
           
 Service getServiceByHostname(java.lang.String applicationID, java.lang.String hostname)
           
 Service getServiceByMappingId(java.lang.String applicationID, int serviceType, java.lang.String mappingId)
           
 java.util.List getServices(java.lang.String applicationID, int serviceType, java.lang.String filter)
           
 java.util.Collection getUserJobsPaged(java.lang.String applicationID, int pageNumber, int pageSize)
           
 java.util.List getWorkflowTasks(java.lang.String applicationID)
           
 void removeJob(Job savedJob)
           
 void saveApplication(ApplicationContext app)
           
 void saveEvent(BrokerEvent evt)
           
 void saveJob(Job j)
           
 void saveJob(org.gridbus.scs.common.SCSJob j)
           
 void saveNetworkLink(java.lang.String applicationID, NetworkLink nl)
          Saves the network link entity for a given application
 void saveQos(java.lang.String applicationId, Qos qos)
          Updates the qos for a given application
 void saveService(Service s)
           
 
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

clone

protected java.lang.Object clone()
                          throws java.lang.CloneNotSupportedException
Overrides:
clone in class java.lang.Object
Throws:
java.lang.CloneNotSupportedException
See Also:
Object.clone()

getJobCount

public long getJobCount(java.lang.String applicationID,
                        int jobStatus,
                        int jobType,
                        java.lang.String serverName)
                 throws GridBrokerException
Returns the total number of jobs with the given status, on the given server. If no status is given, count of jobs with all statuses are returned. If no serverID is given, count of jobs on all servers (including unassigned jobs) is given.

Parameters:
applicationID -
jobStatus -
jobType -
serverName -
Returns:
job count
Throws:
GridBrokerException

getSCSJobCount

public long getSCSJobCount(java.lang.String applicationID,
                           int jobStatus,
                           int jobType,
                           java.lang.String serverName)
                    throws GridBrokerException
Throws:
GridBrokerException

getQos

public Qos getQos(java.lang.String appId)
           throws GridBrokerException
Parameters:
appId -
Returns:
Qos object
Throws:
GridBrokerException

getApplication

public ApplicationContext getApplication(java.lang.String applicationID)
                                  throws GridBrokerException
Parameters:
applicationID -
Returns:
application object
Throws:
GridBrokerException

getApplication

public ApplicationContext getApplication(java.lang.String username,
                                         java.lang.String appname)
                                  throws GridBrokerException
Parameters:
username -
appname -
Returns:
application object
Throws:
GridBrokerException

getJob

public Job getJob(java.lang.String applicationID,
                  java.lang.String jobName)
           throws GridBrokerException
Parameters:
applicationID -
jobName -
Returns:
job object
Throws:
GridBrokerException

getSCSJob

public org.gridbus.scs.common.SCSJob getSCSJob(java.lang.String applicationID,
                                               java.lang.String jobName)
                                        throws GridBrokerException
Parameters:
applicationID -
jobName -
Returns:
job object
Throws:
GridBrokerException

getService

public Service getService(java.lang.String applicationID,
                          int serviceType,
                          java.lang.String name)
                   throws GridBrokerException
Parameters:
applicationID -
serviceType -
name -
Returns:
service object
Throws:
GridBrokerException

getServiceByMappingId

public Service getServiceByMappingId(java.lang.String applicationID,
                                     int serviceType,
                                     java.lang.String mappingId)
                              throws GridBrokerException
Parameters:
applicationID -
serviceType -
name -
Returns:
service object
Throws:
GridBrokerException

getServices

public java.util.List getServices(java.lang.String applicationID,
                                  int serviceType,
                                  java.lang.String filter)
                           throws GridBrokerException
Parameters:
applicationID -
serviceType -
filter - : an expression (in hql) to filter the data
Returns:
list of servers.
Throws:
GridBrokerException

getJobs

public java.util.List getJobs(java.lang.String applicationID,
                              int jobStatus,
                              int jobType,
                              java.lang.String serverName)
                       throws GridBrokerException
Parameters:
applicationID -
jobStatus - (STATUS_ANY means any status)
jobType - (TYPE_ANY means any type)
serverName - (Constants.ANY_SERVER signifies any server)
Returns:
collection of jobs
Throws:
GridBrokerException

getSCSJobs

public java.util.List getSCSJobs(java.lang.String applicationID,
                                 int jobStatus,
                                 int jobType,
                                 java.lang.String serverName)
                          throws GridBrokerException
Throws:
GridBrokerException

getSCSJobs

public java.util.List getSCSJobs(java.lang.String applicationID,
                                 int[] jobStates,
                                 int jobType,
                                 java.lang.String serverName)
                          throws GridBrokerException
Throws:
GridBrokerException

getJobs

public java.util.List getJobs(java.lang.String applicationID,
                              int[] jobStates,
                              int jobType,
                              java.lang.String serverName)
                       throws GridBrokerException
Parameters:
applicationID -
jobStates -
jobType -
serverName -
Returns:
collection of jobs
Throws:
GridBrokerException

saveJob

public void saveJob(Job j)
             throws GridBrokerException
Parameters:
j -
Throws:
GridBrokerException

saveJob

public void saveJob(org.gridbus.scs.common.SCSJob j)
             throws GridBrokerException
Throws:
GridBrokerException

removeJob

public void removeJob(Job savedJob)
               throws GridBrokerException
Parameters:
savedJob -
Throws:
GridBrokerException

saveService

public void saveService(Service s)
                 throws GridBrokerException
Parameters:
s -
Throws:
GridBrokerException

saveApplication

public void saveApplication(ApplicationContext app)
                     throws GridBrokerException
Parameters:
app -
Throws:
GridBrokerException

saveQos

public void saveQos(java.lang.String applicationId,
                    Qos qos)
             throws GridBrokerException
Updates the qos for a given application

Parameters:
applicationId -
qos -
Throws:
GridBrokerException

saveNetworkLink

public void saveNetworkLink(java.lang.String applicationID,
                            NetworkLink nl)
                     throws GridBrokerException
Saves the network link entity for a given application

Parameters:
applicationID -
nl -
Throws:
GridBrokerException

getCount

public int getCount(java.lang.String hql)
             throws GridBrokerException
Gets an integer count returned by the given HQL query. An exception is thrown if the query doesnot return an int value

Parameters:
hql -
Returns:
count
Throws:
GridBrokerException

getList

public java.util.List getList(java.lang.String hqlQuery)
                       throws GridBrokerException
Parameters:
hqlQuery -
Returns:
list
Throws:
GridBrokerException

getList

public java.util.List getList(java.lang.String hqlQuery,
                              int limit)
                       throws GridBrokerException
Parameters:
hqlQuery -
limit -
Returns:
list
Throws:
GridBrokerException

addCredentials

public void addCredentials(java.lang.String applicationId,
                           UserCredential uc)
Gets appropriate user-credentials from the in-memory collection of credentials.

Parameters:
applicationId -
uc -

getCredentialsForService

public UserCredential getCredentialsForService(java.lang.String applicationId,
                                               Service s)
Returns the appropriate credentials from the in-memory credential store for the given service entity

Parameters:
applicationId -
s -
Returns:
UserCredential

addCredentialMappings

public void addCredentialMappings(java.lang.String applicationId,
                                  java.lang.String credentialID,
                                  java.lang.String serviceMappingID)
Parameters:
applicationId -
credentialID -
serviceMappingID -

saveEvent

public void saveEvent(BrokerEvent evt)
               throws GridBrokerException
Parameters:
evt -
Throws:
GridBrokerException

getJobStatistics

public JobStatistics getJobStatistics(java.lang.String applicationId,
                                      java.lang.String serverName)
                               throws GridBrokerException
Parameters:
serverName -
Returns:
job statistics
Throws:
GridBrokerException

getJobStatistics

public JobStatistics getJobStatistics(java.lang.String applicationId,
                                      java.lang.String serverName,
                                      int jobType)
                               throws GridBrokerException
Parameters:
serverName -
Returns:
job statistics
Throws:
GridBrokerException

getUserJobsPaged

public java.util.Collection getUserJobsPaged(java.lang.String applicationID,
                                             int pageNumber,
                                             int pageSize)
                                      throws GridBrokerException
Parameters:
applicationID -
pageNumber -
pageSize -
Returns:
Throws:
GridBrokerException

getWorkflowTasks

public java.util.List getWorkflowTasks(java.lang.String applicationID)
                                throws GridBrokerException
Parameters:
applicationID -
Returns:
Throws:
GridBrokerException

getDataConstraints

public java.util.List getDataConstraints(java.lang.String applicationID)
                                  throws GridBrokerException
Parameters:
applicationID -
Returns:
Throws:
GridBrokerException

getServiceByHostname

public Service getServiceByHostname(java.lang.String applicationID,
                                    java.lang.String hostname)
                             throws GridBrokerException
Throws:
GridBrokerException

Copyright © The University of Melbourne. 2006