gavo.protocols package

Submodules

• gavo.protocols.adqlglue module
  • ADQLCore
    • ADQLCore.attrSeq
    • ADQLCore.clearProperty()
    • ADQLCore.completedCallbacks
    • ADQLCore.getFullId()
    • ADQLCore.getProperty()
    • ADQLCore.hasProperty()
    • ADQLCore.managedAttrs
    • ADQLCore.name_
    • ADQLCore.rd
    • ADQLCore.run()
    • ADQLCore.setProperty()
    • ADQLCore.wantsTableWidget()
  • DaCHSFieldInfoGetter
    • DaCHSFieldInfoGetter.getInfosFor()
  • TDContext
    • TDContext.getName()
  • adqlTableRefToDaCHS()
  • localquery()
  • makeFieldInfo()
  • mapADQLErrors()
  • morphADQL()
  • query()
  • runTAPQuery()
• gavo.protocols.creds module
  • addToGroup()
  • addUser()
  • changeUser()
  • delUser()
  • getGroupsForUser()
  • getHashedAdminPassword()
  • hasCredentials()
  • hashMatches()
  • hashPassword()
  • isAdmin()
  • removeFromGroup()
• gavo.protocols.dali module
  • DALIErrorResource
    • DALIErrorResource.isLeaf
    • DALIErrorResource.render()
  • URLUpload
    • URLUpload.value
  • getDALIError()
  • getUploadKeyFor()
  • iterUploads()
  • mangleUploads()
  • parseUploadString()
  • serveDALIError()
• gavo.protocols.datalink module
  • DLFITSProductDescriptor
  • DataFormatter
    • DataFormatter.additionalNamesForProcs
    • DataFormatter.attrSeq
    • DataFormatter.completedCallbacks
    • DataFormatter.formalArgs
    • DataFormatter.managedAttrs
    • DataFormatter.name_
    • DataFormatter.requiredType
  • DataFunction
    • DataFunction.additionalNamesForProcs
    • DataFunction.attrSeq
    • DataFunction.completedCallbacks
    • DataFunction.formalArgs
    • DataFunction.managedAttrs
    • DataFunction.name_
    • DataFunction.requiredType
  • DatalinkCore
    • DatalinkCore.adaptForDescriptors()
    • DatalinkCore.adaptForRenderer()
    • DatalinkCore.attrSeq
    • DatalinkCore.clearProperty()
    • DatalinkCore.completedCallbacks
    • DatalinkCore.datalinkAdaptingRenderers
    • DatalinkCore.datalinkType
    • DatalinkCore.finalize()
    • DatalinkCore.getFullId()
    • DatalinkCore.getProperty()
    • DatalinkCore.hasProperty()
    • DatalinkCore.managedAttrs
    • DatalinkCore.name_
    • DatalinkCore.overflowed
    • DatalinkCore.rd
    • DatalinkCore.runForData()
    • DatalinkCore.runForMeta()
    • DatalinkCore.setProperty()
    • DatalinkCore.workerSystem
  • DatalinkCoreBase
    • DatalinkCoreBase.attrSeq
    • DatalinkCoreBase.clearProperty()
    • DatalinkCoreBase.completeElement()
    • DatalinkCoreBase.completedCallbacks
    • DatalinkCoreBase.getDatalinksResource()
    • DatalinkCoreBase.getFullId()
    • DatalinkCoreBase.getMetaForDescriptor()
    • DatalinkCoreBase.getProperty()
    • DatalinkCoreBase.hasProperty()
    • DatalinkCoreBase.managedAttrs
    • DatalinkCoreBase.rd
    • DatalinkCoreBase.rejectExtras
    • DatalinkCoreBase.setProperty()
  • DatalinkDescriptorMixin
    • DatalinkDescriptorMixin.cleanup()
    • DatalinkDescriptorMixin.contentQualifier
    • DatalinkDescriptorMixin.currentSemantics()
    • DatalinkDescriptorMixin.data
    • DatalinkDescriptorMixin.forSemantics
    • DatalinkDescriptorMixin.makeLink()
    • DatalinkDescriptorMixin.makeLinkFromFile()
  • DescriptorGenerator
    • DescriptorGenerator.additionalNamesForProcs
    • DescriptorGenerator.attrSeq
    • DescriptorGenerator.completedCallbacks
    • DescriptorGenerator.formalArgs
    • DescriptorGenerator.managedAttrs
    • DescriptorGenerator.name_
    • DescriptorGenerator.requiredType
  • FITSProductDescriptor
    • FITSProductDescriptor.changingAxis()
    • FITSProductDescriptor.cleanup()
  • LinkDef
    • LinkDef.asDict()
    • LinkDef.fromFile()
  • MetaMaker
    • MetaMaker.additionalNamesForProcs
    • MetaMaker.attrSeq
    • MetaMaker.completedCallbacks
    • MetaMaker.formalArgs
    • MetaMaker.managedAttrs
    • MetaMaker.name_
    • MetaMaker.requiredType
  • ProcLinkDef
    • ProcLinkDef.asDict()
    • ProcLinkDef.asVOT()
  • ProductDescriptor
    • ProductDescriptor.estimateSize()
    • ProductDescriptor.fromAccref()
  • getFITSDescriptor()
  • makeDatalinkServiceDescriptor()
