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