Index

Symbols

-c <configfile>, --conf <configfile> piped command line option -D piped command line option -d <dirname>, --rundir <dirname> piped command line option -l <logfile>, --logfile <logfile> piped command line option

-n, --nodaemon piped command line option -O <path:value>, --override <path:value> piped command line option -p <pidfile>, --pidfile <pidfile> piped command line option

A

add_consumer() (piped.resource.IResourceProvider method) add_dependency() (piped.dependencies.DependencyManager method) (piped.dependencies.DependencyMap method) AMQPConnection (class in piped_amqp.providers) AMQPConnectionProvider (class in piped_amqp.providers) AMQPConsumer (class in piped_amqp.providers)

AMQPConsumerProvider (class in piped_amqp.providers) AMQProtocol (class in piped_amqp.providers) as_dependency() (piped.dependencies.DependencyManager method) AttributeDict (class in piped.util)

B

baton BatonCleaner (class in piped.processors.util_processors)

BatonCollector (class in piped.processors.util_processors) BatonJSONEncoder (class in piped.util)

C

CallbackDeferred (class in piped.processors.util_processors) CallRemote (class in piped.processors.spread_processors) chunked() (in module piped.util) ClientGetPage (class in piped.processors.web_processors) ConfigurationManager (class in piped.conf) configure() (IDependency method) (piped.conf.ConfigurationManager method) (piped.dependencies.DependencyManager method) (piped.processing.IProcessor method) (piped.processors.base.Processor method) (piped.resource.IResourceProvider method) consumers (piped.processing.IProcessor attribute) context_factory (piped_zmq.providers.ZMQSocketProvider attribute) ContextFetcher (class in piped.processors.context_processors)

ContextProvider (class in piped.providers.context_provider) CoroutineWrapper (class in piped.processors.util_processors) CounterIncrementer (class in piped.processors.util_processors) create_deferred_state_watcher() (in module piped.util) create_dependency_map() (piped.dependencies.DependencyManager method) CreateEmailMessage (class in piped.processors.smtp_processors) CreateZooKeeperNode (class in piped_zookeeper.processors) CycloneProvider (class in piped_cyclone.providers)

D

DateFormatter (class in piped.processors.datetime_processors) DateTimeParser (class in piped.processors.datetime_processors) DebuggableHandler (class in piped_cyclone.handlers) Dependency (class in piped.dependencies) DependencyCaller (class in piped.processors.util_processors) DependencyDiagrammer (class in piped.processors.pipeline_processors) DependencyManager (class in piped.dependencies) DependencyMap (class in piped.dependencies) depends_on (piped.processing.IProcessor attribute) (piped.processors.base.Processor attribute)

DiagramTrace (class in piped.processors.trace_processors) dict_get_path() (in module piped.util) dict_iterate_paths() (in module piped.util) dict_remove_path() (in module piped.util) dict_set_path() (in module piped.util) dict_setdefault_path() (in module piped.util) DictGrouper (class in piped.processors.util_processors) DictResourceDependencyAdapter (class in piped.dependencies)

E

ensure_date() (in module piped.util) error_consumers (piped.processing.IProcessor attribute) evaluator (piped.processing.IProcessor attribute) Event (class in piped.event)

ExecProcessor (class in piped.processors.util_processors) expand_filepath() (in module piped.util) ExtractRequestArguments (class in piped.processors.web_processors)

F

fail_after_delay() (in module piped.util) FileAppender (class in piped.processors.file_processors) flatten() (in module piped.util)

FlattenDictionaryList (class in piped.processors.util_processors) ForEach (class in piped.processors.pipeline_processors) FormEncodeValidator (class in piped_validation.processors)

G

get() (piped.conf.ConfigurationManager method) get_consumers() (piped.processing.IProcessor method) (piped.processors.base.Processor method) get_debug() (piped_cyclone.handlers.DebuggableHandler method) get_dot() (piped.dependencies.DependencyManager method) get_error_consumers() (piped.processing.IProcessor method) (piped.processors.base.Processor method) get_input() (piped.processors.base.MappingProcessor method) (piped.processors.base.Processor method) get_named_channel() (piped_amqp.providers.AMQProtocol method)

