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
      • eventscore.ext.kafka.streams module
      • Module contents
    • eventscore.ext.redis package
      • Submodules
      • eventscore.ext.redis.serializers module
      • eventscore.ext.redis.streams module
      • Module contents
  • Module contents

Submodules

eventscore.decorators module

eventscore.decorators.consumer(func: Callable[[Event], Any] | None = None, *, ecore: IECore, event: str | StrEnum | IntEnum, group: str | StrEnum | IntEnum, clones: int = 1) → Callable[[Event], Any]

eventscore.shortcuts module

Module contents