eventscore package

Subpackages

• eventscore.core package
  • Submodules
  • eventscore.core.abstract module
    • IECore
      • IECore.process_pipeline
      • IECore.spawn_worker
      • IECore.producer
      • IECore.stream_factory
      • IECore.stream
      • IECore.consumer()
      • IECore.register_consumer()
      • IECore.discover_consumers()
      • IECore.produce()
      • IECore.spawn_workers()
    • IProcessPipeline
    • ISpawnWorker
    • IEventSerializer
      • IEventSerializer.encode()
      • IEventSerializer.decode()
    • IProducer
      • IProducer.produce()
    • IStream
      • IStream.put()
      • IStream.pop()
    • IStreamFactory
    • IRunner
      • IRunner.run()
    • IConsumer
      • IConsumer.consume()
  • eventscore.core.consumers module
    • Consumer
      • Consumer.consume()
  • eventscore.core.ecore module
    • ECore
      • ECore.process_pipeline
      • ECore.spawn_worker
      • ECore.producer
      • ECore.stream_factory
      • ECore.stream
      • ECore.consumer()
      • ECore.register_consumer()
      • ECore.discover_consumers()
      • ECore.produce()
      • ECore.spawn_workers()
  • eventscore.core.exceptions module
    • EventsCoreError
      • EventsCoreError.message
    • AlreadySpawnedError
      • AlreadySpawnedError.message
    • ClonesMismatchError
      • ClonesMismatchError.message
    • EmptyPipelineError
      • EmptyPipelineError.message
    • UnrelatedConsumersError
      • UnrelatedConsumersError.message
    • EventNotSentError
      • EventNotSentError.message
    • EmptyStreamError
      • EmptyStreamError.message
    • TooManyDataError
      • TooManyDataError.message
    • PathError
      • PathError.message
    • NotADirectoryError
      • NotADirectoryError.message
    • NotAPackageError
      • NotAPackageError.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.encode()
      • EventSerializer.decode()
  • eventscore.core.types module
    • DeliverySemantic
      • DeliverySemantic.AT_MOST_ONCE
      • DeliverySemantic.AT_LEAST_ONCE
      • DeliverySemantic.EXACTLY_ONCE
    • EventStatus
      • EventStatus.PENDING
      • EventStatus.SENT
      • EventStatus.FAILED
    • EventDict
      • EventDict.type
      • EventDict.uid
      • EventDict.ts
      • EventDict.payload
    • Event
      • Event.type
      • Event.uid
      • Event.ts
      • Event.payload
      • Event.asdict()
      • Event.fromdict()
    • PipelineItem
      • PipelineItem.func
      • PipelineItem.func_path
      • PipelineItem.event
      • PipelineItem.group
      • PipelineItem.clones
    • Pipeline
      • Pipeline.uid
      • Pipeline.items
    • Worker
      • Worker.name
      • Worker.runner
      • Worker.clones
      • 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

consumer(func=None, *, ecore, event, group, clones=1)

Parameters:

• func (Callable[[Event], Any] | None)

• ecore (IECore)

• event (str | StrEnum | IntEnum)

• group (str | StrEnum | IntEnum)

• clones (int)

Return type:

Callable[[Event], Any]

eventscore.shortcuts module

Module contents