stable
Core:
MicroAgent
Periodic functions
Signal bus
Queue broker
Internal hooks
Launcher and configuration
Tools:
Redis
AMQP (RabbitMQ)
Kafka
Mocks & testing
Examples:
Agent examples
Configuration, launch and etc.
MicroAgent
Index
Edit on GitHub
Index
_
|
A
|
B
|
C
|
D
|
G
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
U
|
W
_
_bindings (microagent.broker.AbstractQueueBroker attribute)
A
AbstractQueueBroker (class in microagent.broker)
AbstractSignalBus (class in microagent.bus)
AgentsManager (class in microagent.launcher)
AMQPBroker (class in microagent.tools.amqp)
B
bind() (microagent.broker.AbstractQueueBroker method)
(microagent.bus.AbstractSignalBus method)
(microagent.tools.amqp.AMQPBroker method)
(microagent.tools.kafka.KafkaBroker method)
(microagent.tools.redis.RedisBroker method)
(microagent.tools.redis.RedisSignalBus method)
bind_consumer() (microagent.broker.AbstractQueueBroker method)
bind_consumers() (microagent.MicroAgent method)
bind_receiver() (microagent.bus.AbstractSignalBus method)
bind_receivers() (microagent.MicroAgent method)
BoundQueue (class in microagent.broker)
BoundSignal (class in microagent.bus)
broker (microagent.MicroAgent attribute)
BrokerMock (class in microagent.tools.mocks)
bus (microagent.MicroAgent attribute)
BusMock (class in microagent.tools.mocks)
C
call() (microagent.bus.AbstractSignalBus method)
Consumer (class in microagent.broker)
consumer() (in module microagent)
,
[1]
cron() (in module microagent)
,
[1]
CRONTask (class in microagent.timer)
D
declare_queue() (microagent.tools.amqp.AMQPBroker method)
deserialize() (microagent.bus.Signal method)
(microagent.queue.Queue method)
dsn (microagent.broker.AbstractQueueBroker attribute)
(microagent.bus.AbstractSignalBus attribute)
G
get() (microagent.bus.Signal class method)
(microagent.queue.Queue class method)
get_all() (microagent.bus.Signal class method)
(microagent.queue.Queue class method)
get_channel() (microagent.tools.amqp.AMQPBroker method)
GroupInterrupt (class in microagent.launcher)
I
info() (microagent.MicroAgent method)
init_agent() (in module microagent.launcher)
K
KafkaBroker (class in microagent.tools.kafka)
L
load_configuration() (in module microagent.launcher)
load_queues() (in module microagent)
load_signals() (in module microagent)
log (microagent.broker.AbstractQueueBroker attribute)
(microagent.bus.AbstractSignalBus attribute)
(microagent.MicroAgent attribute)
M
make_channel_name() (microagent.bus.Signal method)
microagent
module
,
[1]
MicroAgent (class in microagent)
microagent.agent
module
microagent.broker
module
microagent.bus
module
microagent.hooks
module
microagent.launcher
module
microagent.timer
module
microagent.tools.amqp
module
microagent.tools.kafka
module
microagent.tools.mocks
module
microagent.tools.redis
module
module
microagent
,
[1]
microagent.agent
microagent.broker
microagent.bus
microagent.hooks
microagent.launcher
microagent.timer
microagent.tools.amqp
microagent.tools.kafka
microagent.tools.mocks
microagent.tools.redis
N
name (microagent.bus.Signal attribute)
(microagent.queue.Queue attribute)
O
on() (in module microagent)
,
[1]
P
period (microagent.timer.CRONTask property)
periodic() (in module microagent)
,
[1]
PeriodicTask (class in microagent.timer)
prefix (microagent.bus.AbstractSignalBus attribute)
providing_args (microagent.bus.Signal attribute)
putout() (microagent.tools.amqp.AMQPBroker static method)
Q
Queue (class in microagent.queue)
queue_length() (microagent.broker.AbstractQueueBroker method)
(microagent.tools.amqp.AMQPBroker method)
(microagent.tools.kafka.KafkaBroker method)
(microagent.tools.redis.RedisBroker method)
QueueException (class in microagent.queue)
QueueNotFound (class in microagent.queue)
R
Receiver (class in microagent.bus)
receiver() (in module microagent)
,
[1]
(microagent.bus.AbstractSignalBus method)
receivers (microagent.bus.AbstractSignalBus attribute)
RedisBroker (class in microagent.tools.redis)
RedisSignalBus (class in microagent.tools.redis)
ROLLBACK_ATTEMPTS (microagent.tools.redis.RedisBroker attribute)
S
send() (microagent.broker.AbstractQueueBroker method)
(microagent.bus.AbstractSignalBus method)
(microagent.tools.amqp.AMQPBroker method)
(microagent.tools.kafka.KafkaBroker method)
(microagent.tools.redis.RedisBroker method)
(microagent.tools.redis.RedisSignalBus method)
serialize() (microagent.bus.Signal method)
(microagent.queue.Queue method)
SerializingError (class in microagent.queue)
(class in microagent.signal)
ServerInterrupt (class in microagent.launcher)
settings (microagent.MicroAgent attribute)
Signal (class in microagent.bus)
SignalException (class in microagent.signal)
SignalNotFound (class in microagent.signal)
start() (microagent.MicroAgent method)
start_after (microagent.timer.CRONTask property)
U
uid (microagent.broker.AbstractQueueBroker attribute)
(microagent.bus.AbstractSignalBus attribute)
W
WAIT_TIME (microagent.tools.redis.RedisBroker attribute)
waiter() (microagent.bus.BoundSignal method)
Read the Docs
v: stable
Versions
latest
stable
Downloads
pdf
epub
On Read the Docs
Project Home
Builds