Index

A

add() (pypeman.channels.BaseChannel method) add_context() (pypeman.message.Message method)

add_handler() (pypeman.events.Event method) append() (pypeman.channels.BaseChannel method) async_run() (pypeman.nodes.BaseNode method)

B

B64Decode (class in pypeman.nodes) B64Encode (class in pypeman.nodes)

BaseChannel (class in pypeman.channels) BaseNode (class in pypeman.nodes)

C

callable_or_value() (in module pypeman.nodes) Case (class in pypeman.channels) case() (pypeman.channels.BaseChannel method) change_message_state() (pypeman.msgstore.MessageStore method) channels() (pypeman.remoteadmin.RemoteAdminClient method) (pypeman.remoteadmin.RemoteAdminServer method) ChannelStopped

choose_first_not_none() (in module pypeman.nodes) command() (pypeman.remoteadmin.RemoteAdminServer method) ConditionSubChannel (class in pypeman.channels) connection_lost() (pypeman.contrib.hl7.MLLPProtocol method) connection_made() (pypeman.contrib.hl7.MLLPProtocol method) copy() (pypeman.message.Message method) count_msgs() (pypeman.msgstore.FileMessageStore method) CronChannel (class in pypeman.contrib.time)

D

data_received() (pypeman.contrib.hl7.MLLPProtocol method) Decode (class in pypeman.nodes) delete() (pypeman.contrib.ftp.FTPHelper method)

download_file() (pypeman.contrib.ftp.FTPHelper method) (pypeman.contrib.ftp.FTPWatcherChannel method) Drop (class in pypeman.nodes) Dropped

E

Email (class in pypeman.nodes) Empty (class in pypeman.nodes) Encode (class in pypeman.nodes)

Event (class in pypeman.events) exec() (pypeman.remoteadmin.RemoteAdminClient method) (pypeman.remoteadmin.RemoteAdminServer method)

F

FakeMessageStore (class in pypeman.msgstore) FakeMessageStoreFactory (class in pypeman.msgstore) FileMessageStore (class in pypeman.msgstore) FileMessageStoreFactory (class in pypeman.msgstore) FileReader (class in pypeman.nodes) FileWatcherChannel (class in pypeman.channels) FileWriter (class in pypeman.nodes) fire() (pypeman.events.Event method) fork() (pypeman.channels.BaseChannel method)

from_dict() (pypeman.message.Message static method) from_json() (pypeman.message.Message static method) FTPConnection (class in pypeman.contrib.ftp) FTPFileDeleter (class in pypeman.contrib.ftp) FTPFileReader (class in pypeman.contrib.ftp) FTPFileWriter (class in pypeman.contrib.ftp) FTPHelper (class in pypeman.contrib.ftp) FTPWatcherChannel (class in pypeman.contrib.ftp) fullpath() (pypeman.nodes.BaseNode method)

G

get() (pypeman.msgstore.MessageStore method) get_channel() (pypeman.remoteadmin.RemoteAdminServer method) get_file_and_process() (pypeman.contrib.ftp.FTPWatcherChannel method) get_node() (pypeman.channels.BaseChannel method)

get_store() (pypeman.msgstore.MessageStoreFactory method) getHandlerCount() (pypeman.events.Event method) graph() (pypeman.channels.BaseChannel method) graph_dot() (pypeman.channels.BaseChannel method)

H

handle() (pypeman.channels.BaseChannel method) (pypeman.nodes.BaseNode method) handle_and_wait() (pypeman.channels.BaseChannel method) handle_request() (pypeman.contrib.http.HttpRequest method)

HL7ToPython (class in pypeman.contrib.hl7) HttpChannel (class in pypeman.contrib.http) HTTPEndpoint (class in pypeman.contrib.http) HttpRequest (class in pypeman.contrib.http)

I

is_stopped() (pypeman.channels.BaseChannel method)

J

JsonToPython (class in pypeman.nodes)

L

list_msg() (pypeman.remoteadmin.RemoteAdminClient method) (pypeman.remoteadmin.RemoteAdminServer method)

