Index

_

__call__() (sarracenia.config.Config.addBinding method) __connect() (sarracenia.moth.amqp.AMQP method) __deepcopy__() (sarracenia.config.Config method) __init__() (sarracenia.config.Config method) (sarracenia.diskqueue.DiskQueue method) (sarracenia.filemetadata.FileMetadata method) (sarracenia.flow.Flow method) (sarracenia.flow.poll.Poll method) (sarracenia.flow.post.Post method) (sarracenia.flow.report.Report method) (sarracenia.flow.sarra.Sarra method) (sarracenia.flow.sender.Sender method) (sarracenia.flow.shovel.Shovel method) (sarracenia.flow.subscribe.Subscribe method) (sarracenia.flow.watch.Watch method) (sarracenia.flow.winnow.Winnow method) (sarracenia.flowcb.accept.delete.Delete method) (sarracenia.flowcb.accept.downloadbaseurl.DownloadBaseUrl method) (sarracenia.flowcb.accept.hourtree.HourTree method) (sarracenia.flowcb.accept.httptohttps.HttpToHttps method) (sarracenia.flowcb.accept.longflow.LongFlow method) (sarracenia.flowcb.accept.posthourtree.Posthourtree method) (sarracenia.flowcb.accept.postoverride.PostOverride method) (sarracenia.flowcb.accept.printlag.PrintLag method) (sarracenia.flowcb.accept.rename4jicc.Rename4Jicc method) (sarracenia.flowcb.accept.renamedmf.RenameDMF method) (sarracenia.flowcb.accept.renamewhatfn.RenameWhatFn method) (sarracenia.flowcb.accept.save.Save method) (sarracenia.flowcb.accept.speedo.Speedo method) (sarracenia.flowcb.accept.sundewpxroute.SundewPxRoute method) (sarracenia.flowcb.accept.testretry.TestRetry method) (sarracenia.flowcb.accept.toclusters.ToClusters method) (sarracenia.flowcb.accept.tolocalfile.ToLocalFile method) (sarracenia.flowcb.accept.wmotypesuffix.WmoTypeSuffix method) (sarracenia.flowcb.clamav.Clamav method) (sarracenia.flowcb.filter.fdelay.Fdelay method) (sarracenia.flowcb.filter.wmo2msc.Wmo2msc method) (sarracenia.flowcb.FlowCB method) (sarracenia.flowcb.gather.file.File method) (sarracenia.flowcb.gather.file.SimpleEventHandler method) (sarracenia.flowcb.gather.message.Message method) (sarracenia.flowcb.housekeeping.resources.Resources method) (sarracenia.flowcb.log.Log method) (sarracenia.flowcb.mdelaylatest.MDelayLatest method) (sarracenia.flowcb.pclean.PClean method) (sarracenia.flowcb.poll.mail.Mail method) (sarracenia.flowcb.poll.noaa_hydrometric.Noaa_hydrometric method) (sarracenia.flowcb.poll.Poll method) (sarracenia.flowcb.post.message.Message method) (sarracenia.flowcb.retry.Retry method) (sarracenia.flowcb.sample.Sample method) (sarracenia.flowcb.scheduled.Scheduled method) (sarracenia.flowcb.send.email.Email method) (sarracenia.flowcb.shiftdir2baseurl.ShiftDir2baseUrl method) (sarracenia.flowcb.v2wrapper.V2Wrapper method) (sarracenia.flowcb.work.rxpipe.Rxpipe method) (sarracenia.identity.arbitrary.Arbitrary method) (sarracenia.instance.instance method) (sarracenia.Message method) (sarracenia.moth.amq1.AMQ1 method) (sarracenia.moth.amqp.AMQP method) (sarracenia.moth.Moth method) (sarracenia.moth.pika.PIKA method) (sarracenia.transfer.file.File method) (sarracenia.transfer.ftp.Ftp method) (sarracenia.transfer.ftp.IMPLICIT_FTP_TLS method) (sarracenia.transfer.https.Https method) (sarracenia.transfer.sftp.Sftp method) (sarracenia.transfer.Transfer method)