• gavo.protocols.datapack module
  • create()
  • dumpPackage()
  • getPackageMeta()
  • getRDForDump()
  • iterExtraResources()
  • iterRDResources()
  • load()
  • main()
  • makeBasicMeta()
  • makeDescriptor()
  • namer()
• gavo.protocols.dlasync module
  • DLJob
  • DLTransitions
    • DLTransitions.getCommandLine()
    • DLTransitions.queueJob()
  • DLUWS
    • DLUWS.baseURL
    • DLUWS.getURLForId()
    • DLUWS.jobdocPreamble
    • DLUWS.joblistPreamble
    • DLUWS.parameterGrammar
  • WritingFakeRequest
    • WritingFakeRequest.finish()
    • WritingFakeRequest.write()
  • main()
  • parseCommandLine()
  • writeResultTo()
• gavo.protocols.gavolog module
  • RotatingFileHandler
    • RotatingFileHandler.doRollover()
  • getLoggingHandler()
• gavo.protocols.linetap module
  • InChIError
  • getElementData()
  • getILib()
• gavo.protocols.oaiclient module
  • CanonicalPrefixes
    • CanonicalPrefixes.getNSForPrefix()
    • CanonicalPrefixes.getPrefixForNS()
    • CanonicalPrefixes.haveNS()
    • CanonicalPrefixes.iterNS()
    • CanonicalPrefixes.registerPrefix()
    • CanonicalPrefixes.registerPrefixOrMakeUp()
  • FailedQuery
  • IdParser
    • IdParser.getResult()
    • IdParser.resumptionToken
  • IdentifyParser
    • IdentifyParser.getResult()
    • IdentifyParser.resumptionToken
    • IdentifyParser.serverProperties
  • NoRecordsMatch
  • OAIErrorMixin
  • OAIQuery
    • OAIQuery.doHTTP()
    • OAIQuery.endDate
    • OAIQuery.getKWs()
    • OAIQuery.maxRecords
    • OAIQuery.metadataPrefix
    • OAIQuery.registry
    • OAIQuery.set
    • OAIQuery.startDate
    • OAIQuery.talkOAI()
    • OAIQuery.timeout
  • OAIRecordsParser
    • OAIRecordsParser.characters()
    • OAIRecordsParser.endElementNS()
    • OAIRecordsParser.endHandlers
    • OAIRecordsParser.endPrefixMapping()
    • OAIRecordsParser.getResult()
    • OAIRecordsParser.normalizeNamespace()
    • OAIRecordsParser.notifyError()
    • OAIRecordsParser.resumptionToken
    • OAIRecordsParser.shipout()
    • OAIRecordsParser.startElementNS()
    • OAIRecordsParser.startHandlers
    • OAIRecordsParser.startPrefixMapping()
  • PrefixIsTaken
  • RecordParser
  • ServerProperties
    • ServerProperties.add()
    • ServerProperties.adminEmails
    • ServerProperties.baseURL
    • ServerProperties.compressions
    • ServerProperties.deletedRecord
    • ServerProperties.earliestDatestamp
    • ServerProperties.granularity
    • ServerProperties.protocolVersion
    • ServerProperties.repositoryName
    • ServerProperties.set()
  • getCanonicalPrefixes()
  • getIdentifiers()
  • getRecord()
  • getRecords()
  • getServerProperties()
  • parseRecord()
