diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-11-28 19:41:06 +0800 |
|---|---|---|
| committer | Zack Dever <zack.dever@rd.io> | 2015-12-04 11:25:39 -0800 |
| commit | a85e09df89a43de5b659a0fa4ed35bec37c60e04 (patch) | |
| tree | a539af32fe502006c1f35b96d8ae36225292f7a5 /kafka/protocol/abstract.py | |
| parent | e24a4d5f5252d6f97ac586e328b95779ef83f4b6 (diff) | |
| download | kafka-python-a85e09df89a43de5b659a0fa4ed35bec37c60e04.tar.gz | |
Rework protocol type definition: AbstractType, Schema, Struct
Diffstat (limited to 'kafka/protocol/abstract.py')
| -rw-r--r-- | kafka/protocol/abstract.py | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/kafka/protocol/abstract.py b/kafka/protocol/abstract.py new file mode 100644 index 0000000..9c53c8c --- /dev/null +++ b/kafka/protocol/abstract.py @@ -0,0 +1,13 @@ +import abc + + +class AbstractType(object): + __metaclass__ = abc.ABCMeta + + @abc.abstractmethod + def encode(cls, value): + pass + + @abc.abstractmethod + def decode(cls, data): + pass |