timeflux.core.io

timeflux.core.io: lightweight i/o wrapper

io

class timeflux.core.io.Port(persistent=False)[source]
clear()[source]
ready()[source]
set(rows, timestamps=None, names=None, meta={})[source]