• gavo.protocols.obscore module
  • restoreObscore()
  • suspendFromObscore()
• gavo.protocols.products module
  • CutoutProduct
    • CutoutProduct.fromRAccref()
    • CutoutProduct.iterData()
    • CutoutProduct.makePreview()
    • CutoutProduct.render()
  • FileProduct
    • FileProduct.close()
    • FileProduct.forSaving
    • FileProduct.fromRAccref()
    • FileProduct.getFile()
    • FileProduct.iterData()
    • FileProduct.read()
    • FileProduct.render()
  • InvalidProduct
    • InvalidProduct.fromRAccref()
    • InvalidProduct.iterData()
  • NonExistingProduct
    • NonExistingProduct.fromRAccref()
    • NonExistingProduct.iterData()
    • NonExistingProduct.render()
  • PreviewCacheManager
    • PreviewCacheManager.cachePath
    • PreviewCacheManager.getCacheName()
    • PreviewCacheManager.getCachedPreviewPath()
    • PreviewCacheManager.getPreviewFor()
    • PreviewCacheManager.saveToCache()
  • ProductBase
    • ProductBase.chunkSize
    • ProductBase.close()
    • ProductBase.fromRAccref()
    • ProductBase.iterData()
    • ProductBase.read()
    • ProductBase.render()
    • ProductBase.setupRealFile()
  • ProductCore
    • ProductCore.attrSeq
    • ProductCore.clearProperty()
    • ProductCore.completedCallbacks
    • ProductCore.getFullId()
    • ProductCore.getProperty()
    • ProductCore.hasProperty()
    • ProductCore.managedAttrs
    • ProductCore.name_
    • ProductCore.rd
    • ProductCore.resolveName()
    • ProductCore.run()
    • ProductCore.setProperty()
  • RAccref
    • RAccref.fromPathAndArgs()
    • RAccref.fromRequest()
    • RAccref.fromString()
    • RAccref.localpath
    • RAccref.previewIsCacheable()
    • RAccref.productsRow
  • RemotePreview
    • RemotePreview.fromRAccref()
  • RemoteProduct
    • RemoteProduct.fromRAccref()
    • RemoteProduct.fromURL()
    • RemoteProduct.iterData()
    • RemoteProduct.render()
  • ScaledFITSProduct
    • ScaledFITSProduct.fromRAccref()
    • ScaledFITSProduct.iterData()
    • ScaledFITSProduct.render()
  • StaticPreview
    • StaticPreview.forSaving
    • StaticPreview.fromRAccref()
  • UnauthorizedProduct
    • UnauthorizedProduct.forSaving
    • UnauthorizedProduct.fromRAccref()
    • UnauthorizedProduct.render()
  • computePreviewFor()
  • formatProductLink()
  • getProductColumns()
  • getProductForRAccref()
  • makePreviewFromFITS()
  • makePreviewWithPIL()
  • makeProductLink()
  • quoteProductKey()
  • unquoteProductKey()
