diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-01 12:11:08 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-01 12:11:08 -0800 |
| commit | 9fe904e9bbc64a8bcd1fa5876a76ca93b544cdfe (patch) | |
| tree | 0db96299d0aa449d25cdeda4ca497189f4b6995e /kafka/protocol/struct.py | |
| parent | 9258bb4ba5e66565f74a691640c5c11f3b58bbd8 (diff) | |
| download | kafka-python-9fe904e9bbc64a8bcd1fa5876a76ca93b544cdfe.tar.gz | |
Struct __eq__
Diffstat (limited to 'kafka/protocol/struct.py')
| -rw-r--r-- | kafka/protocol/struct.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/kafka/protocol/struct.py b/kafka/protocol/struct.py index d340abf..0a96c02 100644 --- a/kafka/protocol/struct.py +++ b/kafka/protocol/struct.py @@ -44,6 +44,13 @@ class Struct(AbstractType): key_vals.append('%s=%s' % (name, field.repr(self.__dict__[name]))) return self.__class__.__name__ + '(' + ', '.join(key_vals) + ')' + def __eq__(self, other): + if self.SCHEMA != other.SCHEMA: + return False + for attr in self.SCHEMA.names: + if self.__dict__[attr] != other.__dict__[attr]: + return False + return True """ class MetaStruct(type): |