xrootdlib.streams.XrdXrootdMon.map module

exception MapInfoError

Bases: Exception

An item was not in the map store

class MapInfoStore

Bases: object

digest_map(stod: int, map_struct: xrootdlib.structs.XrdXrootdMon.Map)

Digest map data from a packet

free_access(stod: int, dictid: int) → None
free_user(stod: int, dictid: int) → None
get_access(stod: int, dictid: int) → xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo
get_server(stod: int, sid: int) → xrootdlib.streams.XrdXrootdMon.map.ServerInfo
get_user(stod: int, dictid: int) → xrootdlib.streams.XrdXrootdMon.map.UserInfo
set_access(server: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, dictid: int, userid: int, path: bytes) → xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo

Add a file access info based on raw references (i.e. FStat Open with LFN)

class MapInfoStoreCleaner(store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore, clean_delay: int = 30)

Bases: threading.Thread

add_deletion(instruction, *args, **kwargs)
run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

class PathAccessInfo(client: Optional[xrootdlib.structs.XrdXrootdMon.map.UserId], server: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, path: bytes, auth: Optional[xrootdlib.structs.XrdXrootdMon.map.AuthInfo] = None)

Bases: object

Metadata of a client accessing a path on a server

Depending on the monitoring settings, client and auth may be unavailable and just None.

auth
client
host
path
pid
protocol
server
user
class ServerInfo(user_id: xrootdlib.structs.XrdXrootdMon.map.UserId, server_info: xrootdlib.structs.XrdXrootdMon.map.SrvInfo, stod: int)

Bases: object

host
instance
pid
port
program
protocol
sid
site
stod
user
version
class UserInfo(client: xrootdlib.structs.XrdXrootdMon.map.UserId, server_info: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, auth_info: Optional[xrootdlib.structs.XrdXrootdMon.map.AuthInfo] = None)

Bases: object

auth_info
client
host
pid
protocol
server
user