timeflux.core.io


timeflux.core.io: lightweight i/o wrapper

io

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