icecube.gcdserver.I3MS module¶
- class icecube.gcdserver.I3MS.DBInsertHandler(inserter, i3msHost, force=False)¶
Bases:
object
Wrap commit() method of inserter to both insert the data into the local database and forward the data to I3MS. Roll back the local transaction if I3MS forwarding fails
- close()¶
- commit()¶
- insert(msg)¶
- class icecube.gcdserver.I3MS.DBReceiver(db, i3msHost)¶
Bases:
object
Wrap a I3MSSubscriber instance with a routine to insert GCD data into the proper collection in the omdb Mongo database
- close()¶
- class icecube.gcdserver.I3MS.I3MSBase(socketType, host, port, bind=False, poll_msec=5000, linger_msec=1000)¶
Bases:
object
- close()¶
- class icecube.gcdserver.I3MS.I3MSSender(host, port, **kwargs)¶
Bases:
I3MSBase
ZMQ REQ client for sending data to I3MS
- send(msg)¶
- class icecube.gcdserver.I3MS.I3MSSubscriber(handler, host, **kwargs)¶
Bases:
I3MSBase
ZMQ SUB client for receiving transaction data from I3MS
- close()¶
- class icecube.gcdserver.I3MS.I3MSTransactionSender(host, **kwargs)¶
Bases:
object
Format transaction data and send it to I3MS via I3MSSender. Set topic and check I3MS return.
- close()¶
- send(msg)¶
- icecube.gcdserver.I3MS.I3MSWrap(msg, topic)¶
Wrap up an I3MS transmission message with topic and service
- icecube.gcdserver.I3MS.calDBInserter(db, runValid, i3msHost=None, force=False)¶
- icecube.gcdserver.I3MS.db_receiver_context(db, i3msHost)¶
- icecube.gcdserver.I3MS.geoDBInserter(db, i3msHost=None, force=False)¶
- icecube.gcdserver.I3MS.getSender(i3msHost)¶
- icecube.gcdserver.I3MS.i3ms_sender_context(host, port, **kwargs)¶
- icecube.gcdserver.I3MS.statusDBInserter(db, i3msHost=None, force=False)¶