pyemit package

Submodules

pyemit.emit module

class pyemit.emit.Engine

Bases: enum.IntEnum

An enumeration.

IN_PROCESS = 0

REDIS = 1

pyemit.emit.async_register(event: str, handler: Callable, exchange='')

异步地将一个`handler`注册到事件`event`的处理器队列中。 :param event: :param handler: :param exchange: :return:

pyemit.emit.emit(channel: str, message: Any = None, exchange='')

publish a message to channel. :param channel: the name of channel :param message: :return:

pyemit.emit.on(event, exchange='')

提供了消息注册的装饰器实现 Args:

event: exchange:

Returns:

pyemit.emit.register(event: str, handler: Callable, exchange='')

为`event`注册一个事件处理器。如果 :param event: :param handler: :param exchange: :return:

pyemit.emit.rpc_respond(msg: dict)

pyemit.emit.rpc_send(remote) → Any

emit msg and wait response back. The func will add __emit_sn__ to the dict, and the server should echo the serial number back. Args:

remote:

Returns:

pyemit.emit.start(engine: pyemit.emit.Engine = <Engine.IN_PROCESS: 0>, start_server=False, heart_beat=0, **kwargs)

Args:

engine: start_server: heart_beat:

pyemit.emit.stop()

显式地关闭与redis的连接，释放资源

pyemit.emit.unsubscribe(channel: str, handler: Callable, exchange='')

stop subscribe message from channel :param channel: :param handler: :return:

pyemit.remote module

Author: Aaron-Yang [code@jieyu.ai] Contributors:

class pyemit.remote.Remote(timeout=10)

Bases: object

invoke()

static loads(s) → pyemit.remote.Remote

respond(result: Any)

server_impl()

sn

timeout

Module contents

Top-level package for py-emit.