__len__() (sarracenia.diskqueue.DiskQueue method) __new__() (sarracenia.config.octal_number static method) __open__() (sarracenia.transfer.https.Https method) __repr__() (sarracenia.config.octal_number method) __str__() (sarracenia.config.octal_number method) __url_redir_str() (sarracenia.transfer.https.Https method) __weakref__ (sarracenia.config.Config attribute) (sarracenia.diskqueue.DiskQueue attribute) (sarracenia.filemetadata.FileMetadata attribute) (sarracenia.flow.Flow attribute) (sarracenia.flowcb.FlowCB attribute) (sarracenia.identity.Identity attribute) (sarracenia.instance.instance attribute) (sarracenia.Message attribute) (sarracenia.moth.Moth attribute) (sarracenia.Sarracenia attribute) (sarracenia.TimeConversions attribute) (sarracenia.transfer.TimeoutException attribute) (sarracenia.transfer.Transfer attribute) _build_mask() (sarracenia.config.Config method) _count_msgs() (sarracenia.diskqueue.DiskQueue method) _parse_binding() (sarracenia.config.Config method) _parse_set_string() (sarracenia.config.Config method) _parse_setting() (sarracenia.config.Config method) _parse_v2plugin() (sarracenia.config.Config method) _resolve_exchange() (sarracenia.config.Config method) _runCallbackMetrics() (sarracenia.flow.Flow method) _runHousekeeping() (sarracenia.flow.Flow method) _sundew_basename_parts() (sarracenia.config.Config method) _varsub() (sarracenia.config.Config method)

A

ack() (sarracenia.moth.amqp.AMQP method) (sarracenia.moth.Moth method) add_option() (sarracenia.config.Config method) add_user() (in module sarracenia.rabbitmq_admin) after_accept() (sarracenia.flowcb.retry.Retry method) after_post() (sarracenia.flowcb.retry.Retry method) after_work() (sarracenia.flowcb.retry.Retry method)

Age (class in sarracenia.flowcb.work.age) Airnow (class in sarracenia.flowcb.poll.airnow) alarm_set() (in module sarracenia.transfer) AMQ1 (class in sarracenia.moth.amq1) AMQP (class in sarracenia.moth.amqp) applyComponentDefaults() (sarracenia.config.Config method) Arbitrary (class in sarracenia.identity.arbitrary)

B

broker_get_exchanges() (in module sarracenia.rabbitmq_admin)

build_path_dict() (sarracenia.flowcb.pclean.PClean method)

C

cd() (sarracenia.transfer.file.File method) cd_forced() (sarracenia.transfer.sftp.Sftp method) Clamav (class in sarracenia.flowcb.clamav) cleanup() (sarracenia.diskqueue.DiskQueue method) (sarracenia.moth.Moth method)

close() (sarracenia.diskqueue.DiskQueue method) computeIdentity() (sarracenia.Message method) Config (class in sarracenia.config) Config.addBinding (class in sarracenia.config) config_path() (in module sarracenia.config) copyDict() (sarracenia.Message method)

D

Data (class in sarracenia.flowcb.nodupe.data) default_options (sarracenia.moth.Moth property) del_user() (in module sarracenia.rabbitmq_admin) Delete (class in sarracenia.flowcb.accept.delete) DeleteFlowFiles (class in sarracenia.flowcb.filter.deleteflowfiles) deriveSource() (sarracenia.Message method) deriveTopics() (sarracenia.Message method) dictify() (sarracenia.config.Config method) DiskQueue (class in sarracenia.diskqueue)

do_download() (sarracenia.flow.Flow method) do_send() (sarracenia.flow.Flow method) doRollover() (sarracenia.instance.RedirectedTimedRotatingFileHandler method) doSpecificProcessing() (sarracenia.flowcb.filter.wmo2msc.Wmo2msc method) download() (sarracenia.flow.Flow method) DownloadBaseUrl (class in sarracenia.flowcb.accept.downloadbaseurl) dump() (sarracenia.config.Config method) dumps() (sarracenia.Message method) durationToSeconds() (in module sarracenia) durationToString() (in module sarracenia)

E

Email (class in sarracenia.flowcb.send.email)

exec_rabbitmqadmin() (in module sarracenia.rabbitmq_admin)

F

