Index

_

__getattribute__() (spreadflow_core.scripts.spreadflow_twistd.SpreadFlowServerOptions method) __getnewargs__() (spreadflow_core.dsl.parser.PartitionBounds method) (spreadflow_core.dsl.stream.AddTokenOp method) (spreadflow_core.dsl.stream.RemoveTokenOp method) (spreadflow_core.dsl.stream.SetDefaultTokenOp method) (spreadflow_core.dsl.tokens.AliasToken method) (spreadflow_core.dsl.tokens.ComponentToken method) (spreadflow_core.dsl.tokens.ConnectionToken method) (spreadflow_core.dsl.tokens.DefaultInputToken method) (spreadflow_core.dsl.tokens.DefaultOutputToken method) (spreadflow_core.dsl.tokens.DescriptionToken method) (spreadflow_core.dsl.tokens.EventHandlerToken method) (spreadflow_core.dsl.tokens.LabelToken method) (spreadflow_core.dsl.tokens.ParentElementToken method) (spreadflow_core.dsl.tokens.PartitionBoundsToken method) (spreadflow_core.dsl.tokens.PartitionSelectToken method) (spreadflow_core.dsl.tokens.PartitionToken method) (spreadflow_core.eventdispatcher.Entry method) (spreadflow_core.eventdispatcher.Handler method) (spreadflow_core.eventdispatcher.Key method) (spreadflow_core.jobqueue.Entry method) (spreadflow_core.jobqueue.Job method) (spreadflow_core.scheduler.AttachEvent method) (spreadflow_core.scheduler.DetachEvent method) (spreadflow_core.scheduler.Entry method) (spreadflow_core.scheduler.JobEvent method) __getstate__() (spreadflow_core.dsl.parser.PartitionBounds method) (spreadflow_core.dsl.stream.AddTokenOp method) (spreadflow_core.dsl.stream.RemoveTokenOp method) (spreadflow_core.dsl.stream.SetDefaultTokenOp method) (spreadflow_core.dsl.tokens.AliasToken method) (spreadflow_core.dsl.tokens.ComponentToken method) (spreadflow_core.dsl.tokens.ConnectionToken method) (spreadflow_core.dsl.tokens.DefaultInputToken method) (spreadflow_core.dsl.tokens.DefaultOutputToken method) (spreadflow_core.dsl.tokens.DescriptionToken method) (spreadflow_core.dsl.tokens.EventHandlerToken method) (spreadflow_core.dsl.tokens.LabelToken method) (spreadflow_core.dsl.tokens.ParentElementToken method) (spreadflow_core.dsl.tokens.PartitionBoundsToken method) (spreadflow_core.dsl.tokens.PartitionSelectToken method) (spreadflow_core.dsl.tokens.PartitionToken method) (spreadflow_core.eventdispatcher.Entry method) (spreadflow_core.eventdispatcher.Handler method) (spreadflow_core.eventdispatcher.Key method) (spreadflow_core.jobqueue.Entry method) (spreadflow_core.jobqueue.Job method) (spreadflow_core.scheduler.AttachEvent method) (spreadflow_core.scheduler.DetachEvent method) (spreadflow_core.scheduler.Entry method) (spreadflow_core.scheduler.JobEvent method)

__next__() (spreadflow_core.jobqueue.JobQueue method) __repr__() (spreadflow_core.dsl.parser.PartitionBounds method) (spreadflow_core.dsl.stream.AddTokenOp method) (spreadflow_core.dsl.stream.RemoveTokenOp method) (spreadflow_core.dsl.stream.SetDefaultTokenOp method) (spreadflow_core.dsl.tokens.AliasToken method) (spreadflow_core.dsl.tokens.ComponentToken method) (spreadflow_core.dsl.tokens.ConnectionToken method) (spreadflow_core.dsl.tokens.DefaultInputToken method) (spreadflow_core.dsl.tokens.DefaultOutputToken method) (spreadflow_core.dsl.tokens.DescriptionToken method) (spreadflow_core.dsl.tokens.EventHandlerToken method) (spreadflow_core.dsl.tokens.LabelToken method) (spreadflow_core.dsl.tokens.ParentElementToken method) (spreadflow_core.dsl.tokens.PartitionBoundsToken method) (spreadflow_core.dsl.tokens.PartitionSelectToken method) (spreadflow_core.dsl.tokens.PartitionToken method) (spreadflow_core.eventdispatcher.Entry method) (spreadflow_core.eventdispatcher.Handler method) (spreadflow_core.eventdispatcher.Key method) (spreadflow_core.jobqueue.Entry method) (spreadflow_core.jobqueue.Job method) (spreadflow_core.scheduler.AttachEvent method) (spreadflow_core.scheduler.DetachEvent method) (spreadflow_core.scheduler.Entry method) (spreadflow_core.scheduler.JobEvent method)

