Welcome to eventscore!

• eventscore package
  • Subpackages
    • eventscore.core package
      • Submodules
      • eventscore.core.abstract module
        • IConsumer
          • IConsumer.consume()
        • IECore
          • IECore.consumer()
          • IECore.discover_consumers()
          • IECore.process_pipeline
          • IECore.produce()
          • IECore.producer
          • IECore.register_consumer()
          • IECore.spawn_worker
          • IECore.spawn_workers()
          • IECore.stream
          • IECore.stream_factory
        • IEventSerializer
          • IEventSerializer.decode()
          • IEventSerializer.encode()
        • IProcessPipeline
          • IProcessPipeline.__call__()
        • IProducer
          • IProducer.produce()
        • IRunner
          • IRunner.run()
        • ISpawnWorker
          • ISpawnWorker.__call__()
        • IStream
          • IStream.pop()
          • IStream.put()
        • IStreamFactory
          • IStreamFactory.__call__()
      • eventscore.core.consumers module
        • Consumer
          • Consumer.consume()
      • eventscore.core.ecore module
        • ECore
          • ECore.consumer()
          • ECore.discover_consumers()
          • ECore.process_pipeline
          • ECore.produce()
          • ECore.producer
          • ECore.register_consumer()
          • ECore.spawn_worker
          • ECore.spawn_workers()
          • ECore.stream
          • ECore.stream_factory
      • eventscore.core.exceptions module
        • AlreadySpawnedError
          • AlreadySpawnedError.message
        • ClonesMismatchError
          • ClonesMismatchError.message
        • EmptyPipelineError
          • EmptyPipelineError.message
        • EmptyStreamError
          • EmptyStreamError.message
        • EventNotSentError
          • EventNotSentError.message
        • EventsCoreError
          • EventsCoreError.message
        • NotADirectoryError
          • NotADirectoryError.message
        • NotAPackageError
          • NotAPackageError.message
        • PathError
          • PathError.message
        • TooManyDataError
          • TooManyDataError.message
        • UnrelatedConsumersError
          • UnrelatedConsumersError.message
      • eventscore.core.logging module
      • eventscore.core.pipelines module
        • ProcessPipeline
      • eventscore.core.producers module
        • Producer
          • Producer.produce()
      • eventscore.core.runners module
        • ObserverRunner
          • ObserverRunner.run()
      • eventscore.core.serializers module
        • EventSerializer
          • EventSerializer.decode()
          • EventSerializer.encode()
      • eventscore.core.types module
        • DeliverySemantic
          • DeliverySemantic.AT_LEAST_ONCE
          • DeliverySemantic.AT_MOST_ONCE
          • DeliverySemantic.EXACTLY_ONCE
        • Event
          • Event.asdict()
          • Event.fromdict()
          • Event.payload
          • Event.ts
          • Event.type
          • Event.uid
        • EventDict
          • EventDict.payload
          • EventDict.ts
          • EventDict.type
          • EventDict.uid
        • EventStatus
          • EventStatus.FAILED
          • EventStatus.PENDING
          • EventStatus.SENT
        • Pipeline
          • Pipeline.items
          • Pipeline.uid
        • PipelineItem
          • PipelineItem.__eq__()
          • PipelineItem.__hash__()
          • PipelineItem.clones
          • PipelineItem.event
          • PipelineItem.func
          • PipelineItem.func_path
          • PipelineItem.group
        • Worker
          • Worker.clones
          • Worker.name
          • Worker.runner
          • Worker.uid
      • eventscore.core.workers module
        • SpawnMPWorker
      • Module contents
    • eventscore.ext package
      • Subpackages
        • eventscore.ext.kafka package
          • Submodules
          • eventscore.ext.kafka.serializers module
            • KafkaEventSerializer
              • KafkaEventSerializer.decode()
              • KafkaEventSerializer.encode()
          • eventscore.ext.kafka.streams module
          • Module contents
        • eventscore.ext.redis package
          • Submodules
          • eventscore.ext.redis.serializers module
            • RedisEventSerializer
              • RedisEventSerializer.decode()
              • RedisEventSerializer.encode()
          • eventscore.ext.redis.streams module
          • Module contents
      • Module contents
  • Submodules
  • eventscore.decorators module
    • consumer()
  • eventscore.shortcuts module
  • Module contents