Fdelay (class in sarracenia.flowcb.filter.fdelay) File (class in sarracenia.flowcb.gather.file) (class in sarracenia.transfer.file) file_should_be_downloaded() (sarracenia.flow.Flow method) FileMetadata (class in sarracenia.filemetadata) finalize() (sarracenia.config.Config method)

findAllSubclasses() (sarracenia.moth.Moth static method) Flow (class in sarracenia.flow) FlowCB (class in sarracenia.flowcb) fromFileData() (sarracenia.Message static method) fromFileInfo() (sarracenia.Message static method) fromStream() (sarracenia.Message static method) Ftp (class in sarracenia.transfer.ftp)

G

gather() (sarracenia.flowcb.gather.file.File method) (sarracenia.flowcb.gather.message.Message method) (sarracenia.flowcb.retry.Retry method) get() (sarracenia.diskqueue.DiskQueue method) (sarracenia.filemetadata.FileMetadata method) get_exchanges() (in module sarracenia.rabbitmq_admin) get_extension() (sarracenia.flowcb.pclean.PClean method) get_log_filename() (in module sarracenia.config) get_metrics_filename() (in module sarracenia.config)

get_pid_filename() (in module sarracenia.config) get_queues() (in module sarracenia.rabbitmq_admin) get_user_cache_dir() (in module sarracenia.config) get_users() (in module sarracenia.rabbitmq_admin) getContent() (sarracenia.Message method) getIDStr() (sarracenia.Message method) getNewMessage() (sarracenia.moth.amqp.AMQP method) (sarracenia.moth.Moth method) getSetup() (sarracenia.moth.amqp.AMQP method)

H

handle_data() (sarracenia.flowcb.poll.nasa_mls_nrt.Nasa_mls_nrt method) (sarracenia.flowcb.poll.Poll method) has_vip() (sarracenia.flow.Flow method) hohoo_validate_urlstr() (sarracenia.config.Config method)

HourTree (class in sarracenia.flowcb.accept.hourtree) HTTPRedirectHandlerSameMethod (class in sarracenia.transfer.https) Https (class in sarracenia.transfer.https) HttpToHttps (class in sarracenia.flowcb.accept.httptohttps)

I

Identity (class in sarracenia.identity) IMPLICIT_FTP_TLS (class in sarracenia.transfer.ftp)

in_cache() (sarracenia.diskqueue.DiskQueue method) instance (class in sarracenia.instance) is_expired() (sarracenia.diskqueue.DiskQueue method)

L

link1file() (sarracenia.flow.Flow method) list() (sarracenia.filemetadata.FileMetadata method) load_library() (in module sarracenia.flowcb) Log (class in sarracenia.flowcb.log)

logger (in module sarracenia.config) (in module sarracenia.flowcb.gather) (in module sarracenia.moth.amqp) logProgress() (sarracenia.transfer.Transfer method) LongFlow (class in sarracenia.flowcb.accept.longflow)

M