Log (class in pypeman.nodes) log() (pypeman.message.Message method)

M

Map (class in pypeman.nodes) MemoryMessageStore (class in pypeman.msgstore) MemoryMessageStoreFactory (class in pypeman.msgstore) Message (class in pypeman.message)

MessageStore (class in pypeman.msgstore) MessageStoreFactory (class in pypeman.msgstore) MLLPProtocol (class in pypeman.contrib.hl7) mock() (pypeman.nodes.BaseNode method)

N

NullMessageStore (class in pypeman.msgstore)

NullMessageStoreFactory (class in pypeman.msgstore)

P

process() (pypeman.channels.BaseChannel method) (pypeman.contrib.http.HttpRequest method) (pypeman.nodes.BaseNode method) push_msg() (pypeman.remoteadmin.RemoteAdminClient method) (pypeman.remoteadmin.RemoteAdminServer method) pypeman.channels (module) pypeman.contrib (module) pypeman.contrib.ftp (module) pypeman.contrib.hl7 (module) pypeman.contrib.http (module)

pypeman.contrib.time (module) pypeman.contrib.xml (module) pypeman.endpoints (module) pypeman.events (module) pypeman.message (module) pypeman.msgstore (module) pypeman.nodes (module) pypeman.remoteadmin (module) PythonToHL7 (class in pypeman.contrib.hl7) PythonToJson (class in pypeman.nodes) PythonToXML (class in pypeman.contrib.xml)

R

receiver() (pypeman.events.Event method) Rejected RemoteAdminClient (class in pypeman.remoteadmin) RemoteAdminServer (class in pypeman.remoteadmin) remove_handler() (pypeman.events.Event method) rename() (pypeman.contrib.ftp.FTPHelper method)

renew() (pypeman.message.Message method) replay() (pypeman.channels.BaseChannel method) replay_msg() (pypeman.remoteadmin.RemoteAdminClient method) (pypeman.remoteadmin.RemoteAdminServer method) restore_data() (pypeman.nodes.BaseNode method) run() (pypeman.nodes.BaseNode method)

S

Save (class in pypeman.nodes) save_data() (pypeman.nodes.BaseNode method) SaveFileBackend (class in pypeman.nodes) SaveNullBackend (class in pypeman.nodes) search() (pypeman.msgstore.MessageStore method) send_command() (pypeman.remoteadmin.RemoteAdminClient method) SetCtx (class in pypeman.nodes) Sleep (class in pypeman.nodes) sorted_list_directories() (pypeman.msgstore.FileMessageStore method) start() (pypeman.channels.BaseChannel method) (pypeman.msgstore.MessageStore method) (pypeman.remoteadmin.RemoteAdminClient method) (pypeman.remoteadmin.RemoteAdminServer method)

start_channel() (pypeman.remoteadmin.RemoteAdminServer method) status (pypeman.channels.BaseChannel attribute) stop() (pypeman.channels.BaseChannel method) (pypeman.remoteadmin.RemoteAdminClient method) stop_channel() (pypeman.remoteadmin.RemoteAdminServer method) store() (pypeman.msgstore.FileMessageStore method) (pypeman.msgstore.MessageStore method) SubChannel (class in pypeman.channels) subhandle() (pypeman.channels.BaseChannel method)

T

ThreadNode (class in pypeman.nodes) tick() (pypeman.contrib.ftp.FTPWatcherChannel method) timestamp_str() (pypeman.message.Message method) to_dict() (pypeman.message.Message method)

to_json() (pypeman.message.Message method) to_print() (pypeman.message.Message method) ToOrderedDict (class in pypeman.nodes) total() (pypeman.msgstore.MessageStore method)

U

upload_file() (pypeman.contrib.ftp.FTPHelper method)

W

watch_for_file() (pypeman.contrib.ftp.FTPWatcherChannel method)

when() (pypeman.channels.BaseChannel method)

X

XMLToPython (class in pypeman.contrib.xml)