import msgpack class Message(object): def __init__(self, message_type, data, node_id): self.type = message_type self.data = data self.node_id = node_id def serialize(self): return msgpack.dumps((self.type, self.data, self.node_id)) @classmethod def unserialize(cls, data): msg = cls(*msgpack.loads(data, encoding='utf-8')) return msg
# | Change | User | Description | Committed | |
---|---|---|---|---|---|
#1 | 21680 | Robert Cowham |
Populate -o //guest/robert_cowham/p4benchmark/main/locust/... //guest/robert_cowham/p4benchmark/github/locust/.... |
||
//guest/robert_cowham/p4benchmark/main/locust/locust/rpc/protocol.py | |||||
#1 | 19772 | Robert Cowham | Initial version of locust |