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

class icecube.gcdserver.I3MS.NullSender

Bases: object

close()

send(msgList)

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)