A

add_listener() (spreadflow_core.eventdispatcher.EventDispatcher method) AddTokenOp (class in spreadflow_core.dsl.stream) alias (spreadflow_core.dsl.tokens.AliasToken attribute) alias_parser (spreadflow_core.dsl.parser.AliasResolverPass attribute) AliasParser (class in spreadflow_core.dsl.parser) AliasResolverPass (class in spreadflow_core.dsl.parser)

AliasToken (class in spreadflow_core.dsl.tokens) apply() (spreadflow_core.script.ChainTemplate method) (spreadflow_core.script.DuplicatorTemplate method) (spreadflow_core.script.ProcessTemplate method) (spreadflow_delta.proc.LockedProcessTemplate method) (spreadflow_delta.proc.LockingProcessorTemplate method) args (spreadflow_core.eventdispatcher.Handler attribute) (spreadflow_core.jobqueue.Job attribute) attach() (spreadflow_core.proc.Sleep method) (spreadflow_core.proc.SyntheticSource method) (spreadflow_core.proc.Throttle method) (spreadflow_core.remote.ClientEndpointMixin method) (spreadflow_core.remote.ServerEndpointMixin method) (spreadflow_delta.proc.LockingProcessor method) (spreadflow_mongodb.proc.MongoConnection method) AttachEvent (class in spreadflow_core.scheduler)

B

bounds (spreadflow_core.dsl.tokens.PartitionBoundsToken attribute) builder (spreadflow_core.remote.SchedulerProtocol attribute), [1]

buildProtocol() (spreadflow_core.remote.SchedulerClientFactory method) (spreadflow_core.remote.SchedulerServerFactory method) (spreadflow_exiftool.proc.ExiftoolProtocolFactory method)

C

Cachedir (class in spreadflow_delta.proc) callback (spreadflow_core.dsl.tokens.EventHandlerToken attribute) (spreadflow_core.eventdispatcher.Handler attribute) chain (spreadflow_core.script.ChainTemplate attribute) (spreadflow_delta.proc.LockedProcessTemplate attribute) Chain() (in module spreadflow_core.script) ChainTemplate (class in spreadflow_core.script) channel (spreadflow_core.jobqueue.Job attribute) CHUNK_SIZE (spreadflow_observer_fs.protocol.MessageFactory attribute) clear() (spreadflow_core.jobqueue.JobQueue method) ClientEndpointMixin (class in spreadflow_core.remote) cmd() (spreadflow_mongodb.proc.MongoConnection method) completed (spreadflow_core.scheduler.JobEvent attribute) component (spreadflow_core.dsl.tokens.ComponentToken attribute) component_parser (spreadflow_core.script.ChainTemplate attribute) (spreadflow_core.script.DuplicatorTemplate attribute) (spreadflow_core.script.Process attribute) (spreadflow_delta.proc.LockedProcessTemplate attribute) ComponentParser (class in spreadflow_core.dsl.parser)