• gavo.protocols.scs module
  • SCSCore
    • SCSCore.attrSeq
    • SCSCore.clearProperty()
    • SCSCore.completedCallbacks
    • SCSCore.getFullId()
    • SCSCore.getProperty()
    • SCSCore.hasProperty()
    • SCSCore.managedAttrs
    • SCSCore.name_
    • SCSCore.onElementComplete()
    • SCSCore.rd
    • SCSCore.resolveName()
    • SCSCore.setProperty()
  • findNClosest()
  • getConeColumns()
  • getRadialCondition()
  • parseHumanSpoint()
• gavo.protocols.sdm module
  • formatSDMData()
  • getColIndForUtype()
  • getFluxColumn()
  • getSDM1UtypeForSSA()
  • getSpectralColumn()
  • makeBasicSDMHeader()
  • makeSDMDataForPUBDID()
  • makeSDMDataForSSARow()
  • makeSDMFITS()
  • mangle_cutout()
  • mangle_fluxcalib()
• gavo.protocols.siap module
  • SIAPCutoutCore
    • SIAPCutoutCore.attrSeq
    • SIAPCutoutCore.clearProperty()
    • SIAPCutoutCore.completedCallbacks
    • SIAPCutoutCore.copiedCols
    • SIAPCutoutCore.getFullId()
    • SIAPCutoutCore.getProperty()
    • SIAPCutoutCore.getQueryCols()
    • SIAPCutoutCore.hasProperty()
    • SIAPCutoutCore.managedAttrs
    • SIAPCutoutCore.name_
    • SIAPCutoutCore.rd
    • SIAPCutoutCore.resolveName()
    • SIAPCutoutCore.run()
    • SIAPCutoutCore.setProperty()
  • dissectPositions()
  • getPGSQuery()
  • getQuery()
  • parseSIAP2Geometry()
• gavo.protocols.simbadinterface module
  • ObjectCache
    • ObjectCache.addItem()
    • ObjectCache.getItem()
  • Sesame
    • Sesame.getPositionFor()
    • Sesame.query()
    • Sesame.svc_urls
  • getSimbadPositions()
• gavo.protocols.soda module
  • DatalinkFault
    • DatalinkFault.AuthenticationFault()
    • DatalinkFault.AuthorizationFault()
    • DatalinkFault.FatalFault()
    • DatalinkFault.Fault()
    • DatalinkFault.NotFoundFault()
    • DatalinkFault.TransientFault()
    • DatalinkFault.UsageFault()
    • DatalinkFault.asDict()
    • DatalinkFault.raiseException()
  • DeliverNow
  • EmptyData
    • EmptyData.responseCode
    • EmptyData.responsePayload
  • FormatNow
  • addPolygonSlices()
  • doAxisCutout()
  • ensureSkyWCS()
  • iterOtherAxisKeys()
  • iterSpatialAxisKeys()
• gavo.protocols.ssap module
  • SSADescriptor
    • SSADescriptor.fromSSAResult()
    • SSADescriptor.fromSSARow()
    • SSADescriptor.ssaRow
  • SSAPCore
    • SSAPCore.attrSeq
    • SSAPCore.clearProperty()
    • SSAPCore.completedCallbacks
    • SSAPCore.getFullId()
    • SSAPCore.getProperty()
    • SSAPCore.hasProperty()
    • SSAPCore.managedAttrs
    • SSAPCore.name_
    • SSAPCore.onElementComplete()
    • SSAPCore.outputTableXML
    • SSAPCore.previewColumn
    • SSAPCore.rd
    • SSAPCore.resolveName()
    • SSAPCore.run()
    • SSAPCore.setProperty()
  • getDatalinkCore()
  • iterViewColumns()