Mail (class in sarracenia.flowcb.poll.mail) mask_ppstr() (sarracenia.config.Config method) Md5 (class in sarracenia.identity.md5) MDelayLatest (class in sarracenia.flowcb.mdelaylatest) merge() (sarracenia.config.Config method) Message (class in sarracenia) (class in sarracenia.flowcb.gather.message) (class in sarracenia.flowcb.post.message) metricsDisconnect() (sarracenia.moth.Moth method) metricsReport() (sarracenia.flowcb.retry.Retry method) mkdir() (sarracenia.flow.Flow method) module sarracenia sarracenia.config sarracenia.diskqueue sarracenia.filemetadata sarracenia.flow sarracenia.flow.poll sarracenia.flow.post sarracenia.flow.report sarracenia.flow.sarra sarracenia.flow.sender sarracenia.flow.shovel sarracenia.flow.subscribe sarracenia.flow.watch sarracenia.flow.winnow sarracenia.flowcb sarracenia.flowcb.accept sarracenia.flowcb.accept.delete sarracenia.flowcb.accept.downloadbaseurl sarracenia.flowcb.accept.hourtree sarracenia.flowcb.accept.httptohttps sarracenia.flowcb.accept.longflow sarracenia.flowcb.accept.posthourtree sarracenia.flowcb.accept.postoverride sarracenia.flowcb.accept.printlag sarracenia.flowcb.accept.rename4jicc sarracenia.flowcb.accept.renamedmf sarracenia.flowcb.accept.renamewhatfn sarracenia.flowcb.accept.save sarracenia.flowcb.accept.speedo sarracenia.flowcb.accept.sundewpxroute sarracenia.flowcb.accept.testretry sarracenia.flowcb.accept.toclusters sarracenia.flowcb.accept.tolocalfile sarracenia.flowcb.accept.wmotypesuffix sarracenia.flowcb.clamav sarracenia.flowcb.destfn.sample sarracenia.flowcb.download sarracenia.flowcb.filter sarracenia.flowcb.filter.deleteflowfiles sarracenia.flowcb.filter.fdelay sarracenia.flowcb.filter.pclean_f90 sarracenia.flowcb.filter.pclean_f92 sarracenia.flowcb.filter.wmo2msc sarracenia.flowcb.gather sarracenia.flowcb.gather.file sarracenia.flowcb.gather.message sarracenia.flowcb.housekeeping sarracenia.flowcb.housekeeping.resources sarracenia.flowcb.log sarracenia.flowcb.mdelaylatest sarracenia.flowcb.nodupe sarracenia.flowcb.nodupe.data sarracenia.flowcb.nodupe.name sarracenia.flowcb.pclean sarracenia.flowcb.poll sarracenia.flowcb.poll.airnow sarracenia.flowcb.poll.mail sarracenia.flowcb.poll.nasa_mls_nrt sarracenia.flowcb.poll.noaa_hydrometric sarracenia.flowcb.post sarracenia.flowcb.post.message sarracenia.flowcb.retry sarracenia.flowcb.sample sarracenia.flowcb.scheduled sarracenia.flowcb.send sarracenia.flowcb.send.email sarracenia.flowcb.shiftdir2baseurl sarracenia.flowcb.v2wrapper sarracenia.flowcb.work sarracenia.flowcb.work.age sarracenia.flowcb.work.rxpipe sarracenia.identity sarracenia.identity.arbitrary sarracenia.identity.md5 sarracenia.identity.random sarracenia.identity.sha512 sarracenia.instance sarracenia.moth sarracenia.moth.amq1 sarracenia.moth.amqp sarracenia.moth.pika sarracenia.rabbitmq_admin sarracenia.transfer sarracenia.transfer.file sarracenia.transfer.ftp sarracenia.transfer.https sarracenia.transfer.sftp

Moth (class in sarracenia.moth) msg_get_from_file() (sarracenia.diskqueue.DiskQueue method)

N

Name (class in sarracenia.flowcb.nodupe.name) Nasa_mls_nrt (class in sarracenia.flowcb.poll.nasa_mls_nrt) needs_requeuing() (sarracenia.diskqueue.DiskQueue method) new_pathWrite() (sarracenia.Message method)

newMessages() (sarracenia.moth.amqp.AMQP method) (sarracenia.moth.Moth method) no_file_config() (in module sarracenia.config) Noaa_hydrometric (class in sarracenia.flowcb.poll.noaa_hydrometric) NoDupe (class in sarracenia.flowcb.nodupe)

O

octal_number (class in sarracenia.config) on_data() (sarracenia.transfer.Transfer method) on_housekeeping() (sarracenia.diskqueue.DiskQueue method) on_html_page() (sarracenia.flowcb.poll.Poll method)

on_line() (sarracenia.flowcb.poll.Poll method) on_time() (sarracenia.flowcb.v2wrapper.V2Wrapper method) one_config() (in module sarracenia.config) override() (sarracenia.config.Config method)

P

parse_args() (sarracenia.config.Config method) parse_count() (in module sarracenia.config) parse_file() (sarracenia.config.Config method) parse_float() (in module sarracenia.config) PClean (class in sarracenia.flowcb.pclean) PClean_F90 (class in sarracenia.flowcb.filter.pclean_f90) PClean_F92 (class in sarracenia.flowcb.filter.pclean_f92) persist() (sarracenia.filemetadata.FileMetadata method) PIKA (class in sarracenia.moth.pika) please_stop() (sarracenia.flowcb.FlowCB method) (sarracenia.flowcb.gather.message.Message method) (sarracenia.flowcb.post.message.Message method) (sarracenia.moth.Moth method)

