timeflux.core.io module

timeflux.core.io: lightweight i/o wrapper

class timeflux.core.io.Port(persistent=False)[source]

Bases: object

__init__(persistent=False)[source]

Initialize self. See help(type(self)) for accurate signature.

clear()[source]
ready()[source]
set(rows, timestamps=None, names=None, meta={})[source]