Index

_

__call__() (eventscore.core.abstract.IProcessPipeline method) (eventscore.core.abstract.ISpawnWorker method) (eventscore.core.abstract.IStreamFactory method)

__eq__() (eventscore.core.types.PipelineItem method) __hash__() (eventscore.core.types.PipelineItem method)

A

AlreadySpawnedError asdict() (eventscore.core.types.Event method)

AT_LEAST_ONCE (eventscore.core.types.DeliverySemantic attribute) AT_MOST_ONCE (eventscore.core.types.DeliverySemantic attribute)

C

clones (eventscore.core.types.PipelineItem attribute) (eventscore.core.types.Worker attribute) ClonesMismatchError consume() (eventscore.core.abstract.IConsumer method) (eventscore.core.consumers.Consumer method)

Consumer (class in eventscore.core.consumers) consumer() (eventscore.core.abstract.IECore method) (eventscore.core.ecore.ECore method) (in module eventscore.decorators)

D

decode() (eventscore.core.abstract.IEventSerializer method) (eventscore.core.serializers.EventSerializer method) (eventscore.ext.kafka.serializers.KafkaEventSerializer method) (eventscore.ext.redis.serializers.RedisEventSerializer method)

DeliverySemantic (class in eventscore.core.types) discover_consumers() (eventscore.core.abstract.IECore method) (eventscore.core.ecore.ECore method)

E

ECore (class in eventscore.core.ecore) EmptyPipelineError EmptyStreamError encode() (eventscore.core.abstract.IEventSerializer method) (eventscore.core.serializers.EventSerializer method) (eventscore.ext.kafka.serializers.KafkaEventSerializer method) (eventscore.ext.redis.serializers.RedisEventSerializer method) Event (class in eventscore.core.types) event (eventscore.core.types.PipelineItem attribute) EventDict (class in eventscore.core.types) EventNotSentError eventscore module eventscore.core module eventscore.core.abstract module eventscore.core.consumers module eventscore.core.ecore module eventscore.core.exceptions module eventscore.core.logging module eventscore.core.pipelines module

eventscore.core.producers module eventscore.core.runners module eventscore.core.serializers module eventscore.core.types module eventscore.core.workers module eventscore.decorators module eventscore.ext module eventscore.ext.kafka module eventscore.ext.kafka.serializers module eventscore.ext.redis module eventscore.ext.redis.serializers module eventscore.shortcuts module EventsCoreError EventSerializer (class in eventscore.core.serializers) EventStatus (class in eventscore.core.types) EXACTLY_ONCE (eventscore.core.types.DeliverySemantic attribute)

F

FAILED (eventscore.core.types.EventStatus attribute) fromdict() (eventscore.core.types.Event class method)

func (eventscore.core.types.PipelineItem attribute) func_path (eventscore.core.types.PipelineItem attribute)

G

group (eventscore.core.types.PipelineItem attribute)

I

IConsumer (class in eventscore.core.abstract) IECore (class in eventscore.core.abstract) IEventSerializer (class in eventscore.core.abstract) IProcessPipeline (class in eventscore.core.abstract) IProducer (class in eventscore.core.abstract)

IRunner (class in eventscore.core.abstract) ISpawnWorker (class in eventscore.core.abstract) IStream (class in eventscore.core.abstract) IStreamFactory (class in eventscore.core.abstract) items (eventscore.core.types.Pipeline attribute)

K

KafkaEventSerializer (class in eventscore.ext.kafka.serializers)

M

message (eventscore.core.exceptions.AlreadySpawnedError attribute) (eventscore.core.exceptions.ClonesMismatchError attribute) (eventscore.core.exceptions.EmptyPipelineError attribute) (eventscore.core.exceptions.EmptyStreamError attribute) (eventscore.core.exceptions.EventNotSentError attribute) (eventscore.core.exceptions.EventsCoreError attribute) (eventscore.core.exceptions.NotADirectoryError attribute) (eventscore.core.exceptions.NotAPackageError attribute) (eventscore.core.exceptions.PathError attribute) (eventscore.core.exceptions.TooManyDataError attribute) (eventscore.core.exceptions.UnrelatedConsumersError attribute) module eventscore eventscore.core eventscore.core.abstract eventscore.core.consumers eventscore.core.ecore eventscore.core.exceptions eventscore.core.logging eventscore.core.pipelines eventscore.core.producers eventscore.core.runners eventscore.core.serializers eventscore.core.types eventscore.core.workers eventscore.decorators eventscore.ext eventscore.ext.kafka eventscore.ext.kafka.serializers eventscore.ext.redis eventscore.ext.redis.serializers eventscore.shortcuts

N

name (eventscore.core.types.Worker attribute)

NotADirectoryError NotAPackageError

O

ObserverRunner (class in eventscore.core.runners)

P

PathError payload (eventscore.core.types.Event attribute) (eventscore.core.types.EventDict attribute) PENDING (eventscore.core.types.EventStatus attribute) Pipeline (class in eventscore.core.types) PipelineItem (class in eventscore.core.types) pop() (eventscore.core.abstract.IStream method) process_pipeline (eventscore.core.abstract.IECore property) (eventscore.core.ecore.ECore property)

ProcessPipeline (class in eventscore.core.pipelines) produce() (eventscore.core.abstract.IECore method) (eventscore.core.abstract.IProducer method) (eventscore.core.ecore.ECore method) (eventscore.core.producers.Producer method) Producer (class in eventscore.core.producers) producer (eventscore.core.abstract.IECore property) (eventscore.core.ecore.ECore property) put() (eventscore.core.abstract.IStream method)

R

RedisEventSerializer (class in eventscore.ext.redis.serializers) register_consumer() (eventscore.core.abstract.IECore method) (eventscore.core.ecore.ECore method)

run() (eventscore.core.abstract.IRunner method) (eventscore.core.runners.ObserverRunner method) runner (eventscore.core.types.Worker attribute)

S

SENT (eventscore.core.types.EventStatus attribute) spawn_worker (eventscore.core.abstract.IECore property) (eventscore.core.ecore.ECore property) spawn_workers() (eventscore.core.abstract.IECore method) (eventscore.core.ecore.ECore method)

SpawnMPWorker (class in eventscore.core.workers) stream (eventscore.core.abstract.IECore property) (eventscore.core.ecore.ECore property) stream_factory (eventscore.core.abstract.IECore property) (eventscore.core.ecore.ECore property)

T

TooManyDataError ts (eventscore.core.types.Event attribute) (eventscore.core.types.EventDict attribute)

type (eventscore.core.types.Event attribute) (eventscore.core.types.EventDict attribute)

U

uid (eventscore.core.types.Event attribute) (eventscore.core.types.EventDict attribute) (eventscore.core.types.Pipeline attribute) (eventscore.core.types.Worker attribute)

UnrelatedConsumersError

W

Worker (class in eventscore.core.types)