Poll (class in sarracenia.flow.poll) (class in sarracenia.flowcb.poll) Post (class in sarracenia.flow.post) post1file() (sarracenia.flowcb.gather.file.File method) Posthourtree (class in sarracenia.flowcb.accept.posthourtree) PostOverride (class in sarracenia.flowcb.accept.postoverride) PrintLag (class in sarracenia.flowcb.accept.printlag) process_event() (sarracenia.flowcb.gather.file.File method) put() (sarracenia.diskqueue.DiskQueue method) putNewMessage() (sarracenia.moth.amqp.AMQP method) (sarracenia.moth.Moth method)

R

Random (class in sarracenia.identity.random) redirect_request() (sarracenia.transfer.https.HTTPRedirectHandlerSameMethod method) RedirectedTimedRotatingFileHandler (class in sarracenia.instance) registered_as() (sarracenia.identity.md5.Md5 static method) reject() (sarracenia.flow.Flow method) removeOneFile() (sarracenia.flow.Flow method) Rename4Jicc (class in sarracenia.flowcb.accept.rename4jicc) RenameDMF (class in sarracenia.flowcb.accept.renamedmf) renameOneItem() (sarracenia.flow.Flow method)

RenameWhatFn (class in sarracenia.flowcb.accept.renamewhatfn) replaceChar() (sarracenia.flowcb.filter.wmo2msc.Wmo2msc method) Report (class in sarracenia.flow.report) Resources (class in sarracenia.flowcb.housekeeping.resources) restart() (sarracenia.flowcb.housekeeping.resources.Resources method) Retry (class in sarracenia.flowcb.retry) run() (sarracenia.flow.Flow method) run_entry() (sarracenia.flowcb.v2wrapper.V2Wrapper method) run_rabbitmqadmin() (in module sarracenia.rabbitmq_admin) Rxpipe (class in sarracenia.flowcb.work.rxpipe)

S

Sample (class in sarracenia.flowcb.destfn.sample) (class in sarracenia.flowcb.sample) Sarra (class in sarracenia.flow.sarra) sarracenia module Sarracenia (class in sarracenia) sarracenia.config module sarracenia.diskqueue module sarracenia.filemetadata module sarracenia.flow module sarracenia.flow.poll module sarracenia.flow.post module sarracenia.flow.report module sarracenia.flow.sarra module sarracenia.flow.sender module sarracenia.flow.shovel module sarracenia.flow.subscribe module sarracenia.flow.watch module sarracenia.flow.winnow module sarracenia.flowcb module sarracenia.flowcb.accept module sarracenia.flowcb.accept.delete module sarracenia.flowcb.accept.downloadbaseurl module sarracenia.flowcb.accept.hourtree module sarracenia.flowcb.accept.httptohttps module sarracenia.flowcb.accept.longflow module sarracenia.flowcb.accept.posthourtree module sarracenia.flowcb.accept.postoverride module sarracenia.flowcb.accept.printlag module sarracenia.flowcb.accept.rename4jicc module sarracenia.flowcb.accept.renamedmf module sarracenia.flowcb.accept.renamewhatfn module sarracenia.flowcb.accept.save module sarracenia.flowcb.accept.speedo module sarracenia.flowcb.accept.sundewpxroute module sarracenia.flowcb.accept.testretry module sarracenia.flowcb.accept.toclusters module sarracenia.flowcb.accept.tolocalfile module sarracenia.flowcb.accept.wmotypesuffix module sarracenia.flowcb.clamav module sarracenia.flowcb.destfn.sample module sarracenia.flowcb.download module sarracenia.flowcb.filter module sarracenia.flowcb.filter.deleteflowfiles module sarracenia.flowcb.filter.fdelay module sarracenia.flowcb.filter.pclean_f90 module sarracenia.flowcb.filter.pclean_f92 module sarracenia.flowcb.filter.wmo2msc module sarracenia.flowcb.gather module sarracenia.flowcb.gather.file module sarracenia.flowcb.gather.message module sarracenia.flowcb.housekeeping module sarracenia.flowcb.housekeeping.resources module

