Index

A

AlreadySpawnedError, [1] asdict() (Event method), [1]

AT_LEAST_ONCE (DeliverySemantic attribute), [1] AT_MOST_ONCE (DeliverySemantic attribute), [1]

C

clones (PipelineItem attribute), [1] (Worker attribute), [1] ClonesMismatchError, [1] consume() (Consumer method), [1] (IConsumer method), [1]

Consumer (class in eventscore.core.consumers), [1] consumer() (ECore method), [1] (IECore method), [1] (in module eventscore.decorators), [1]

D

decode() (EventSerializer method), [1] (IEventSerializer method), [1] (KafkaEventSerializer method) (RedisEventSerializer method), [1]

DeliverySemantic (class in eventscore.core.types), [1] discover_consumers() (ECore method), [1] (IECore method), [1]

E

ECore (class in eventscore.core.ecore), [1] EmptyPipelineError, [1] EmptyStreamError, [1] encode() (EventSerializer method), [1] (IEventSerializer method), [1] (KafkaEventSerializer method) (RedisEventSerializer method), [1] Event (class in eventscore.core.types), [1] event (PipelineItem attribute), [1] EventDict (class in eventscore.core.types), [1] EventNotSentError, [1] eventscore module eventscore.core module, [1] eventscore.core.abstract module, [1] eventscore.core.consumers module, [1] eventscore.core.ecore module, [1] eventscore.core.exceptions module, [1] eventscore.core.logging module, [1] eventscore.core.pipelines module, [1] eventscore.core.pkg module eventscore.core.producers module, [1]

eventscore.core.runners module, [1] eventscore.core.serializers module, [1] eventscore.core.streams module eventscore.core.types module, [1] eventscore.core.workers module, [1] eventscore.decorators module, [1] eventscore.ext module, [1] eventscore.ext.kafka module eventscore.ext.kafka.serializers module eventscore.ext.kafka.streams module eventscore.ext.redis module, [1] eventscore.ext.redis.serializers module, [1] eventscore.ext.redis.streams module, [1] eventscore.shortcuts module, [1] EventsCoreError, [1] EventSerializer (class in eventscore.core.serializers), [1] EventStatus (class in eventscore.core.types), [1] EXACTLY_ONCE (DeliverySemantic attribute), [1]

F

FAILED (EventStatus attribute), [1] fromdict() (Event class method), [1]

func (PipelineItem attribute), [1] func_path (PipelineItem attribute), [1]

G

group (PipelineItem attribute), [1]

I

IConsumer (class in eventscore.core.abstract), [1] IECore (class in eventscore.core.abstract), [1] IEventSerializer (class in eventscore.core.abstract), [1] IProcessPipeline (class in eventscore.core.abstract), [1] IProducer (class in eventscore.core.abstract), [1]

IRunner (class in eventscore.core.abstract), [1] is_python_package() (in module eventscore.core.pkg) ISpawnWorker (class in eventscore.core.abstract), [1] IStream (class in eventscore.core.abstract), [1] IStreamFactory (class in eventscore.core.abstract), [1] items (Pipeline attribute), [1]

K

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

KafkaStream (class in eventscore.ext.kafka.streams)

M

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

module_name_from_path() (in module eventscore.core.pkg)

N

name (Worker attribute), [1]

NotADirectoryError, [1] NotAPackageError, [1]

O

ObserverRunner (class in eventscore.core.runners), [1]

P

PathError, [1] payload (Event attribute), [1] (EventDict attribute), [1] PENDING (EventStatus attribute), [1] Pipeline (class in eventscore.core.types), [1] PipelineItem (class in eventscore.core.types), [1] pop() (IStream method), [1] (KafkaStream method) (RedisStream method), [1] process_pipeline (ECore property), [1] (IECore property), [1]

ProcessPipeline (class in eventscore.core.pipelines), [1] produce() (ECore method), [1] (IECore method), [1] (IProducer method), [1] (Producer method), [1] Producer (class in eventscore.core.producers), [1] producer (ECore property), [1] (IECore property), [1] put() (IStream method), [1] (KafkaStream method) (RedisStream method), [1]

R

RedisEventSerializer (class in eventscore.ext.redis.serializers), [1] RedisStream (class in eventscore.ext.redis.streams), [1] register_consumer() (ECore method), [1] (IECore method), [1]

run() (IRunner method), [1] (ObserverRunner method), [1] runner (Worker attribute), [1]

S

SENT (EventStatus attribute), [1] spawn_worker (ECore property), [1] (IECore property), [1] spawn_workers() (ECore method), [1] (IECore method), [1]

SpawnMPWorker (class in eventscore.core.workers), [1] stream (ECore property), [1] (IECore property), [1] stream_factory (ECore property), [1] (IECore property), [1] StreamFactory (class in eventscore.core.streams)

T

TooManyDataError, [1] ts (Event attribute), [1] (EventDict attribute), [1]

type (Event attribute), [1] (EventDict attribute), [1]

U

uid (Event attribute), [1] (EventDict attribute), [1] (Pipeline attribute), [1] (Worker attribute), [1]

UnrelatedConsumersError, [1]

W

walk_files() (in module eventscore.core.pkg)

Worker (class in eventscore.core.types), [1]