Wrappers
Base classes
Stream2Zmq
- class libstored.Stream2Zmq(stack='ascii,term', listen='*', port=19026, timeout_s=1, printStdout=True)
A generic out-of-band frame grabber for ASCII streams.
- activity()
- close()
- decode(data)
- default_port = 19026
- property down
- encode(data)
- isWaiting()
- lastActivity()
- property mtu
- name = 'layer'
- poll(timeout_s=None)
- recvAll(socket, f)
- registerStream(stream, f=True)
- reset()
- stdout(data)
- timeout()
- property up
- wrap(layer)
- property zmq
Stdio2Zmq
- class libstored.Stdio2Zmq(args, stack='ascii,term', listen='*', port=19026, **kwargs)
A stdin/stdout frame grabber to ZmqServer bridge.
- activity()
- close()
- decode(data)
- default_port = 19026
- property down
- encode(data)
- isWaiting()
- lastActivity()
- property mtu
- name = 'layer'
- poll(timeout_s=None)
- recvAll(socket, f)
- registerStream(stream, f=True)
- reset()
- sendToApp(data)
- stdout(data)
- timeout()
- property up
- wrap(layer)
- property zmq
Serial2Zmq
- class libstored.Serial2Zmq(stack='ascii,term', zmqlisten='*', zmqport=19026, drop_s=1, printStdout=True, **kwargs)
Serial port frame grabber to ZmqServer bridge.
- activity()
- close()
- decode(data)
- default_port = 19026
- property down
- drop(data)
- encode(data)
- isWaiting()
- lastActivity()
- property mtu
- name = 'layer'
- poll(timeout_s=None)
- recvAll(socket, f)
- registerStream(stream, f=True)
- reset()
- sendToApp(data)
- stdout(data)
- timeout()
- property up
- wrap(layer)
- property zmq
ZmqServer
- class libstored.ZmqServer(bind=None, listen='*', port=19026, context=None)
A ZMQ Server
This can be used to create a bridge from an arbitrary interface to ZMQ, which in turn can be used to connect a libstored.zmq_client.ZmqClient to.
Instantiate as libstored.ZmqServer().
- activity()
- close()
- decode(data)
- default_port = 19026
- property down
- encode(data)
- isWaiting()
- lastActivity()
- property mtu
- name = 'zmq'
- poll(timeout_s=None)
- register(socket, flags)
- registerStream(stream, f=True)
- req(message, rep)
- timeout()
- unregister(socket)
- property up
- wrap(layer)
libstored.wrapper.stdio
A stdin/stdout frame grabber to ZmqServer wrapper for a to-be-started process.
libstored.wrapper.serial
A frame grabber to ZmqServer wrapper for a serial port.