Index

A

AbstractNexus (class in async_nexus) add_converter() (async_nexus.AsyncEventNexus method) add_filter() (async_nexus.AsyncEventNexus method) add_handler() (async_nexus.AsyncEventNexus method) add_producer() (async_nexus.AsyncEventNexus method) anext() (in module async_nexus) async_nexus module async_nexus.boundaries module

async_nexus.errors module async_nexus.zmq module AsyncEventBoundary (class in async_nexus.boundaries) AsyncEventNexus (class in async_nexus) AsyncEventNexus.States (class in async_nexus) AsyncEventPriorityQueue (class in async_nexus) AUTO (async_nexus.EventFactory attribute)

B

BadCall

C

cleanup() (async_nexus.AsyncEventNexus method) close() (async_nexus.boundaries.AsyncEventBoundary method) (async_nexus.EventConverter method) (async_nexus.EventSource method) convert_to_event() (async_nexus.zmq.ZmqEventConverter method)

COUNT_DOWN (async_nexus.Timer attribute) COUNT_UP (async_nexus.Timer attribute) create_event() (async_nexus.EventFactory method) (async_nexus.Timer method) create_handler_coro() (in module async_nexus)

D

deregister() (async_nexus.EventFanout method)

distribute_event() (async_nexus.EventProducer method)

E

Event (class in async_nexus) event_generator() (async_nexus.EventConverter method) EventConsumer (class in async_nexus) EventConverter (class in async_nexus) EventDiscarder (class in async_nexus)

EventDispatcher (class in async_nexus) EventFactory (class in async_nexus) EventFanout (class in async_nexus) EventProducer (class in async_nexus) EventSource (class in async_nexus)

G

get_nowait() (async_nexus.AsyncEventPriorityQueue method)

H

handle() (async_nexus.boundaries.AsyncEventBoundary method) (async_nexus.EventConsumer method) (async_nexus.EventDiscarder method) (async_nexus.EventFanout method) (async_nexus.zmq.ZmqEventSender method)

I

id (async_nexus.Event attribute) ingest() (async_nexus.AbstractNexus method) (async_nexus.AsyncEventNexus method)

InvalidLoopState

L

loop_forever() (async_nexus.AsyncEventNexus method) LoopAlreadyStarted

LOOPING (async_nexus.AsyncEventNexus.States attribute) LoopStopped

M

MisconfiguredEventConsumer MisconfiguredEventProducer module async_nexus async_nexus.boundaries async_nexus.errors async_nexus.zmq

MultipleStart

N

NamedEvent (class in async_nexus)

next_id() (async_nexus.EventFactory method) NoMoreEvents

O

obtain_event() (async_nexus.EventConverter method) (async_nexus.SimpleEventConverter method) (async_nexus.zmq.ZmqEventConverter method) (async_nexus.zmq.ZmqEventReceiver method)

ONE_SHOT (async_nexus.Timer attribute) ONGOING (async_nexus.Timer attribute)

P

payload (async_nexus.Event attribute)

priority (async_nexus.Event attribute) put() (async_nexus.AsyncEventPriorityQueue method)

Q

QUEUE_MAXLEN (async_nexus.AsyncEventNexus attribute) (async_nexus.boundaries.AsyncEventBoundary attribute)

R

RANDOM (async_nexus.EventFactory attribute) random_id() (async_nexus.EventFactory method) READY (async_nexus.AsyncEventNexus.States attribute)

register() (async_nexus.AsyncEventNexus method) (async_nexus.EventFanout method) register_nexus() (async_nexus.EventProducer method)

S

send_event() (in module async_nexus.zmq) SimpleEventConverter (class in async_nexus) start() (async_nexus.AsyncEventNexus method) (async_nexus.boundaries.AsyncEventBoundary method) (async_nexus.EventProducer method) (async_nexus.EventSource method) (async_nexus.Timer method)

STARTING (async_nexus.AsyncEventNexus.States attribute) stop() (async_nexus.AsyncEventNexus method) (async_nexus.Timer method) STOPPED (async_nexus.AsyncEventNexus.States attribute)

T

Timer (class in async_nexus)

transfer_events() (async_nexus.boundaries.AsyncEventBoundary method) type (async_nexus.Event attribute)

U

UnhandledEvent

Z

ZmqAbstractConverter (class in async_nexus.zmq) ZmqEventConverter (class in async_nexus.zmq)

ZmqEventReceiver (class in async_nexus.zmq) ZmqEventSender (class in async_nexus.zmq)