• eventscore.core package
  • Submodules
  • eventscore.core.abstract module
    • IConsumer
      • IConsumer.consume()
    • IECore
      • IECore.consumer()
      • IECore.discover_consumers()
      • IECore.process_pipeline
      • IECore.produce()
      • IECore.producer
      • IECore.register_consumer()
      • IECore.spawn_worker
      • IECore.spawn_workers()
      • IECore.stream
      • IECore.stream_factory
    • IEventSerializer
      • IEventSerializer.decode()
      • IEventSerializer.encode()
    • IProcessPipeline
      • IProcessPipeline.__call__()
    • IProducer
      • IProducer.produce()
    • IRunner
      • IRunner.run()
    • ISpawnWorker
      • ISpawnWorker.__call__()
    • IStream
      • IStream.pop()
      • IStream.put()
    • IStreamFactory
      • IStreamFactory.__call__()
  • eventscore.core.consumers module
    • Consumer
      • Consumer.consume()
  • eventscore.core.ecore module
    • ECore
      • ECore.consumer()
      • ECore.discover_consumers()
      • ECore.process_pipeline
      • ECore.produce()
      • ECore.producer
      • ECore.register_consumer()
      • ECore.spawn_worker
      • ECore.spawn_workers()
      • ECore.stream
      • ECore.stream_factory
  • eventscore.core.exceptions module
    • AlreadySpawnedError
      • AlreadySpawnedError.message
    • ClonesMismatchError
      • ClonesMismatchError.message
    • EmptyPipelineError
      • EmptyPipelineError.message
    • EmptyStreamError
      • EmptyStreamError.message
    • EventNotSentError
      • EventNotSentError.message
    • EventsCoreError
      • EventsCoreError.message
    • NotADirectoryError
      • NotADirectoryError.message
    • NotAPackageError
      • NotAPackageError.message
    • PathError
      • PathError.message
    • TooManyDataError
      • TooManyDataError.message
    • UnrelatedConsumersError
      • UnrelatedConsumersError.message
  • eventscore.core.logging module
  • eventscore.core.pipelines module
    • ProcessPipeline
  • eventscore.core.producers module
    • Producer
      • Producer.produce()
  • eventscore.core.runners module
    • ObserverRunner
      • ObserverRunner.run()
  • eventscore.core.serializers module
    • EventSerializer
      • EventSerializer.decode()
      • EventSerializer.encode()
  • eventscore.core.types module
    • DeliverySemantic
      • DeliverySemantic.AT_LEAST_ONCE
      • DeliverySemantic.AT_MOST_ONCE
      • DeliverySemantic.EXACTLY_ONCE
    • Event
      • Event.asdict()
      • Event.fromdict()
      • Event.payload
      • Event.ts
      • Event.type
      • Event.uid
    • EventDict
      • EventDict.payload
      • EventDict.ts
      • EventDict.type
      • EventDict.uid
    • EventStatus
      • EventStatus.FAILED
      • EventStatus.PENDING
      • EventStatus.SENT
    • Pipeline
      • Pipeline.items
      • Pipeline.uid
    • PipelineItem
      • PipelineItem.__eq__()
      • PipelineItem.__hash__()
      • PipelineItem.clones
      • PipelineItem.event
      • PipelineItem.func
      • PipelineItem.func_path
      • PipelineItem.group
    • Worker
      • Worker.clones
      • Worker.name
      • Worker.runner
      • Worker.uid
  • eventscore.core.workers module
    • SpawnMPWorker
  • Module contents
• eventscore.ext package
  • Subpackages
    • eventscore.ext.kafka package
      • Submodules
      • eventscore.ext.kafka.serializers module
        • KafkaEventSerializer
          • KafkaEventSerializer.decode()
          • KafkaEventSerializer.encode()
      • eventscore.ext.kafka.streams module
      • Module contents
    • eventscore.ext.redis package
      • Submodules
      • eventscore.ext.redis.serializers module
        • RedisEventSerializer
          • RedisEventSerializer.decode()
          • RedisEventSerializer.encode()
      • eventscore.ext.redis.streams module
      • Module contents
  • Module contents
• eventscore.ext.kafka package
  • Submodules
  • eventscore.ext.kafka.serializers module
    • KafkaEventSerializer
      • KafkaEventSerializer.decode()
      • KafkaEventSerializer.encode()
  • eventscore.ext.kafka.streams module
  • Module contents
• eventscore.ext.redis package
  • Submodules
  • eventscore.ext.redis.serializers module
    • RedisEventSerializer
      • RedisEventSerializer.decode()
      • RedisEventSerializer.encode()
  • eventscore.ext.redis.streams module
  • Module contents