ComponentsPurgePass (class in spreadflow_core.dsl.parser) ComponentToken (class in spreadflow_core.dsl.tokens) Compound (class in spreadflow_core.component) config_eval() (in module spreadflow_core.config) connection_parser (spreadflow_core.dsl.parser.AliasResolverPass attribute) (spreadflow_core.dsl.parser.ComponentsPurgePass attribute) (spreadflow_core.dsl.parser.EventHandlersPass attribute) (spreadflow_core.dsl.parser.PartitionBoundsPass attribute) (spreadflow_core.dsl.parser.PartitionControllersPass attribute) (spreadflow_core.dsl.parser.PartitionWorkerPass attribute) (spreadflow_core.dsl.parser.PortsValidatorPass attribute) connectionLost() (spreadflow_core.remote.SchedulerProtocol method) ConnectionParser (class in spreadflow_core.dsl.parser) ConnectionToken (class in spreadflow_core.dsl.tokens) consume() (spreadflow_core.dsl.stream.StreamBranch method) ContentHash (class in spreadflow_delta.proc) Context (class in spreadflow_core.script) contract() (in module spreadflow_core.graph) createOrGetApplication() (spreadflow_core.scripts.spreadflow_twistd.SpreadFlowApplicationRunner method)

D

dataReceived() (spreadflow_core.remote.SchedulerProtocol method) DebugLog (class in spreadflow_core.proc) default_ins_parser (spreadflow_core.dsl.parser.AliasResolverPass attribute) default_outs_parser (spreadflow_core.dsl.parser.AliasResolverPass attribute) DefaultInputParser (class in spreadflow_core.dsl.parser) DefaultInputToken (class in spreadflow_core.dsl.tokens) DefaultOutputParser (class in spreadflow_core.dsl.parser) DefaultOutputToken (class in spreadflow_core.dsl.tokens) deferred (spreadflow_core.jobqueue.Entry attribute) (spreadflow_core.scheduler.Entry attribute) delay (spreadflow_delta.proc.LockedProcessTemplate attribute) description (spreadflow_core.dsl.tokens.DescriptionToken attribute) DescriptionParser (class in spreadflow_core.dsl.parser)

DescriptionToken (class in spreadflow_core.dsl.tokens) destination (spreadflow_core.script.DuplicatorTemplate attribute) detach() (spreadflow_core.proc.Sleep method) (spreadflow_core.proc.SyntheticSource method) (spreadflow_core.proc.Throttle method) (spreadflow_core.remote.ClientEndpointMixin method) (spreadflow_core.remote.ServerEndpointMixin method) (spreadflow_delta.proc.Cachedir method) (spreadflow_delta.proc.LockingProcessor method) (spreadflow_mongodb.proc.MongoConnection method) DetachEvent (class in spreadflow_core.scheduler) digraph() (in module spreadflow_core.graph) dispatch() (spreadflow_core.eventdispatcher.EventDispatcher method) (spreadflow_core.remote.MessageHandler method) divert() (spreadflow_core.dsl.stream.StreamBranch method) Duplicate() (in module spreadflow_core.script) DuplicateTokenError Duplicator (class in spreadflow_core.proc) DuplicatorTemplate (class in spreadflow_core.script)

E

element (spreadflow_core.dsl.tokens.AliasToken attribute) (spreadflow_core.dsl.tokens.DefaultInputToken attribute) (spreadflow_core.dsl.tokens.DefaultOutputToken attribute) (spreadflow_core.dsl.tokens.DescriptionToken attribute) (spreadflow_core.dsl.tokens.LabelToken attribute) (spreadflow_core.dsl.tokens.ParentElementToken attribute) (spreadflow_core.dsl.tokens.PartitionToken attribute) EncodedTemporaryFile() (in module spreadflow_delta.util) Entry (class in spreadflow_core.eventdispatcher) (class in spreadflow_core.jobqueue) (class in spreadflow_core.scheduler) event_type (spreadflow_core.dsl.tokens.EventHandlerToken attribute) EventDispatcher (class in spreadflow_core.eventdispatcher) EventHandler (class in spreadflow_observer_fs.script) EventHandlerParser (class in spreadflow_core.dsl.parser)

