Replay

class fedmsg.replay.ReplayContext(**config)

Bases: object

listen()

fedmsg.replay.check_for_replay(name, names_to_seq_id, msg, config, context=None)

fedmsg.replay.get_replay(name, query, config, context=None)

Replay queries

Currently, a query is the union of multiple criteria. It means that the more criteria you add, the bigger the result set should become. The following criteria are supported:

seq_ids

list - A list of integers, matching the seq_id attributes of the messages. It should return at most as many messages as the length of the list, assuming no duplicate. Supported by SqlStore.

seq_id

int - A single integer matching the seq_id attribute of the messages. Should return a single message. It is intended as a shorthand for singleton seq_ids queries. Supported by SqlStore.

seq_id_range

tuple - A couple of integers defining a range of seq_id to check. Supported by SqlStore

msg_ids

list - a list of UUIDs matching the msg_id attribute of the messages. Supported by SqlStore.

msg_id

uuid - A single UUID for the msg_id attribute. Supported by SqlStore.

time

tuple - Couple of timestamps. It will return all messages emitted inbetween. Supported by SqlStore