class documentation

class Function(object): (source)

View In Hierarchy

Interface for Pulsar Function

Method process Process input message
@abstractmethod
def process(self, input, context): (source)

Process input message