EventHandlersPass (class in spreadflow_core.dsl.parser) EventHandlerToken (class in spreadflow_core.dsl.tokens) ExiftoolProtocolFactory (class in spreadflow_exiftool.proc) ExitOnFailure (class in spreadflow_core.scripts.spreadflow_twistd) extract() (spreadflow_core.dsl.stream.StreamBranch method) (spreadflow_delta.proc.ContentHash method) (spreadflow_delta.proc.Extractor method) (spreadflow_delta.proc.ExtractorBase method) (spreadflow_delta.proc.Fileurl method) (spreadflow_delta.proc.Loadfile method) (spreadflow_delta.proc.Savefile method) (spreadflow_delta.proc.SetComputedValue method) (spreadflow_delta.proc.Symlink method) (spreadflow_pdf.proc.LoadPdfPages method) (spreadflow_pdf.proc.MergePdfPage method) (spreadflow_pdf.proc.SavePdfPages method) Extractor (class in spreadflow_delta.proc) ExtractorBase (class in spreadflow_delta.proc)

F

FailMode (class in spreadflow_core.eventdispatcher) FilesystemObserverSource (class in spreadflow_observer_fs.source) Fileurl (class in spreadflow_delta.proc) Filter (class in spreadflow_delta.proc)

finalize() (spreadflow_delta.proc.MapReduce method) (spreadflow_delta.proc.MapReduceBase method) flush() (spreadflow_observer_fs.script.EventHandler method) fsencode() (in module spreadflow_observer_fs.compat) func (spreadflow_core.jobqueue.Job attribute)

G

generate_url() (spreadflow_thumbor.proc.ThumborService method) get() (spreadflow_core.jobqueue.JobQueue method) get_aliasmap() (spreadflow_core.dsl.parser.AliasParser method) get_client_protocol_factory() (spreadflow_core.remote.ClientEndpointMixin method) (spreadflow_core.subprocess.SubprocessController method) (spreadflow_exiftool.proc.MetadataExtractor method) (spreadflow_observer_fs.source.FilesystemObserverSource method) get_component() (spreadflow_core.dsl.parser.ComponentParser method) get_descriptionmap() (spreadflow_core.dsl.parser.DescriptionParser method) get_handlers() (spreadflow_core.dsl.parser.EventHandlerParser method) get_labelmap() (spreadflow_core.dsl.parser.LabelParser method) get_links() (spreadflow_core.dsl.parser.ConnectionParser method) get_listeners() (spreadflow_core.eventdispatcher.EventDispatcher method)

get_listeners_grouped() (spreadflow_core.eventdispatcher.EventDispatcher method) get_nodeset() (spreadflow_core.dsl.parser.ParentParser method) get_parentmap() (spreadflow_core.dsl.parser.ParentParser method) get_parentmap_toposort() (spreadflow_core.dsl.parser.ParentParser method) get_partition_bounds() (spreadflow_core.dsl.parser.PartitionBoundsParser method) get_partitionmap() (spreadflow_core.dsl.parser.PartitionParser method) get_portmap() (spreadflow_core.dsl.parser.ConnectionParser method) (spreadflow_core.dsl.parser.DefaultInputParser method) (spreadflow_core.dsl.parser.DefaultOutputParser method) get_portset() (spreadflow_core.dsl.parser.ConnectionParser method) get_selected_partition() (spreadflow_core.dsl.parser.PartitionSelectParser method) get_server_protocol_factory() (spreadflow_core.remote.ServerEndpointMixin method) (spreadflow_core.subprocess.SubprocessWorker method)

H

Handler (class in spreadflow_core.eventdispatcher) handler (spreadflow_core.eventdispatcher.Entry attribute) (spreadflow_core.eventdispatcher.HandlerError attribute) (spreadflow_core.remote.SchedulerProtocol attribute), [1], [2]

HandlerError HEADER_MAX_LEN (spreadflow_core.format.PickleMessageParser attribute)

I

ins (spreadflow_core.dsl.parser.PartitionBounds attribute) (spreadflow_core.subprocess.SubprocessController attribute) (spreadflow_core.subprocess.SubprocessWorker attribute) (spreadflow_delta.proc.LockingProcessor attribute) is_delta() (in module spreadflow_delta.proc)

is_delta_empty() (in module spreadflow_delta.proc)

J

