PublisherHandler

PublisherHandler

This service has been built to provide the RSS web views with all the information they need. NO OTHER COMPONENT THAN Web controllers should make use of it.

class DIRAC.ResourceStatusSystem.Service.PublisherHandler.PublisherHandler(handlerInitDict, trid)

Bases: PublisherHandlerMixin, RequestHandler

__init__(handlerInitDict, trid)

Constructor

Parameters:

• handlerInitDict (dictionary) – Information vars for the service

• trid (object) – Transport to use

auth_ping = ['all']

auth_refreshConfiguration = ['CSAdministrator']

auth_whoami = ['all']

static export_echo(data)

This method is used for testing performance of the service

Parameters:

data (str) – data to be sent back to the caller

Returns:

S_OK, Value is the input data

export_getCachedDowntimes(element, elementType, name, severity)

classmethod export_getDowntimes(element, elementType, name)

classmethod export_getElementHistory(element, name, elementType, statusType)

Returns element history from ResourceStatusDB

classmethod export_getElementPolicies(element, name, statusType)

Returns policies for a given element

classmethod export_getElementStatuses(element, name, elementType, statusType, status, tokenOwner)

Returns element statuses from the ResourceStatusDB

classmethod export_getNodeStatuses()

export_getSites()

Returns list of all sites considered by RSS

Returns:

S_OK( [ sites ] ) | S_ERROR

export_getSitesResources(siteNames)

Returns dictionary with SEs and CEs for the given site(s). If siteNames is None, all sites are taken into account.

Returns:

S_OK( { site1 : { ces : [ ces ], ‘ses’ : [ ses ] },… } ) | S_ERROR

export_getTree(elementType, elementName)

Given an element type and name, finds its parent site and returns all descendants of that site.

export_ping()

static export_refreshConfiguration(fromMaster)

Force refreshing the configuration data

Parameters:

fromMaster (bool) – flag to refresh from the master configuration service

export_setStatus(element, name, statusType, status, elementType, username, lastCheckTime)

export_setToken(element, name, statusType, token, elementType, username, lastCheckTime)

export_whoami()

A simple whoami, returns all credential dictionary, except certificate chain object.

classmethod getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns:

Value for serviceSection/optionName in the CS being defaultValue the default

getRemoteAddress()

Get the address of the remote peer.

Returns:

Address of remote peer.

getRemoteCredentials()

Get the credentials of the remote peer.

Returns:

Credentials dictionary of remote peer.

getSite(elementType, elementName)

Given an element name, return its site

initialize()

Initialize this instance of the handler (to be overwritten)

classmethod initializeHandler(serviceInfoDict)

Initialization of client objects

srv_disconnect(trid=None)

classmethod srv_disconnectClient(trid)

srv_getActionTuple()

classmethod srv_getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns:

Value for serviceSection/optionName in the CS being defaultValue the default

srv_getClientSetup()

srv_getClientVO()

srv_getClientVersion()

srv_getFormattedRemoteCredentials()

classmethod srv_getMonitor()

srv_getRemoteAddress()

Get the address of the remote peer.

Returns:

Address of remote peer.

srv_getRemoteCredentials()

Get the credentials of the remote peer.

Returns:

Credentials dictionary of remote peer.

classmethod srv_getServiceName()

srv_getTransportID()

classmethod srv_getURL()

classmethod srv_msgCreate(msgName)

srv_msgReply(msgObj)

classmethod srv_msgSend(trid, msgObj)

transfer_bulkFromClient(bulkId, token, bulkSize, fileHelper)

transfer_bulkToClient(bulkId, token, fileHelper)

transfer_fromClient(fileId, token, fileSize, fileHelper)

transfer_listBulk(bulkId, token, fileHelper)

transfer_toClient(fileId, token, fileHelper)

types_echo = [<class 'str'>]

types_getCachedDowntimes = [(<class 'str'>, <class 'NoneType'>, <class 'list'>), (<class 'str'>, <class 'NoneType'>, <class 'list'>), (<class 'str'>, <class 'NoneType'>, <class 'list'>), (<class 'str'>, <class 'NoneType'>, <class 'list'>)]

types_getDowntimes = [<class 'str'>, <class 'str'>, <class 'str'>]

types_getElementHistory = [<class 'str'>, (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getElementPolicies = [<class 'str'>, (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getElementStatuses = [<class 'str'>, (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getNodeStatuses = []

types_getSites = []

types_getSitesResources = [(<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getTree = [<class 'str'>, <class 'str'>]

types_ping = []

types_refreshConfiguration = [<class 'bool'>]

types_setStatus = [<class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>]

types_setToken = [<class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>]

types_whoami = []

class DIRAC.ResourceStatusSystem.Service.PublisherHandler.PublisherHandlerMixin

Bases: object

RPCServer used to deliver data to the web portal.

export_getCachedDowntimes(element, elementType, name, severity)

classmethod export_getDowntimes(element, elementType, name)

classmethod export_getElementHistory(element, name, elementType, statusType)

Returns element history from ResourceStatusDB

classmethod export_getElementPolicies(element, name, statusType)

Returns policies for a given element

classmethod export_getElementStatuses(element, name, elementType, statusType, status, tokenOwner)

Returns element statuses from the ResourceStatusDB

classmethod export_getNodeStatuses()

export_getSites()

Returns list of all sites considered by RSS

Returns:

S_OK( [ sites ] ) | S_ERROR

export_getSitesResources(siteNames)

Returns dictionary with SEs and CEs for the given site(s). If siteNames is None, all sites are taken into account.

Returns:

S_OK( { site1 : { ces : [ ces ], ‘ses’ : [ ses ] },… } ) | S_ERROR

export_getTree(elementType, elementName)

Given an element type and name, finds its parent site and returns all descendants of that site.

export_setStatus(element, name, statusType, status, elementType, username, lastCheckTime)

export_setToken(element, name, statusType, token, elementType, username, lastCheckTime)

getSite(elementType, elementName)

Given an element name, return its site

classmethod initializeHandler(serviceInfoDict)

Initialization of client objects

types_getCachedDowntimes = [(<class 'str'>, <class 'NoneType'>, <class 'list'>), (<class 'str'>, <class 'NoneType'>, <class 'list'>), (<class 'str'>, <class 'NoneType'>, <class 'list'>), (<class 'str'>, <class 'NoneType'>, <class 'list'>)]

types_getDowntimes = [<class 'str'>, <class 'str'>, <class 'str'>]

types_getElementHistory = [<class 'str'>, (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getElementPolicies = [<class 'str'>, (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getElementStatuses = [<class 'str'>, (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>), (<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getNodeStatuses = []

types_getSites = []

types_getSitesResources = [(<class 'str'>, <class 'list'>, <class 'NoneType'>)]

types_getTree = [<class 'str'>, <class 'str'>]

types_setStatus = [<class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>]

types_setToken = [<class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>, <class 'str'>]