710 Commits (f732ea255e44db93397e8c48b68e1a4da92090bd)

All Branches

Search

Author	SHA1	Message	Date
Tyler Goodlet	5c70b4824f	Add remote actor error handling and parent re-raising ... Command requests are sent out and responses are handled in a "message loop" where each command is associated with a "caller id" and multiple cmds and results are multiplexed on the came inter-actor channel. When a cmd result arrives it is pushed into a local queue and delivered to the appropriate calling actor's task. Errors from a remote actor are always shipped in an "error" packet back to their spawning-parent actor such that any error in a subactor is always raised directly in the parent. Based on the first response to a cmd (either a 'return' or 'yield' packet) the caller side portal will retrieve values by wrapping the local response queue in either of an async function or generator as appropriate.	2018-07-05 16:21:55 -04:00
Tyler Goodlet	4eb014aedc	Use trace level for packet contents	2018-07-05 16:21:55 -04:00
Tyler Goodlet	bed7e240de	Add uid,event attrs to `Channel`	2018-07-05 16:21:55 -04:00
Tyler Goodlet	2e9cbec93c	Add a basic `tractor.run()` test	2018-07-05 16:21:55 -04:00
Tyler Goodlet	f36bd0f188	Uhhh make everything better	2018-07-05 16:21:55 -04:00
Tyler Goodlet	03c57ceece	Add an initial `tractor` price streaming test	2018-07-05 16:21:55 -04:00
Tyler Goodlet	88e176ceff	Add a very rough, minimal actor model system ... I'm calling it `tractor` (as in trio-actor) for now. Lots of work to do still as per the many comments! Relates to #27	2018-07-05 16:21:55 -04:00
Tyler Goodlet	01119545fc	IPC primitives improvements ... - Rename the `Client` to `Channel` - Add better `__repr__()` - use laddr, raddr instead of sockaddr, peer - don't allow re-entrant `Channel.connect()` calls - Make `Channel` an async iterable	2018-07-05 16:21:55 -04:00
Tyler Goodlet	968c385c35	Move ipc types into separate module	2018-07-05 16:21:55 -04:00
goodboy	183c14ba79	Initial commit	2018-07-05 16:01:15 -04:00