Job (class in spreadflow_core.jobqueue) (class in spreadflow_core.scheduler) job (spreadflow_core.jobqueue.Entry attribute) (spreadflow_core.scheduler.Entry attribute) (spreadflow_core.scheduler.JobEvent attribute) JobEvent (class in spreadflow_core.scheduler) JobQueue (class in spreadflow_core.jobqueue) join() (spreadflow_core.scheduler.Scheduler method)

JsonLdFlatten (class in spreadflow_jsonld.proc) JsonLdUnpack (class in spreadflow_jsonld.proc) JsonLdUnpackBase (class in spreadflow_jsonld.proc) JsonMessageBuilder (class in spreadflow_core.format) JsonMessageParser (class in spreadflow_core.format)

K

Key (class in spreadflow_core.eventdispatcher) key (spreadflow_core.eventdispatcher.Entry attribute) (spreadflow_delta.proc.LockedProcessTemplate attribute) (spreadflow_delta.proc.LockingProcessorTemplate attribute)

keywords() (spreadflow_jsonld.proc.JsonLdUnpack method) (spreadflow_jsonld.proc.JsonLdUnpackBase method) kwds (spreadflow_core.eventdispatcher.Handler attribute) (spreadflow_core.jobqueue.Job attribute)

L

label (spreadflow_core.dsl.tokens.LabelToken attribute) LabelParser (class in spreadflow_core.dsl.parser) LabelToken (class in spreadflow_core.dsl.tokens) last (spreadflow_core.proc.Throttle attribute) Loadfile (class in spreadflow_delta.proc) LoadPdfPages (class in spreadflow_pdf.proc) LockedProcessTemplate (class in spreadflow_delta.proc) LockError

LockingProcessor (class in spreadflow_delta.proc) LockingProcessorTemplate (class in spreadflow_delta.proc) log (spreadflow_core.eventdispatcher.EventDispatcher attribute) (spreadflow_core.proc.DebugLog attribute) (spreadflow_core.scheduler.Scheduler attribute) log_failures() (spreadflow_core.eventdispatcher.EventDispatcher method) logstatus() (spreadflow_core.service.SpreadFlowQueuestatusLogger method) longdesc (spreadflow_core.scripts.spreadflow_twistd.SpreadFlowServerOptions attribute) loseConnection() (spreadflow_core.remote.SchedulerProtocol method)

M

main() (in module spreadflow_core.scripts.spreadflow_twistd) (in module spreadflow_observer_fs.script) makeService() (in module spreadflow_core.service) map() (spreadflow_delta.proc.MapReduce method) (spreadflow_delta.proc.MapReduceBase method) (spreadflow_jsonld.proc.JsonLdFlatten method) MapReduce (class in spreadflow_delta.proc) MapReduceBase (class in spreadflow_delta.proc) MAX_LENGTH (spreadflow_core.format.JsonMessageParser attribute) (spreadflow_core.format.PickleMessageParser attribute) (spreadflow_format_bson.MessageParser attribute) MergePdfPage (class in spreadflow_pdf.proc) message() (spreadflow_core.format.JsonMessageBuilder method) (spreadflow_core.format.PickleMessageBuilder method) (spreadflow_format_bson.MessageBuilder method) MessageBuilder (class in spreadflow_format_bson)

MessageFactory (class in spreadflow_observer_fs.protocol) MessageHandler (class in spreadflow_core.remote) MessageParser (class in spreadflow_format_bson) messages() (spreadflow_core.format.JsonMessageParser method) (spreadflow_core.format.PickleMessageParser method) (spreadflow_format_bson.MessageParser method) MetadataExtractor (class in spreadflow_exiftool.proc) MetadataExtractorError MongoCollectionDeltaSync (class in spreadflow_mongodb.proc) MongoConnection (class in spreadflow_mongodb.proc)

N

next() (spreadflow_core.jobqueue.JobQueue method) NoContextError

NoSuchTokenError now (spreadflow_core.proc.Throttle attribute)

O

on_created() (spreadflow_observer_fs.script.EventHandler method) on_deleted() (spreadflow_observer_fs.script.EventHandler method) on_modified() (spreadflow_observer_fs.script.EventHandler method) on_moved() (spreadflow_observer_fs.script.EventHandler method) open_replace() (in module spreadflow_delta.util)