get_namespace() (piped_status_testing.processors.StatusTestProcessor method) get_resource() (IDependency method) (piped.dependencies.InstanceDependency method) (piped.dependencies.ResourceDependency method) get_resulting_baton() (piped.processors.base.Processor method) get_suites() (piped_status_testing.processors.StatusTestProcessor method) get_testcases() (piped_status_testing.processors.StatusTestProcessor method) GetZooKeeperChildren (class in piped_zookeeper.processors) GetZooKeeperData (class in piped_zookeeper.processors)

H

has_all_dependencies_provided() (piped.dependencies.DependencyManager method)

has_resolved() (piped.dependencies.DependencyManager method)

I

id (piped.processing.IProcessor attribute) IDependency (interface in piped.dependencies) in_unittest() (in module piped.util) InputOutputProcessor (class in piped.processors.base) instance_depends_on (piped.processing.IProcessor attribute) (piped.processors.base.InputOutputProcessor attribute) (piped.processors.base.MappingProcessor attribute) instance_provides (piped.processing.IProcessor attribute) (piped.processors.base.InputOutputProcessor attribute) (piped.processors.base.MappingProcessor attribute) InstanceDependency (class in piped.dependencies)

interleaved() (in module piped.util) IOStatParser (class in piped.processors.process_processors) IPDeterminer (class in piped.processors.web_processors) IProcessor (interface in piped.processing) IResourceProvider (interface in piped.resource) is_available() (piped.dependencies.DependencyMap method) items() (piped.dependencies.DependencyMap method)

J

JsonDecoder (class in piped.processors.json_processors)

JsonEncoder (class in piped.processors.json_processors)

K

key_path

keys() (piped.dependencies.DependencyMap method)

L

LambdaConditional (class in piped.processors.util_processors) LambdaProcessor (class in piped.processors.util_processors) load_from_file() (piped.conf.ConfigurationManager method)

LogAppender (class in piped.processors.file_processors) Logger (class in piped.processors.util_processors)

M

manager (IDependency attribute) ManholeProvider (class in piped_manhole.providers) MappingProcessor (class in piped.processors.base) MappingSetter (class in piped.processors.util_processors) MarkupRemover (class in piped.processors.xml_processors)

merge_dicts() (in module piped.util) MergeWithDictProcessor (class in piped.processors.util_processors) MessageSender (class in piped_zmq.processors) MongrelReplySender (class in piped_zmq.mongrel2_processors) MongrelRequestToBatonParser (class in piped_zmq.mongrel2_processors)

N

name (piped.processing.IProcessor attribute) (piped.processors.base.Processor attribute) NestedListFlattener (class in piped.processors.util_processors)

NonCleaningFailure (class in piped.util) NthPrinter (class in piped.processors.util_processors)

O

on_dependency_lost (IDependency attribute) on_dependency_ready (IDependency attribute) on_lost (IDependency attribute)

on_ready (IDependency attribute) on_resource_lost() (piped.dependencies.ResourceDependency method) on_resource_ready() (piped.dependencies.ResourceDependency method)

P

Passthrough (class in piped.processors.util_processors) PBClientProvider (class in piped.providers.spread_provider) PBServerProvider (class in piped.providers.spread_provider) PersistedContextFetcher (class in piped.processors.context_processors) PersistedContextProvider (class in piped.providers.context_provider) piped command line option -D -O <path:value>, --override <path:value> -c <configfile>, --conf <configfile> -d <dirname>, --rundir <dirname> -l <logfile>, --logfile <logfile> -n, --nodaemon -p <pidfile>, --pidfile <pidfile> piped.conf (module) piped.dependencies (module) piped.event (module) piped.processing (module) piped.processors (module) piped.processors.base (module) piped.processors.spread_processors (module) piped.processors.tick_processors (module) piped.processors.trace_processors (module) piped.providers.context_provider (module) piped.providers.pipeline_provider (module) piped.providers.smtp_provider (module) piped.providers.spread_provider (module) piped.providers.system_events_provider (module) piped.providers.tick_provider (module) piped.providers.web_provider (module) piped.resource (module) piped.util (module) piped_cyclone.handlers (module)