• gavo.protocols.tap module
  • LocalFile
    • LocalFile.getURL()
  • PlanAction
    • PlanAction.doGET()
    • PlanAction.formatPlan()
    • PlanAction.getPlan()
    • PlanAction.name
  • TAPCore
    • TAPCore.attrSeq
    • TAPCore.clearProperty()
    • TAPCore.completedCallbacks
    • TAPCore.getFullId()
    • TAPCore.getProperty()
    • TAPCore.getRelevantTables()
    • TAPCore.hasProperty()
    • TAPCore.inputTableXML
    • TAPCore.managedAttrs
    • TAPCore.name_
    • TAPCore.rd
    • TAPCore.run()
    • TAPCore.setProperty()
    • TAPCore.workerSystem
  • TAPError
  • TAPJob
    • TAPJob.prepareForDestruction()
    • TAPJob.quote
  • TAPTransitions
    • TAPTransitions.completeJob()
    • TAPTransitions.errorOutJob()
    • TAPTransitions.getCommandLine()
    • TAPTransitions.killJob()
    • TAPTransitions.queueJob()
  • TAPUWS
    • TAPUWS.baseURL
    • TAPUWS.getURLForId()
    • TAPUWS.jobdocPreamble
    • TAPUWS.joblistPreamble
    • TAPUWS.parameterGrammar
  • getAccessibleTables()
  • getSupportedLanguages()
  • getSupportedOutputFormats()
  • getUploadGrammar()
  • mangleUploads()
  • parseUploadString()
  • publishToTAP()
  • unpublishFromTAP()
• gavo.protocols.taprunner module
  • getQTableFromJob()
  • joinInterruptibly()
  • main()
  • parseCommandLine()
  • runSyncTAPJob()
  • runTAPJob()
  • runTAPJobNoState()
  • setINTHandler()
  • writeResultTo()
• gavo.protocols.useruws module
  • UserUWS
    • UserUWS.getIdsAndPhases()
    • UserUWS.getURLForId()
    • UserUWS.jobdocPreamble
    • UserUWS.joblistPreamble
  • UserUWSJobBase
  • UserUWSTransitions
    • UserUWSTransitions.getCommandLine()
    • UserUWSTransitions.queueJob()
  • main()
  • makeUWSForService()
  • makeUserUWSJobClass()
  • parseCommandLine()
• gavo.protocols.uws module
  • BaseUWSJob
    • BaseUWSJob.change()
    • BaseUWSJob.completeParams()
    • BaseUWSJob.getDefaults()
    • BaseUWSJob.getNewId()
    • BaseUWSJob.getProperties()
    • BaseUWSJob.getTransitionTo()
    • BaseUWSJob.getURL()
    • BaseUWSJob.getWritable()
    • BaseUWSJob.iterSerializedPars()
    • BaseUWSJob.prepareForDestruction()
    • BaseUWSJob.quote
    • BaseUWSJob.setPar()
    • BaseUWSJob.setParamsFromDict()
    • BaseUWSJob.setParamsFromRawDict()
    • BaseUWSJob.update()
  • JobNotFound
  • LocalFile
    • LocalFile.getURL()
  • ParameterRef
  • ProcessBasedUWSTransitions
    • ProcessBasedUWSTransitions.getCommandLine()
    • ProcessBasedUWSTransitions.killJob()
    • ProcessBasedUWSTransitions.startJob()
    • ProcessBasedUWSTransitions.trial_forceTwisted
  • SimpleUWSTransitions
    • SimpleUWSTransitions.completeJob()
    • SimpleUWSTransitions.errorOutJob()
    • SimpleUWSTransitions.ignoreAndLog()
    • SimpleUWSTransitions.killJob()
    • SimpleUWSTransitions.markAborted()
    • SimpleUWSTransitions.queueJob()
  • UWS
    • UWS.changeToPhase()
    • UWS.changeableJob()
    • UWS.cleanupInterval
    • UWS.cleanupJobsTable()
    • UWS.countQueuedJobs()
    • UWS.countRunningJobs()
    • UWS.destroy()
    • UWS.getIdsAndPhases()
    • UWS.getJob()
    • UWS.getJobIds()
    • UWS.getNewIdFromArgs()
    • UWS.getNewIdFromRequest()
    • UWS.getNewJob()
    • UWS.getNewJobId()
    • UWS.getURLForId()
    • UWS.jobdocPreamble
    • UWS.joblistPreamble
    • UWS.parameterGrammar
    • UWS.runCanned()
  • UWSError
  • UWSJobType
    • UWSJobType.jobsTD
  • UWSJobWithWD
    • UWSJobWithWD.addResult()
    • UWSJobWithWD.fixTypeForResultName()
    • UWSJobWithWD.getNewId()
    • UWSJobWithWD.getResult()
    • UWSJobWithWD.getResults()
    • UWSJobWithWD.getWD()
    • UWSJobWithWD.openFile()
    • UWSJobWithWD.openResult()
    • UWSJobWithWD.prepareForDestruction()
  • UWSTransitions
    • UWSTransitions.flagError()
    • UWSTransitions.getTransition()
    • UWSTransitions.noOp()
    • UWSTransitions.noteEndTime()
  • UWSWithQueueing
    • UWSWithQueueing.changeToPhase()
    • UWSWithQueueing.checkProcessQueue()
    • UWSWithQueueing.queueCheckInterval
    • UWSWithQueueing.runcountGoal
    • UWSWithQueueing.scheduleProcessQueueCheck()
  • prepareRequest()