optFlags (spreadflow_core.service.Options attribute) Options (class in spreadflow_core.service) optParameters (spreadflow_core.service.Options attribute) original (spreadflow_core.dsl.stream.StreamBranch attribute) outs (spreadflow_core.dsl.parser.PartitionBounds attribute) (spreadflow_core.subprocess.SubprocessController attribute) (spreadflow_core.subprocess.SubprocessWorker attribute) (spreadflow_delta.proc.LockingProcessor attribute)

P

pack() (spreadflow_delta.proc.Repack method) (spreadflow_delta.proc.RepackBase method) (spreadflow_delta.proc.RepackSequence method) (spreadflow_delta.proc.RepackValue method) parent (spreadflow_core.dsl.tokens.ParentElementToken attribute) parent_parser (spreadflow_core.dsl.parser.ComponentsPurgePass attribute) (spreadflow_core.dsl.parser.EventHandlersPass attribute) (spreadflow_core.dsl.parser.PartitionExpanderPass attribute) ParentElementToken (class in spreadflow_core.dsl.tokens) ParentParser (class in spreadflow_core.dsl.parser) parseOptions() (spreadflow_core.scripts.spreadflow_twistd.SpreadFlowServerOptions method) parser (spreadflow_core.remote.SchedulerProtocol attribute) ParserError partition (spreadflow_core.dsl.tokens.PartitionBoundsToken attribute) (spreadflow_core.dsl.tokens.PartitionSelectToken attribute) (spreadflow_core.dsl.tokens.PartitionToken attribute) partition_bounds_parser (spreadflow_core.dsl.parser.PartitionControllersPass attribute) (spreadflow_core.dsl.parser.PartitionWorkerPass attribute) partition_parser (spreadflow_core.dsl.parser.PartitionBoundsPass attribute) (spreadflow_core.dsl.parser.PartitionControllersPass attribute) (spreadflow_core.dsl.parser.PartitionExpanderPass attribute) (spreadflow_core.dsl.parser.PartitionWorkerPass attribute) partition_select_parser (spreadflow_core.dsl.parser.PartitionWorkerPass attribute) PartitionBounds (class in spreadflow_core.dsl.parser) PartitionBoundsParser (class in spreadflow_core.dsl.parser) PartitionBoundsPass (class in spreadflow_core.dsl.parser) PartitionBoundsToken (class in spreadflow_core.dsl.tokens) PartitionControllersPass (class in spreadflow_core.dsl.parser) PartitionExpanderPass (class in spreadflow_core.dsl.parser) PartitionParser (class in spreadflow_core.dsl.parser) PartitionSelectParser (class in spreadflow_core.dsl.parser)

PartitionSelectToken (class in spreadflow_core.dsl.tokens) PartitionToken (class in spreadflow_core.dsl.tokens) PartitionWorkerPass (class in spreadflow_core.dsl.parser) peer (spreadflow_core.remote.ClientEndpointMixin attribute), [1] (spreadflow_core.remote.ServerEndpointMixin attribute), [1] pending (spreadflow_core.scheduler.Scheduler attribute) PickleMessageBuilder (class in spreadflow_core.format) PickleMessageParser (class in spreadflow_core.format) pop() (spreadflow_core.script.Context class method) port (spreadflow_core.dsl.tokens.DefaultInputToken attribute) (spreadflow_core.dsl.tokens.DefaultOutputToken attribute) port_in (spreadflow_core.dsl.tokens.ConnectionToken attribute) port_out (spreadflow_core.dsl.tokens.ConnectionToken attribute) PortsValidatorPass (class in spreadflow_core.dsl.parser) postOptions() (spreadflow_core.scripts.spreadflow_twistd.SpreadFlowServerOptions method) predicate() (spreadflow_core.dsl.parser.AliasParser method) (spreadflow_core.dsl.parser.ComponentParser method) (spreadflow_core.dsl.parser.ConnectionParser method) (spreadflow_core.dsl.parser.DefaultInputParser method) (spreadflow_core.dsl.parser.DefaultOutputParser method) (spreadflow_core.dsl.parser.DescriptionParser method) (spreadflow_core.dsl.parser.EventHandlerParser method) (spreadflow_core.dsl.parser.LabelParser method) (spreadflow_core.dsl.parser.ParentParser method) (spreadflow_core.dsl.parser.PartitionBoundsParser method) (spreadflow_core.dsl.parser.PartitionParser method) (spreadflow_core.dsl.parser.PartitionSelectParser method) (spreadflow_core.dsl.stream.StreamBranch method) priority (spreadflow_core.dsl.tokens.EventHandlerToken attribute) (spreadflow_core.eventdispatcher.Key attribute) Process (class in spreadflow_core.script) ProcessDecoratorError ProcessTemplate (class in spreadflow_core.script) push() (spreadflow_core.format.JsonMessageParser method) (spreadflow_core.format.PickleMessageParser method) (spreadflow_core.script.Context class method) (spreadflow_format_bson.MessageParser method) put() (spreadflow_core.jobqueue.JobQueue method)