piped_cyclone.providers (module) piped_database.providers (module) piped_manhole.providers (module) piped_zmq.providers (module) piped_zookeeper.providers (module) PipedRequestHandlerProxy (class in piped_cyclone.handlers) pipeline PipelineDiagrammer (class in piped.processors.pipeline_processors) PipelineProvider (class in piped.providers.pipeline_provider) PipelineRequestHandler (class in piped_cyclone.handlers) PipelineRunner (class in piped.processors.pipeline_processors) plugin_manager (piped.resource.IResourceProvider attribute) post_debug() (piped_cyclone.handlers.DebuggableHandler method) prepare() (piped_cyclone.handlers.DebuggableHandler method) PrettyPrint (class in piped.processors.util_processors) PrintTraceback (class in piped.processors.util_processors) process() (piped.processing.IProcessor method) (piped.processors.base.MappingProcessor method) (piped.processors.base.Processor method) process_input() (piped.processors.base.InputOutputProcessor method) process_mapping() (piped.processors.base.MappingProcessor method) processor Processor (class in piped.processors.base) processor graph processor_configuration (piped.processing.IProcessor attribute) provider provides (piped.processing.IProcessor attribute) (piped.processors.base.Processor attribute)

R

RaiseException (class in piped.processors.util_processors) register() (piped.resource.ResourceManager method) RemapProcessor (class in piped.processors.util_processors) remove_dependency() (piped.dependencies.DependencyManager method) (piped.dependencies.DependencyMap method) RenderDot (class in piped.processors.process_processors) RenderTrace (class in piped.processors.trace_processors) ReporterCreator (class in piped_status_testing.processors) resolve() (piped.resource.ResourceManager method)

resolve_initial_state() (IDependency method) (piped.dependencies.Dependency method) (piped.dependencies.ResourceDependency method) resolve_initial_states() (piped.dependencies.DependencyManager method) ResourceDependency (class in piped.dependencies) ResourceManager (class in piped.resource) ResponseWriter (class in piped.processors.web_processors) RPCClientBase (class in piped_amqp.rpc) RPCClientProvider (class in piped_amqp.rpc) RuntimeEnvironment (class in piped.processing)

S

safe_deepcopy() (in module piped.util) ScatterGatherer (class in piped.processors.pipeline_processors) SendEmail (class in piped.processors.smtp_processors) set() (piped.conf.ConfigurationManager method) set_output() (piped.processors.base.MappingProcessor method) setdefault() (piped.conf.ConfigurationManager method) SetExpireHeader (class in piped.processors.web_processors) SetHttpHeaders (class in piped.processors.web_processors) SetMessageHeaders (class in piped.processors.smtp_processors) SetZooKeeperData (class in piped_zookeeper.processors) SMTPProvider (class in piped.providers.smtp_provider)

StartInterval (class in piped.processors.tick_processors) state (piped.processing.IProcessor attribute) StatusTestProcessor (class in piped_status_testing.processors) StopInterval (class in piped.processors.tick_processors) Stopper (class in piped.processors.util_processors) StringDecoder (class in piped.processors.util_processors) StringEncoder (class in piped.processors.util_processors) StringFormatter (class in piped.processors.util_processors) StringPrefixer (class in piped.processors.util_processors) SystemEventsProvider (class in piped.providers.system_events_provider)

T

TickProvider (class in piped.providers.tick_provider)

TrapFailure (class in piped.processors.util_processors)

V

validate_additional_kwargs() (piped.processors.base.MappingProcessor method)

ValueSetter (class in piped.processors.util_processors)

W

wait_for_first() (in module piped.util) wait_for_resource() (piped.dependencies.DependencyMap method) (piped.dependencies.InstanceDependency method) (piped.dependencies.ResourceDependency method) wait_until_fired() (piped.event.Event method) Waiter (class in piped.processors.util_processors)

WaitForReporterProcessing (class in piped_status_testing.processors) WebResource (class in piped.providers.web_provider) WebResourceProvider (class in piped.providers.web_provider) WebSite (class in piped.providers.web_provider)

Z

ZMQProcessorFeederProvider (class in piped_zmq.providers) ZMQSocketProvider (class in piped_zmq.providers)

ZookeeperClientProvider (class in piped_zookeeper.providers) ZooKeeperNodeExists (class in piped_zookeeper.processors)