• eventscore
  • eventscore package
    • Subpackages
      • eventscore.core package
        • Submodules
        • eventscore.core.abstract module
          • IConsumer
            • IConsumer.consume()
          • IECore
            • IECore.consumer()
            • IECore.discover_consumers()
            • IECore.process_pipeline
            • IECore.produce()
            • IECore.producer
            • IECore.register_consumer()
            • IECore.spawn_worker
            • IECore.spawn_workers()
            • IECore.stream
            • IECore.stream_factory
          • IEventSerializer
            • IEventSerializer.decode()
            • IEventSerializer.encode()
          • IProcessPipeline
            • IProcessPipeline.__call__()
          • IProducer
            • IProducer.produce()
          • IRunner
            • IRunner.run()
          • ISpawnWorker
            • ISpawnWorker.__call__()
          • IStream
            • IStream.pop()
            • IStream.put()
          • IStreamFactory
            • IStreamFactory.__call__()
        • eventscore.core.consumers module
          • Consumer
            • Consumer.consume()
        • eventscore.core.ecore module
          • ECore
            • ECore.consumer()
            • ECore.discover_consumers()
            • ECore.process_pipeline
            • ECore.produce()
            • ECore.producer
            • ECore.register_consumer()
            • ECore.spawn_worker
            • ECore.spawn_workers()
            • ECore.stream
            • ECore.stream_factory
        • eventscore.core.exceptions module
          • AlreadySpawnedError
            • AlreadySpawnedError.message
          • ClonesMismatchError
            • ClonesMismatchError.message
          • EmptyPipelineError
            • EmptyPipelineError.message
          • EmptyStreamError
            • EmptyStreamError.message
          • EventNotSentError
            • EventNotSentError.message
          • EventsCoreError
            • EventsCoreError.message
          • NotADirectoryError
            • NotADirectoryError.message
          • NotAPackageError
            • NotAPackageError.message
          • PathError
            • PathError.message
          • TooManyDataError
            • TooManyDataError.message
          • UnrelatedConsumersError
            • UnrelatedConsumersError.message
        • eventscore.core.logging module
        • eventscore.core.pipelines module
          • ProcessPipeline
        • eventscore.core.producers module
          • Producer
            • Producer.produce()
        • eventscore.core.runners module
          • ObserverRunner
            • ObserverRunner.run()
        • eventscore.core.serializers module
          • EventSerializer
            • EventSerializer.decode()
            • EventSerializer.encode()
        • eventscore.core.types module
          • DeliverySemantic
            • DeliverySemantic.AT_LEAST_ONCE
            • DeliverySemantic.AT_MOST_ONCE
            • DeliverySemantic.EXACTLY_ONCE
          • Event
            • Event.asdict()
            • Event.fromdict()
            • Event.payload
            • Event.ts
            • Event.type
            • Event.uid
          • EventDict
            • EventDict.payload
            • EventDict.ts
            • EventDict.type
            • EventDict.uid
          • EventStatus
            • EventStatus.FAILED
            • EventStatus.PENDING
            • EventStatus.SENT
          • Pipeline
            • Pipeline.items
            • Pipeline.uid
          • PipelineItem
            • PipelineItem.__eq__()
            • PipelineItem.__hash__()
            • PipelineItem.clones
            • PipelineItem.event
            • PipelineItem.func
            • PipelineItem.func_path
            • PipelineItem.group
          • Worker
            • Worker.clones
            • Worker.name
            • Worker.runner
            • Worker.uid
        • eventscore.core.workers module
          • SpawnMPWorker
        • Module contents
      • eventscore.ext package
        • Subpackages
          • eventscore.ext.kafka package
            • Submodules
            • eventscore.ext.kafka.serializers module
              • KafkaEventSerializer
                • KafkaEventSerializer.decode()
                • KafkaEventSerializer.encode()
            • eventscore.ext.kafka.streams module
            • Module contents
          • eventscore.ext.redis package
            • Submodules
            • eventscore.ext.redis.serializers module
              • RedisEventSerializer
                • RedisEventSerializer.decode()
                • RedisEventSerializer.encode()
            • eventscore.ext.redis.streams module
            • Module contents
        • Module contents
    • Submodules
    • eventscore.decorators module
      • consumer()
    • eventscore.shortcuts module
    • Module contents