• gavo.protocols.uwsactions module
  • DestructionAction
    • DestructionAction.attName
    • DestructionAction.deserializeValue()
    • DestructionAction.name
    • DestructionAction.serializeValue()
  • ErrorAction
    • ErrorAction.doGET()
    • ErrorAction.doPOST()
    • ErrorAction.mime
    • ErrorAction.name
  • ExecDAction
    • ExecDAction.attName
    • ExecDAction.deserializeValue
    • ExecDAction.name
    • ExecDAction.serializeValue
  • JobAction
    • JobAction.getResource()
    • JobAction.mime
    • JobAction.name
  • JobActions
    • JobActions.addStandardAction()
    • JobActions.dispatch()
  • OwnerAction
    • OwnerAction.doGET()
    • OwnerAction.mime
    • OwnerAction.name
  • ParameterAction
    • ParameterAction.doGET()
    • ParameterAction.doPOST()
    • ParameterAction.name
  • PhaseAction
    • PhaseAction.doGET()
    • PhaseAction.doPOST()
    • PhaseAction.mime
    • PhaseAction.name
    • PhaseAction.timeout
  • QuoteAction
    • QuoteAction.doGET()
    • QuoteAction.mime
    • QuoteAction.name
  • ResultsAction
    • ResultsAction.doGET()
    • ResultsAction.getResource()
    • ResultsAction.name
  • RootAction
    • RootAction.doDELETE()
    • RootAction.doGET()
    • RootAction.doPOST()
    • RootAction.name
  • StartTimeAction
    • StartTimeAction.doGET()
    • StartTimeAction.doPOST()
    • StartTimeAction.mime
    • StartTimeAction.name
  • UWS
    • UWS.UWSElement
    • UWS.creationTime
    • UWS.destruction
    • UWS.detail
    • UWS.endTime
    • UWS.errorSummary
    • UWS.executionDuration
    • UWS.job
    • UWS.jobId
    • UWS.jobInfo
    • UWS.jobref
    • UWS.jobs
    • UWS.makeRoot()
    • UWS.message
    • UWS.ownerId
    • UWS.parameter
    • UWS.parameters
    • UWS.phase
    • UWS.quote
    • UWS.result
    • UWS.results
    • UWS.runId
    • UWS.startTime
  • doJobAction()
  • getErrorSummary()
  • getJobList()
  • getParametersElement()
• gavo.protocols.vocabularies module
  • SubjectMeta
  • download_file()
  • get_label()
  • get_vocabulary()

Module contents

IVOA, W3C, and custom protocol helpers (in cooperation with twisted-based code in weg).

The guiding line should be: Stuff that depends on twisted should go to web or svcs, generic code should be here. Of course, these rules are constantly bent.

When writing support for a protocol, do as much as possible as far as templates for RDs in an RD //<protoname>.

Use the code in protocols for the core and possible library-like functionality.