Class Hierarchy
.iteration.ListConsumer
- asynqueue.misc.TestMethods - Undocumented
- asynqueue.misc.TestUniverse - Undocumented
- asynqueue.threads.IterationGetter.IterationStopper - Undocumented
Exception
- asynqueue.errors.ImplementationError - There was a problem implementing the required interface.
- asynqueue.errors.NotReadyError - You shouldn't have called yet!
- asynqueue.errors.ProcessError - The subprocess couldn't be reached.
- asynqueue.errors.QueueRunError - An attempt was made to dispatch tasks when the dispatcher isn't running.
- asynqueue.errors.ThreadError - A function call in a thread raised an exception.
- asynqueue.errors.TimeoutError - A local worker took too long to provide a result.
- asynqueue.errors.WorkerError - A worker ran into an exception trying to run a task.
- asynqueue.errors.ImplementationError - There was a problem implementing the required interface.
logging.Handler
- asynqueue.test.test_base.Test_TaskQueueErrors.TestHandler - Undocumented
logging.StreamHandler
- asynqueue.test.testbase.TestHandler - Undocumented
- mcmandelbrot.test.test_valuer.TestMandelbrotValuer.Yielded - Undocumented
object
- asynqueue.base.LoadInfoProducer - Produces task queue loading information.
- asynqueue.base.Priority - I provide simple, asynchronous access to a priority heap.
- asynqueue.base.Queue - I am an asynchronous priority queue. Construct me with an item handler
that can be called with each item from the queue and call
shutdown
when I'm done. - asynqueue.base.TaskQueue - I am a task queue for dispatching arbitrary callables to be run by one
or more worker objects.
- asynqueue.null.NullQueue - A
TaskQueue
that runs tasks in the Twisted main loop. - asynqueue.process.ProcessQueue - A
TaskQueue
that runs tasks on one or more subordinate Python processes. - asynqueue.threads.ThreadQueue - I am a
TaskQueue
for dispatching arbitrary callables to be run by a single worker thread.
- asynqueue.null.NullQueue - A
- asynqueue.info.Converter - I provide a bunch of methods for converting objects.
- asynqueue.info.Info - Provides detailed info about function/method calls.
- asynqueue.info.InfoHolder - An instance of me is yielded by
Info.context
, for you to call about info concerning a particular saved function call. - asynqueue.iteration.Deferator - Deferred-yielding iterator.
- asynqueue.iteration.Delay - I let you delay things and wait for things that may take a while, in Twisted fashion.
- asynqueue.iteration.IterationProducer - Producer of iterations from a
Deferator
. - asynqueue.iteration.ListConsumer - Bare-bones iteration consumer.
- asynqueue.iteration.Prefetcherator - I prefetch iterations from an iterator, providing a
getNext
method suitable forDeferator
. - asynqueue.process.ProcessBase - I am a base class for objects that are handy to pass as arguments to a
ProcessQueue
. - asynqueue.process.ProcessUniverse - Each process for a
ProcessWorker
lives in one of these. - asynqueue.tasks.Assignment - I represent the assignment of a single task to whichever worker object accepts me. Deep down, my real role is to provide something to fire the callback of a deferred with instead of just another deferred.
- asynqueue.tasks.AssignmentFactory - I generate
Assignment
instances for workers to handle particular tasks. - asynqueue.tasks.Task - I represent a task that has been dispatched to a queue for running with a given scheduling niceness.
- asynqueue.tasks.TaskFactory - I generate
Task
instances with the right priority setting for effective scheduling between tasks in one or more concurrently running task series. - asynqueue.tasks.TaskHandler - I am a Queue handler that manages one or more providers of
IWorker
. - asynqueue.test.test_interfaces.AttrBogus - Undocumented
- asynqueue.test.test_interfaces.AttrOK - Undocumented
- asynqueue.test.test_interfaces.NoCAttr - Undocumented
- asynqueue.test.test_interfaces.NoIAttr - Undocumented
- asynqueue.test.test_iteration.IteratorGetter - Undocumented
- asynqueue.test.test_tasks.AttrBogus - Undocumented
- asynqueue.test.test_threads.Stuff - No class docstring; 1/3 methods documented
- asynqueue.test.test_wire.BigObject - Undocumented
- asynqueue.test.testbase.DeferredIterable - Undocumented
- asynqueue.test.testbase.MockTask - Undocumented
- asynqueue.test.testbase.MsgBase - A mixin for providing a convenient message method.
- asynqueue.test.testbase.IterationConsumer - Undocumented
- asynqueue.test.testbase.MockWorker - Undocumented
- asynqueue.test.testbase.ProcessProtocol - Undocumented
- asynqueue.test.testbase.Tasks - Undocumented
- asynqueue.test.test_threads.Test_Consumerator - Undocumented
- asynqueue.test.test_threads.Test_Filerator - Undocumented
- asynqueue.test.test_threads.Test_IterationGetter - Undocumented
- asynqueue.test.test_threads.Test_OrderedItemProducer - No class docstring; 1/8 methods documented
- asynqueue.test.test_threads.Test_ThreadQueue - Undocumented
- asynqueue.test.test_threads.Test_ThreadWorker - Undocumented
- asynqueue.test.testbase.TestCase - Slightly improved TestCase
- asynqueue.test.test_base.Test_Priority - Undocumented
- asynqueue.test.test_base.Test_TaskQueue - Undocumented
- asynqueue.test.test_base.Test_TaskQueueErrors - Undocumented
- asynqueue.test.test_info.Test_Functions - Undocumented
- asynqueue.test.test_info.Test_Info - Undocumented
- asynqueue.test.test_interfaces.TestIWorker - Undocumented
- asynqueue.test.test_iteration.TestDeferator - Undocumented
- asynqueue.test.test_iteration.TestDelay - Undocumented
- asynqueue.test.test_iteration.TestIterationProducer - Undocumented
- asynqueue.test.test_iteration.TestListConsumer - Undocumented
- asynqueue.test.test_iteration.TestPrefetcherator - Undocumented
- asynqueue.test.test_process.TestProcessQueue - Undocumented
- asynqueue.test.test_process.TestProcessWorker - Undocumented
- asynqueue.test.test_process.TestProcessWorkerStats - Undocumented
- asynqueue.test.test_tasks.Test_AssignmentFactory - Undocumented
- asynqueue.test.test_tasks.Test_Task - Undocumented
- asynqueue.test.test_tasks.Test_TaskFactory - Undocumented
- asynqueue.test.test_tasks.Test_TaskHandlerHiring - Undocumented
- asynqueue.test.test_tasks.Test_TaskHandlerRun - Undocumented
- asynqueue.test.test_threads.Test_Consumerator - Undocumented
- asynqueue.test.test_threads.Test_Filerator - Undocumented
- asynqueue.test.test_threads.Test_IterationGetter - Undocumented
- asynqueue.test.test_threads.Test_OrderedItemProducer - No class docstring; 1/8 methods documented
- asynqueue.test.test_threads.Test_ThreadLooper - Undocumented
- asynqueue.test.test_threads.Test_ThreadQueue - Undocumented
- asynqueue.test.test_threads.Test_ThreadWorker - Undocumented
- asynqueue.test.test_util.TestCallRunner - Undocumented
- asynqueue.test.test_util.TestDeferredTracker - Undocumented
- asynqueue.test.test_util.TestFunctions - Undocumented
- asynqueue.test.test_wire.Test_ChunkyString - Undocumented
- asynqueue.test.test_wire.Test_WireRunner - Undocumented
- asynqueue.test.test_wire.Test_WireWorker - Undocumented
- asynqueue.test.test_workers.TestAsyncWorker - Undocumented
- asynqueue.test.testbase.TestHandler - Undocumented
- asynqueue.test.testbase.Picklable - Undocumented
- asynqueue.test.testbase.RangeProducer - Produces an integer range of values like
range
. - asynqueue.test.testbase.RangeWriter - Writes an integer range of values like
range
to a file-like object fh and then closes it. - asynqueue.threads.PoolUser - Abstract base class for objects that access a global thread pool instead
of starting their own threads.
- asynqueue.threads.IterationGetter - Abstract base class for objects that munch data on one end and act like
iterators to yield it on the other end.
- asynqueue.test.test_threads.TestableIterationGetter - No class docstring; 1/1 methods documented
- asynqueue.threads.Consumerator - I act like an
IConsumer
for your Twisted code and an iterator for your blocking code running via aThreadWorker
. - asynqueue.threads.Filerator - Stream data to me in one end and I will iterate it out the other.
- asynqueue.threads.OrderedItemProducer - Produces blocking iterations in the order they are requested via an asynchronous function call.
- asynqueue.threads.IterationGetter - Abstract base class for objects that munch data on one end and act like
iterators to yield it on the other end.
- asynqueue.threads.ThreadLooper - I run function calls in a dedicated thread.
- asynqueue.util.CallRunner - I'm used by
threads.ThreadLooper
andprocess.ProcessUniverse
. - asynqueue.util.DeferredTracker - I allow you to track and wait for Twisted
Deferred
objects without actually having received a reference to them, or interfering with their callback chains. - asynqueue.util.ProcessProtocol - I am a simple protocol for spawning a subordinate process.
- asynqueue.util.TestStuff - For testing only.
- asynqueue.va.VA - I provide version-agnostic attributes and a py3 attribute that indicates if we're running under Python 3.
- asynqueue.wire.ChunkyString - I iterate chunks of a big string, deleting my internal reference to it when done so it can be garbage collected even if I'm not.
- asynqueue.wire.ServerManager - I spawn one or more new Python interpreters that run a
WireServer
on the local machine. - asynqueue.wire.WireRunner - An instance of me is constructed by a
WireWorkerUniverse
on the server end of the AMP connection to run all tasks for itsWireServer
. - asynqueue.wire.WireServer - An AMP server for the remote end of a
WireWorker
. - asynqueue.wire.WireWorker - Runs tasks "over the wire," via Twisted AMP running on an
endpoint
connection. - asynqueue.workers.AsyncWorker - I implement an
IWorker
that runs tasks in the Twisted main loop.- mcmandelbrot.test.testbase.MockWireWorker - Undocumented
- asynqueue.workers.ProcessWorker - I implement an
IWorker
that runs tasks in a dedicated worker process. - asynqueue.workers.ThreadWorker - I implement an
IWorker
that runs tasks in a dedicated worker thread. - mcmandelbrot.colormap.ColorMapper - I map floating-point values in the range 0.0 to 1.0 to RGB byte triplets.
- mcmandelbrot.html.ResourceBag - Undocumented
- mcmandelbrot.image.Imager - Call
renderImage
with Twisted web request objects as much as you like to write PNG images in response to them. - mcmandelbrot.image.RunnerToken - TODO: Implmement this with
asynqueue.base.Priority
to dispatch requests to runners based on how fast they've run previous ones. - mcmandelbrot.runner.Runner - I run a multi-process Mandelbrot Set computation operation.
- mcmandelbrot.test.test_vroot.MockBaton - Undocumented
- mcmandelbrot.test.testbase.DeferredIterable - Undocumented
- mcmandelbrot.test.testbase.MsgBase - A mixin for providing a convenient message method.
- mcmandelbrot.test.testbase.FakeFile - Undocumented
- mcmandelbrot.test.testbase.IterationConsumer - Undocumented
- mcmandelbrot.test.testbase.ProcessProtocol - Undocumented
- mcmandelbrot.test.testbase.TestCase - Slightly improved TestCase
- mcmandelbrot.test.test_main.TestRun - Undocumented
- mcmandelbrot.test.test_runner.TestRunner - Undocumented
- mcmandelbrot.test.test_valuer.TestMandelbrotValuer - Undocumented
- mcmandelbrot.test.test_vroot.TestBaton - Undocumented
- mcmandelbrot.test.test_vroot.TestHTML_VRoot - Undocumented
- mcmandelbrot.test.test_vroot.TestVRoot - Undocumented
- mcmandelbrot.test.test_wire.TestMandelbrotWorkerUniverse - Undocumented
- mcmandelbrot.test.test_wire.TestRemoteRunner - Undocumented
- mcmandelbrot.test.testbase.Picklable - Undocumented
- mcmandelbrot.test.testbase.RangeProducer - Produces an integer range of values like
xrange
. - mcmandelbrot.test.testbase.RangeWriter - Writes an integer range of values like
xrange
to a file-like object fh and then closes it. - mcmandelbrot.valuer.MandelbrotValuer - Returns the values (number of iterations to escape, if at all, inverted) of the Mandelbrot set at point cr + i*ci in the complex plane, for a range of real values with a constant imaginary component.
- mcmandelbrot.vroot.Baton - No summary
- mcmandelbrot.vroot.VRoot - No summary
- mcmandelbrot.test.test_vroot.TestableVRoot - Undocumented
- mcmandelbrot.wire.RemoteRunner - Call
setup
and wait for theDeferred
it returns, then you can callimage
as much as you like to get images streamed to you as iterations ofDeferred
chunks. - mcmandelbrot.wire.Writable - Undocumented
PyQt5.QtWidgets.QWidget
- mcmandelbrot.gui.MainWindow - I act as the main window for the QApplication object.
twisted.internet.defer.DeferredLock
- asynqueue.util.DeferredLock - I am a modified form of
defer.DeferredLock
lock that lets you shut things down when you get the lock.
- asynqueue.util.DeferredLock - I am a modified form of
twisted.protocols.amp.AMP
- asynqueue.wire.WireWorker.AMP - Special disconnection-alerting AMP protocol. When my connection is made,
I construct a
Deferred
referenced as d_lcww, which I will fire it if I get disconnected.
- asynqueue.wire.WireWorker.AMP - Special disconnection-alerting AMP protocol. When my connection is made,
I construct a
twisted.protocols.amp.Command
- asynqueue.wire.GetNext - With a unique ID, gets the next iteration of data from an iterator or a task result so big that it had to be chunked.
- asynqueue.wire.RunTask - Runs a task and returns the status and result.
twisted.protocols.amp.CommandLocator
- asynqueue.wire.WireWorkerUniverse - Subclass me in code that runs on the remote interpreter, and then call
the subclass methods via
runTask
.- asynqueue.misc.TestUniverse - Undocumented
- mcmandelbrot.wire.MandelbrotWorkerUniverse - No summary
- asynqueue.wire.WireWorkerUniverse - Subclass me in code that runs on the remote interpreter, and then call
the subclass methods via
twisted.trial.unittest.TestCase
- asynqueue.test.testbase.TestCase - Slightly improved TestCase
- asynqueue.test.test_base.Test_Priority - Undocumented
- asynqueue.test.test_base.Test_TaskQueue - Undocumented
- asynqueue.test.test_base.Test_TaskQueueErrors - Undocumented
- asynqueue.test.test_info.Test_Functions - Undocumented
- asynqueue.test.test_info.Test_Info - Undocumented
- asynqueue.test.test_interfaces.TestIWorker - Undocumented
- asynqueue.test.test_iteration.TestDeferator - Undocumented
- asynqueue.test.test_iteration.TestDelay - Undocumented
- asynqueue.test.test_iteration.TestIterationProducer - Undocumented
- asynqueue.test.test_iteration.TestListConsumer - Undocumented
- asynqueue.test.test_iteration.TestPrefetcherator - Undocumented
- asynqueue.test.test_process.TestProcessQueue - Undocumented
- asynqueue.test.test_process.TestProcessWorker - Undocumented
- asynqueue.test.test_process.TestProcessWorkerStats - Undocumented
- asynqueue.test.test_tasks.Test_AssignmentFactory - Undocumented
- asynqueue.test.test_tasks.Test_Task - Undocumented
- asynqueue.test.test_tasks.Test_TaskFactory - Undocumented
- asynqueue.test.test_tasks.Test_TaskHandlerHiring - Undocumented
- asynqueue.test.test_tasks.Test_TaskHandlerRun - Undocumented
- asynqueue.test.test_threads.Test_Consumerator - Undocumented
- asynqueue.test.test_threads.Test_Filerator - Undocumented
- asynqueue.test.test_threads.Test_IterationGetter - Undocumented
- asynqueue.test.test_threads.Test_OrderedItemProducer - No class docstring; 1/8 methods documented
- asynqueue.test.test_threads.Test_ThreadLooper - Undocumented
- asynqueue.test.test_threads.Test_ThreadQueue - Undocumented
- asynqueue.test.test_threads.Test_ThreadWorker - Undocumented
- asynqueue.test.test_util.TestCallRunner - Undocumented
- asynqueue.test.test_util.TestDeferredTracker - Undocumented
- asynqueue.test.test_util.TestFunctions - Undocumented
- asynqueue.test.test_wire.Test_ChunkyString - Undocumented
- asynqueue.test.test_wire.Test_WireRunner - Undocumented
- asynqueue.test.test_wire.Test_WireWorker - Undocumented
- asynqueue.test.test_workers.TestAsyncWorker - Undocumented
- mcmandelbrot.test.testbase.TestCase - Slightly improved TestCase
- mcmandelbrot.test.test_main.TestRun - Undocumented
- mcmandelbrot.test.test_runner.TestRunner - Undocumented
- mcmandelbrot.test.test_valuer.TestMandelbrotValuer - Undocumented
- mcmandelbrot.test.test_vroot.TestBaton - Undocumented
- mcmandelbrot.test.test_vroot.TestHTML_VRoot - Undocumented
- mcmandelbrot.test.test_vroot.TestVRoot - Undocumented
- mcmandelbrot.test.test_wire.TestMandelbrotWorkerUniverse - Undocumented
- mcmandelbrot.test.test_wire.TestRemoteRunner - Undocumented
- asynqueue.test.testbase.TestCase - Slightly improved TestCase
twisted.web.resource.Resource
- mcmandelbrot.html.ImageResource - Undocumented
- mcmandelbrot.html.RootResource - No class docstring; 2/4 methods documented
twisted.web.server.Site
- mcmandelbrot.html.MandelbrotSite - Undocumented
type
- mcmandelbrot.vroot.Meta - Load class-wide lists of lines for CSS and JS
weave.base_info.custom_info
- mcmandelbrot.valuer.my_info - Undocumented
zope.interface.Interface
- asynqueue.interfaces.IWorker - Provided by worker objects that can have tasks assigned to them for processing.
zope.interface.Invalid
- asynqueue.errors.InvariantError - An invariant of the IWorker provider did not meet requirements.