xrootdlib.streams.XrdXrootdMon.fstat module¶

class Close(client: xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo, lfn: bytes, stats: xrootdlib.structs.XrdXrootdMon.fstat.FileCLS)¶

Bases: object

A client closed a file

client¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.fstat.FileCLS, server: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

lfn¶

stats¶

class Disconnect(client: xrootdlib.streams.XrdXrootdMon.map.UserInfo)¶

Bases: object

A client disconnected from the server

client¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.fstat.FileDSC, server: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

class FstatWindow(server_info: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, start: int, end: int, records: List[Union[xrootdlib.streams.XrdXrootdMon.fstat.Disconnect, xrootdlib.streams.XrdXrootdMon.fstat.Open, xrootdlib.streams.XrdXrootdMon.fstat.Close, xrootdlib.streams.XrdXrootdMon.fstat.Transfer]])¶

Bases: object

Sequence of Open, Close and Disconnect events in a time window

end¶

records¶

server_info¶

start¶

class Open(client: xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo, lfn: bytes, readwrite: bool, filesize: int)¶

Bases: object

A client opened a file

client¶

filesize¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.fstat.FileOPN, server: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

lfn¶

readwrite¶

class Transfer(client: xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo, lfn: bytes, stats: xrootdlib.structs.XrdXrootdMon.fstat.FileXFR)¶

Bases: object

A client transfered a file

client¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.fstat.FileXFR, server: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

lfn¶

stats¶

digest_packet(stod: int, fstat_struct: xrootdlib.structs.XrdXrootdMon.Fstat, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶: Digest a packet containing fstat data