Index

A

ack() (motorway.messages.Message method)

B

batch_process() (in module motorway.decorators)

C

can_claim_shard() (motorway.contrib.amazon_kinesis.ramps.KinesisRamp method)

claim_shard() (motorway.contrib.amazon_kinesis.ramps.KinesisRamp method)

D

definition() (motorway.pipeline.Pipeline method)

F

fail() (motorway.messages.Message method)

failed() (motorway.ramp.Ramp method) from_message() (motorway.messages.Message class method)

I

Intersection (class in motorway.intersection)

K

KinesisInsertIntersection (class in motorway.contrib.amazon_kinesis.intersections)

KinesisRamp (class in motorway.contrib.amazon_kinesis.ramps)

M

Message (class in motorway.messages)

N

new() (motorway.messages.Message class method) next() (motorway.contrib.amazon_kinesis.ramps.KinesisRamp method) (motorway.contrib.amazon_sqs.ramps.SQSRamp method) (motorway.ramp.Ramp method)

P

Pipeline (class in motorway.pipeline) process() (motorway.contrib.amazon_kinesis.intersections.KinesisInsertIntersection method) (motorway.contrib.amazon_sqs.intersections.SQSInsertIntersection method) (motorway.intersection.Intersection method)

process_shard() (motorway.contrib.amazon_kinesis.ramps.KinesisRamp method)

R

Ramp (class in motorway.ramp)

receive_messages() (motorway.intersection.Intersection method) run() (motorway.pipeline.Pipeline method)

S

send_control_message() (motorway.messages.Message method) should_run() (motorway.ramp.Ramp method) SQSInsertIntersection (class in motorway.contrib.amazon_sqs.intersections)

SQSRamp (class in motorway.contrib.amazon_sqs.ramps) success() (motorway.contrib.amazon_kinesis.ramps.KinesisRamp method) (motorway.contrib.amazon_sqs.ramps.SQSRamp method) (motorway.ramp.Ramp method)