Q

QueueNoneReady

R

RAISE (spreadflow_core.eventdispatcher.FailMode attribute), [1] reactor (spreadflow_core.scheduler.AttachEvent attribute) (spreadflow_mongodb.proc.MongoConnection attribute) readConnectionLost() (spreadflow_core.remote.SchedulerServerProtocol method) reduce() (spreadflow_delta.proc.MapReduce method) (spreadflow_delta.proc.MapReduceBase method) (spreadflow_jsonld.proc.JsonLdFlatten method) rejected (spreadflow_core.dsl.stream.StreamBranch attribute) release() (spreadflow_delta.proc.LockingProcessor method) remove_listener() (spreadflow_core.eventdispatcher.EventDispatcher method) RemoveTokenOp (class in spreadflow_core.dsl.stream) Repack (class in spreadflow_delta.proc)

RepackBase (class in spreadflow_delta.proc) RepackSequence (class in spreadflow_delta.proc) RepackValue (class in spreadflow_delta.proc) replace() (spreadflow_observer_fs.protocol.MessageFactory method) (spreadflow_observer_fs.protocol.Repository method) Repository (class in spreadflow_observer_fs.protocol) RETURN (spreadflow_core.eventdispatcher.FailMode attribute), [1] reverse() (in module spreadflow_core.graph) run() (spreadflow_core.scheduler.Scheduler method) (spreadflow_mongodb.proc.WorkerJob method) (spreadflow_mongodb.proc.WorkerStop method) (spreadflow_observer_fs.script.WatchdogObserverCommand method)

S

Savefile (class in spreadflow_delta.proc) SavePdfPages (class in spreadflow_pdf.proc) Scheduler (class in spreadflow_core.scheduler) scheduler (spreadflow_core.remote.SchedulerServerProtocol attribute) (spreadflow_core.scheduler.AttachEvent attribute) (spreadflow_core.scheduler.DetachEvent attribute) (spreadflow_core.scheduler.JobEvent attribute) SchedulerClientFactory (class in spreadflow_core.remote) SchedulerProtocol (class in spreadflow_core.remote) SchedulerServerFactory (class in spreadflow_core.remote) SchedulerServerProtocol (class in spreadflow_core.remote) selected (spreadflow_core.dsl.stream.StreamBranch attribute) send() (spreadflow_core.scheduler.Scheduler method) sendMessage() (spreadflow_core.remote.SchedulerProtocol method) serial (spreadflow_core.eventdispatcher.Key attribute) ServerEndpointMixin (class in spreadflow_core.remote) SetComputedValue (class in spreadflow_delta.proc) SetDefaultTokenOp (class in spreadflow_core.dsl.stream) Sleep (class in spreadflow_core.proc) sleep (spreadflow_core.proc.Sleep attribute) sort_key() (spreadflow_delta.proc.MapReduce method) (spreadflow_delta.proc.MapReduceBase method) sort_reverse (spreadflow_delta.proc.MapReduceBase attribute) spreadflow_core (module) spreadflow_core.component (module) spreadflow_core.config (module) spreadflow_core.dsl (module) spreadflow_core.dsl.parser (module) spreadflow_core.dsl.stream (module) spreadflow_core.dsl.tokens (module) spreadflow_core.eventdispatcher (module) spreadflow_core.format (module) spreadflow_core.graph (module) spreadflow_core.jobqueue (module) spreadflow_core.proc (module) spreadflow_core.remote (module) spreadflow_core.scheduler (module) spreadflow_core.script (module) spreadflow_core.scripts (module) spreadflow_core.scripts.spreadflow_twistd (module) spreadflow_core.service (module) spreadflow_core.subprocess (module)

