Index

A

arroyo.dlq module arroyo.processing.strategies.abstract module arroyo.processing.strategies.batching module arroyo.processing.strategies.commit module arroyo.processing.strategies.filter module arroyo.processing.strategies.healthcheck module arroyo.processing.strategies.noop module arroyo.processing.strategies.produce module

arroyo.processing.strategies.reduce module arroyo.processing.strategies.run_task module arroyo.processing.strategies.run_task_in_threads module arroyo.processing.strategies.run_task_with_multiprocessing module arroyo.processing.strategies.unfold module arroyo.types module arroyo.utils.metrics module

B

BaseValue (class in arroyo.types)

BatchStep (class in arroyo.processing.strategies.batching) BrokerValue (class in arroyo.types)

C

close() (arroyo.processing.strategies.abstract.ProcessingStrategy method) Commit (class in arroyo.types) CommitOffsets (class in arroyo.processing.strategies.commit) committable (arroyo.types.BaseValue property) (arroyo.types.BrokerValue property) (arroyo.types.Message property) (arroyo.types.Value property)

configure_metrics() (in module arroyo.utils.metrics) create_with_partitions() (arroyo.processing.strategies.abstract.ProcessingStrategyFactory method)

D

DlqLimit (class in arroyo.dlq)

DlqPolicy (class in arroyo.dlq)

F

FilteredPayload (class in arroyo.types)

FilterStep (class in arroyo.processing.strategies.filter)

G

gauge() (arroyo.utils.metrics.Metrics method)

H

Healthcheck (class in arroyo.processing.strategies.healthcheck)

I

increment() (arroyo.utils.metrics.Metrics method)

index (arroyo.types.Partition attribute) InvalidMessage

J

join() (arroyo.processing.strategies.abstract.ProcessingStrategy method) (arroyo.processing.strategies.batching.BatchStep method)

K

KafkaDlqProducer (class in arroyo.dlq)

M

Message (class in arroyo.types) MessageRejected Metrics (class in arroyo.utils.metrics) module arroyo.dlq arroyo.processing.strategies.abstract arroyo.processing.strategies.batching arroyo.processing.strategies.commit arroyo.processing.strategies.filter arroyo.processing.strategies.healthcheck arroyo.processing.strategies.noop arroyo.processing.strategies.produce arroyo.processing.strategies.reduce arroyo.processing.strategies.run_task arroyo.processing.strategies.run_task_in_threads arroyo.processing.strategies.run_task_with_multiprocessing arroyo.processing.strategies.unfold arroyo.types arroyo.utils.metrics

N

name (arroyo.types.Topic attribute) next_offset (arroyo.types.BrokerValue property)

Noop (class in arroyo.processing.strategies.noop) NoopDlqProducer (class in arroyo.dlq)

O

offset (arroyo.types.BrokerValue attribute)

P

partition (arroyo.types.BrokerValue attribute) Partition (class in arroyo.types) payload (arroyo.types.BaseValue property) (arroyo.types.BrokerValue property) (arroyo.types.Message property) (arroyo.types.Value property)

payload_unfiltered (arroyo.types.Message property) poll() (arroyo.processing.strategies.abstract.ProcessingStrategy method) ProcessingStrategy (class in arroyo.processing.strategies.abstract) ProcessingStrategyFactory (class in arroyo.processing.strategies.abstract) Produce (class in arroyo.processing.strategies.produce)

R

Reduce (class in arroyo.processing.strategies.reduce) replace() (arroyo.types.BaseValue method) (arroyo.types.BrokerValue method) (arroyo.types.Message method) (arroyo.types.Value method)

RunTask (class in arroyo.processing.strategies.run_task) RunTaskInThreads (class in arroyo.processing.strategies.run_task_in_threads) RunTaskWithMultiprocessing (class in arroyo.processing.strategies.run_task_with_multiprocessing)

S

shutdown() (arroyo.processing.strategies.abstract.ProcessingStrategyFactory method)

submit() (arroyo.processing.strategies.abstract.ProcessingStrategy method) (arroyo.processing.strategies.batching.BatchStep method)

T

terminate() (arroyo.processing.strategies.abstract.ProcessingStrategy method) timestamp (arroyo.types.BaseValue property) (arroyo.types.BrokerValue attribute) (arroyo.types.Message property) (arroyo.types.Value property)

timing() (arroyo.utils.metrics.Metrics method) topic (arroyo.types.Partition attribute) Topic (class in arroyo.types)

U

UnbatchStep (class in arroyo.processing.strategies.batching)

Unfold (class in arroyo.processing.strategies.unfold)

V

value (arroyo.types.Message attribute)

Value (class in arroyo.types)