sarracenia.flowcb.log module sarracenia.flowcb.mdelaylatest module sarracenia.flowcb.nodupe module sarracenia.flowcb.nodupe.data module sarracenia.flowcb.nodupe.name module sarracenia.flowcb.pclean module sarracenia.flowcb.poll module sarracenia.flowcb.poll.airnow module sarracenia.flowcb.poll.mail module sarracenia.flowcb.poll.nasa_mls_nrt module sarracenia.flowcb.poll.noaa_hydrometric module sarracenia.flowcb.post module sarracenia.flowcb.post.message module sarracenia.flowcb.retry module sarracenia.flowcb.sample module sarracenia.flowcb.scheduled module sarracenia.flowcb.send module sarracenia.flowcb.send.email module sarracenia.flowcb.shiftdir2baseurl module sarracenia.flowcb.v2wrapper module sarracenia.flowcb.work module sarracenia.flowcb.work.age module sarracenia.flowcb.work.rxpipe module sarracenia.identity module sarracenia.identity.arbitrary module sarracenia.identity.md5 module sarracenia.identity.random module sarracenia.identity.sha512 module sarracenia.instance module sarracenia.moth module sarracenia.moth.amq1 module sarracenia.moth.amqp module sarracenia.moth.pika module sarracenia.rabbitmq_admin module sarracenia.transfer module sarracenia.transfer.file module sarracenia.transfer.ftp module sarracenia.transfer.https module sarracenia.transfer.sftp module Save (class in sarracenia.flowcb.accept.save) Scheduled (class in sarracenia.flowcb.scheduled) Sender (class in sarracenia.flow.sender) set() (sarracenia.filemetadata.FileMetadata method) set_local_file_attributes() (sarracenia.flow.Flow method) setReport() (sarracenia.Message method) Sftp (class in sarracenia.transfer.sftp) Sha512 (class in sarracenia.identity.sha512) ShiftDir2baseUrl (class in sarracenia.flowcb.shiftdir2baseurl) Shovel (class in sarracenia.flow.shovel) SimpleEventHandler (class in sarracenia.flowcb.gather.file) sock (sarracenia.transfer.ftp.IMPLICIT_FTP_TLS property) Speedo (class in sarracenia.flowcb.accept.speedo) start() (sarracenia.instance.instance method) stat() (in module sarracenia) stop_request() (sarracenia.flow.Flow method) str_options (in module sarracenia.config) Subscribe (class in sarracenia.flow.subscribe) sumstrFromMessage() (in module sarracenia.flowcb.v2wrapper) sundew_dirPattern() (sarracenia.config.Config method) sundew_getDestInfos() (sarracenia.flow.Flow method) SundewPxRoute (class in sarracenia.flowcb.accept.sundewpxroute)

T

TestRetry (class in sarracenia.flowcb.accept.testretry) threshold (sarracenia.flowcb.housekeeping.resources.Resources attribute) TimeConversions (class in sarracenia) timeflt2str() (in module sarracenia)

TimeoutException ToClusters (class in sarracenia.flowcb.accept.toclusters) ToLocalFile (class in sarracenia.flowcb.accept.tolocalfile) Transfer (class in sarracenia.transfer)

U

update_appointments() (sarracenia.flowcb.scheduled.Scheduled method) update_file() (sarracenia.identity.Identity method)

updateFieldsAccepted() (sarracenia.flow.Flow method) updatePaths() (sarracenia.Message method) user_access() (in module sarracenia.rabbitmq_admin)

V

V2Wrapper (class in sarracenia.flowcb.v2wrapper) validate() (sarracenia.Message method) value (sarracenia.identity.arbitrary.Arbitrary property) (sarracenia.identity.Identity property) (sarracenia.identity.random.Random property)

variableExpansion() (sarracenia.config.Config method)

W

walk() (sarracenia.flowcb.gather.file.File method) walk_priming() (sarracenia.flowcb.gather.file.File method) Watch (class in sarracenia.flow.watch)

Winnow (class in sarracenia.flow.winnow) Wmo2msc (class in sarracenia.flowcb.filter.wmo2msc) WmoTypeSuffix (class in sarracenia.flowcb.accept.wmotypesuffix) write_inline_file() (sarracenia.flow.Flow method)