spreadflow_delta (module) spreadflow_delta.proc (module) spreadflow_delta.util (module) spreadflow_exiftool (module) spreadflow_exiftool.proc (module) spreadflow_format_bson (module) spreadflow_jsonld (module) spreadflow_jsonld.proc (module) spreadflow_mongodb (module) spreadflow_mongodb.proc (module) spreadflow_observer_fs (module) spreadflow_observer_fs.compat (module) spreadflow_observer_fs.protocol (module) spreadflow_observer_fs.script (module) spreadflow_observer_fs.source (module) spreadflow_pdf (module) spreadflow_pdf.proc (module) spreadflow_thumbor (module) spreadflow_thumbor.proc (module) spreadflow_xslt (module) spreadflow_xslt.proc (module) SpreadFlowApplicationRunner (class in spreadflow_core.scripts.spreadflow_twistd) SpreadFlowQueuestatusLogger (class in spreadflow_core.service) SpreadFlowServerOptions (class in spreadflow_core.scripts.spreadflow_twistd) SpreadFlowService (class in spreadflow_core.service) startService() (spreadflow_core.service.SpreadFlowService method) StderrLogger() (in module spreadflow_core.scripts.spreadflow_twistd) stop() (spreadflow_core.scheduler.Scheduler method) stopempty (spreadflow_core.jobqueue.JobQueue attribute) stopService() (spreadflow_core.service.SpreadFlowService method) StreamBranch (class in spreadflow_core.dsl.stream) StreamError strport (spreadflow_core.remote.ClientEndpointMixin attribute), [1] (spreadflow_core.remote.ServerEndpointMixin attribute), [1] SubprocessController (class in spreadflow_core.subprocess) SubprocessWorker (class in spreadflow_core.subprocess) Symlink (class in spreadflow_delta.proc) symlink_replace() (in module spreadflow_delta.util) SyntheticSource (class in spreadflow_core.proc)

T

Throttle (class in spreadflow_core.proc) ThumborService (class in spreadflow_thumbor.proc) ThumborUrlGenerator (class in spreadflow_thumbor.proc) token (spreadflow_core.dsl.stream.AddTokenOp attribute) (spreadflow_core.dsl.stream.RemoveTokenOp attribute) (spreadflow_core.dsl.stream.SetDefaultTokenOp attribute)

token_attr_map() (in module spreadflow_core.dsl.stream) token_map() (in module spreadflow_core.dsl.stream) top() (spreadflow_core.script.Context class method)

U

Unpack (class in spreadflow_delta.proc) unpack() (spreadflow_delta.proc.Unpack method) (spreadflow_delta.proc.UnpackBase method) (spreadflow_delta.proc.UnpackSequence method) (spreadflow_delta.proc.UnpackValue method) (spreadflow_jsonld.proc.JsonLdUnpackBase method) UnpackBase (class in spreadflow_delta.proc)

UnpackSequence (class in spreadflow_delta.proc) UnpackValue (class in spreadflow_delta.proc) update() (spreadflow_observer_fs.protocol.MessageFactory method) (spreadflow_observer_fs.protocol.Repository method)

V

vertices() (in module spreadflow_core.graph)

W

watch() (spreadflow_core.service.SpreadFlowQueuestatusLogger method) WatchdogObserverCommand (class in spreadflow_observer_fs.script) WorkerJob (class in spreadflow_mongodb.proc)

WorkerStop (class in spreadflow_mongodb.proc) wrapped_failure (spreadflow_core.eventdispatcher.HandlerError attribute) writeConnectionLost() (spreadflow_core.remote.SchedulerServerProtocol method)

X

XSLT (class in spreadflow_xslt.proc)