Index

A | C | D | E | G | H | I | M | N | R | S | T

A

ack_endpoint (zmqpipeline.Collector attribute), [1]

C

Collector (class in zmqpipeline), [1]

D

dependencies (zmqpipeline.Task attribute)
Distributor (class in zmqpipeline)

E

endpoint (zmqpipeline.Collector attribute), [1]
(zmqpipeline.ServiceWorker attribute)
(zmqpipeline.Task attribute)
EndpointAddress (class in zmqpipeline)

G

get_ack_data() (zmqpipeline.Collector method), [1]
get_metadata() (zmqpipeline.MetaDataWorker method)

H

handle() (zmqpipeline.Task method)
handle_collection() (zmqpipeline.Collector method), [1]
handle_execution() (zmqpipeline.MultiThreadedWorker method)
(zmqpipeline.SingleThreadedWorker method)
handle_finished() (zmqpipeline.Collector method), [1]
handle_message() (zmqpipeline.ServiceWorker method)
handle_thread_execution() (zmqpipeline.MultiThreadedWorker method)

I

initialize() (zmqpipeline.Task method)
is_available_for_handling() (zmqpipeline.Task method)

M

MetaDataWorker (class in zmqpipeline)
MultiThreadedWorker (class in zmqpipeline)

N

n_threads (zmqpipeline.MultiThreadedWorker attribute)

R

run() (zmqpipeline.Collector method), [1]
(zmqpipeline.Distributor method)
(zmqpipeline.MetaDataWorker method)
(zmqpipeline.Service method)
(zmqpipeline.ServiceWorker method)

S

Service (class in zmqpipeline)
ServiceClient (class in zmqpipeline)
ServiceWorker (class in zmqpipeline)
shutdown() (zmqpipeline.Distributor method)
(zmqpipeline.Service method)
SingleThreadedWorker (class in zmqpipeline)

T

Task (class in zmqpipeline)
task_type (zmqpipeline.ServiceWorker attribute)
(zmqpipeline.Task attribute)
TaskType (class in zmqpipeline)