Source code for kafka.protocol.abstract

from __future__ import absolute_import

import abc


[docs]class AbstractType(object): __metaclass__ = abc.ABCMeta @abc.abstractmethod
[docs] def encode(cls, value): # pylint: disable=no-self-argument pass
@abc.abstractmethod
[docs] def decode(cls, data): # pylint: disable=no-self-argument pass
@classmethod
[docs] def repr(cls, value): return repr(value)