synapse package
The synapse intelligence analysis framework.
Subpackages
- synapse.assets package
- synapse.cmds package
- synapse.data package
- synapse.lib package
- Subpackages
- synapse.lib.crypto package
- synapse.lib.platforms package
- synapse.lib.stormlib package
- Submodules
- synapse.lib.stormlib.aha module
- synapse.lib.stormlib.auth module
- synapse.lib.stormlib.backup module
- synapse.lib.stormlib.basex module
- synapse.lib.stormlib.cache module
- synapse.lib.stormlib.cell module
- synapse.lib.stormlib.compression module
- synapse.lib.stormlib.cortex module
- synapse.lib.stormlib.easyperm module
- synapse.lib.stormlib.env module
- synapse.lib.stormlib.ethereum module
- synapse.lib.stormlib.gen module
- synapse.lib.stormlib.gis module
- synapse.lib.stormlib.graph module
- synapse.lib.stormlib.hashes module
- synapse.lib.stormlib.hex module
- synapse.lib.stormlib.imap module
- synapse.lib.stormlib.infosec module
- synapse.lib.stormlib.ipv6 module
- synapse.lib.stormlib.iters module
- synapse.lib.stormlib.json module
- synapse.lib.stormlib.log module
- synapse.lib.stormlib.macro module
- synapse.lib.stormlib.math module
- synapse.lib.stormlib.mime module
- synapse.lib.stormlib.model module
- synapse.lib.stormlib.modelext module
- synapse.lib.stormlib.notifications module
- synapse.lib.stormlib.oauth module
- synapse.lib.stormlib.pack module
- synapse.lib.stormlib.project module
- synapse.lib.stormlib.random module
- synapse.lib.stormlib.scrape module
- synapse.lib.stormlib.smtp module
- synapse.lib.stormlib.spooled module
- synapse.lib.stormlib.stats module
- synapse.lib.stormlib.stix module
- synapse.lib.stormlib.storm module
- synapse.lib.stormlib.tabular module
- synapse.lib.stormlib.vault module
- synapse.lib.stormlib.version module
- synapse.lib.stormlib.xml module
- synapse.lib.stormlib.yaml module
- Submodules
- synapse.lib.agenda module
- synapse.lib.aha module
AhaApi
AhaApi.addAhaClone()
AhaApi.addAhaPool()
AhaApi.addAhaPoolSvc()
AhaApi.addAhaServer()
AhaApi.addAhaSvc()
AhaApi.addAhaSvcProv()
AhaApi.addAhaUserEnroll()
AhaApi.clearAhaClones()
AhaApi.clearAhaSvcProvs()
AhaApi.clearAhaUserEnrolls()
AhaApi.delAhaPool()
AhaApi.delAhaPoolSvc()
AhaApi.delAhaServer()
AhaApi.delAhaSvc()
AhaApi.delAhaSvcProv()
AhaApi.delAhaUserEnroll()
AhaApi.genCaCert()
AhaApi.getAhaPool()
AhaApi.getAhaPools()
AhaApi.getAhaServer()
AhaApi.getAhaServers()
AhaApi.getAhaSvc()
AhaApi.getAhaSvcMirrors()
AhaApi.getAhaSvcs()
AhaApi.getAhaUrls()
AhaApi.getCaCert()
AhaApi.iterPoolTopo()
AhaApi.modAhaSvcInfo()
AhaApi.signHostCsr()
AhaApi.signUserCsr()
AhaCell
AhaCell.addAhaClone()
AhaCell.addAhaPool()
AhaCell.addAhaPoolSvc()
AhaCell.addAhaServer()
AhaCell.addAhaSvc()
AhaCell.addAhaSvcProv()
AhaCell.addAhaUserEnroll()
AhaCell.cellapi
AhaCell.clearAhaClones()
AhaCell.clearAhaSvcProvs()
AhaCell.clearAhaUserEnrolls()
AhaCell.confbase
AhaCell.confdefs
AhaCell.delAhaPool()
AhaCell.delAhaPoolSvc()
AhaCell.delAhaServer()
AhaCell.delAhaSvc()
AhaCell.delAhaSvcProv()
AhaCell.delAhaUserEnroll()
AhaCell.genCaCert()
AhaCell.getAhaClone()
AhaCell.getAhaPool()
AhaCell.getAhaPools()
AhaCell.getAhaServer()
AhaCell.getAhaServers()
AhaCell.getAhaSvc()
AhaCell.getAhaSvcMirrors()
AhaCell.getAhaSvcProv()
AhaCell.getAhaSvcs()
AhaCell.getAhaUrls()
AhaCell.getAhaUserEnroll()
AhaCell.getCaCert()
AhaCell.getEnvPrefix()
AhaCell.getMyUrl()
AhaCell.initServiceNetwork()
AhaCell.initServiceRuntime()
AhaCell.initServiceStorage()
AhaCell.iterPoolTopo()
AhaCell.modAhaSvcInfo()
AhaCell.saveCaCert()
AhaCell.saveHostCert()
AhaCell.saveUserCert()
AhaCell.setAhaSvcDown()
AhaCell.signHostCsr()
AhaCell.signUserCsr()
AhaProvisionServiceV1
AhaServicesV1
CloneApi
EnrollApi
ProvApi
ProvDmon
- synapse.lib.ast module
AbsPropCond
AndCond
ArgvQuery
ArrayCond
AstNode
AstNode.addExcInfo()
AstNode.addKid()
AstNode.format()
AstNode.getAstText()
AstNode.getPosInfo()
AstNode.getRuntVars()
AstNode.hasAstClass()
AstNode.hasVarName()
AstNode.init()
AstNode.isRuntSafe()
AstNode.isRuntSafeAtom()
AstNode.iterright()
AstNode.optimize()
AstNode.prepare()
AstNode.repr()
AstNode.reqRuntSafe()
AstNode.runtopaque
AstNode.sibling()
AstNode.validate()
Bool
BreakOper
CallArgs
CallKwarg
CallKwargs
CaseEntry
CatchBlock
CmdOper
Cmpr
Cond
Const
ContinueOper
DollarExpr
Edit
EditEdgeAdd
EditEdgeDel
EditNodeAdd
EditParens
EditPropDel
EditPropSet
EditTagAdd
EditTagDel
EditTagPropDel
EditTagPropSet
EditUnivDel
EmbedQuery
Emit
EmptyBlock
ExprAndNode
ExprDict
ExprList
ExprNode
ExprOrNode
FiltByArray
FiltOper
FiniBlock
ForLoop
FormName
FormPivot
FormTagProp
FormatString
FuncArgs
FuncCall
Function
HasAbsPropCond
HasRelPropCond
HasTagPropCond
IfClause
IfStmt
InitBlock
LiftByArray
LiftFormTag
LiftFormTagProp
LiftOper
LiftProp
LiftPropBy
LiftTag
LiftTagProp
LiftTagTag
List
LookList
Lookup
N1Walk
N1WalkNPivo
N2Walk
N2WalkNPivo
NotCond
Oper
OrCond
PivotIn
PivotInFrom
PivotOper
PivotOut
PivotToTags
PropName
PropPivot
PropPivotOut
PropValue
Query
RawPivot
RelProp
RelPropCond
RelPropValue
Return
Search
SetItemOper
SetVarOper
Stop
SubGraph
SubQuery
SubqCond
SwitchCase
TagCond
TagMatch
TagName
TagProp
TagPropCond
TagPropValue
TagValuCond
TagValue
TryCatch
UnaryExprNode
UnivProp
UnivPropValue
Value
VarDeref
VarEvalOper
VarList
VarListSetOper
VarValue
WhileLoop
YieldValu
expr_add()
expr_div()
expr_eq()
expr_ge()
expr_gt()
expr_le()
expr_lt()
expr_mod()
expr_mul()
expr_ne()
expr_neg()
expr_not()
expr_pow()
expr_prefix()
expr_re()
expr_sub()
parseNumber()
pullone()
- synapse.lib.auth module
Auth
Auth.addAuthGate()
Auth.addRole()
Auth.addUser()
Auth.checkUserLimit()
Auth.delAuthGate()
Auth.delRole()
Auth.delUser()
Auth.feedBeholder()
Auth.getAuthGate()
Auth.getAuthGates()
Auth.getRoleByName()
Auth.getUserByName()
Auth.getUserIdenByName()
Auth.popUserProfileValu()
Auth.popUserVarValu()
Auth.reqAuthGate()
Auth.reqRole()
Auth.reqRoleByName()
Auth.reqUser()
Auth.reqUserByName()
Auth.reqUserByNameOrIden()
Auth.role()
Auth.roles()
Auth.setRoleInfo()
Auth.setRoleName()
Auth.setUserInfo()
Auth.setUserName()
Auth.setUserProfileValu()
Auth.setUserVarValu()
Auth.user()
Auth.users()
AuthGate
Role
Ruler
User
User.allow()
User.allowed()
User.clearAuthCache()
User.confirm()
User.genGateInfo()
User.getAllowedReason()
User.getRoles()
User.grant()
User.hasRole()
User.isAdmin()
User.isArchived()
User.isLocked()
User.pack()
User.popProfileValu()
User.popVarValu()
User.raisePermDeny()
User.reqAdmin()
User.revoke()
User.setAdmin()
User.setArchived()
User.setLocked()
User.setName()
User.setPasswd()
User.setProfileValu()
User.setRoles()
User.setVarValu()
User.tryPasswd()
getShadow()
textFromRule()
- synapse.lib.autodoc module
- synapse.lib.base module
Base
Base.addSignalHandlers()
Base.anit()
Base.dist()
Base.enter_context()
Base.fini()
Base.fire()
Base.incref()
Base.link()
Base.main()
Base.off()
Base.on()
Base.onWith()
Base.onfini()
Base.postAnit()
Base.schedCallSafe()
Base.schedCoro()
Base.schedCoroSafe()
Base.schedCoroSafePend()
Base.unlink()
Base.waiter()
Base.waitfini()
BaseRef
Waiter
main()
schedGenr()
- synapse.lib.boss module
- synapse.lib.cache module
- synapse.lib.cell module
Cell
Cell.BACKUP_SPAWN_TIMEOUT
Cell.COMMIT
Cell.FREE_SPACE_CHECK_FREQ
Cell.SYSCTL_CHECK_FREQ
Cell.SYSCTL_VALS
Cell.VERSION
Cell.VERSTRING
Cell.addActiveCoro()
Cell.addDriveItem()
Cell.addDrivePath()
Cell.addHealthFunc()
Cell.addHttpApi()
Cell.addHttpSess()
Cell.addHttpsPort()
Cell.addReloadableSystem()
Cell.addRole()
Cell.addRoleRule()
Cell.addSignalHandlers()
Cell.addUser()
Cell.addUserApiKey()
Cell.addUserRole()
Cell.addUserRule()
Cell.behold()
Cell.beholder()
Cell.cellapi
Cell.checkFreeSpace()
Cell.checkUserApiKey()
Cell.confbase
Cell.confdefs
Cell.configNexsVers()
Cell.cullNexsLog()
Cell.delActiveCoro()
Cell.delBackup()
Cell.delDriveData()
Cell.delDriveInfo()
Cell.delHttpSess()
Cell.delRole()
Cell.delRoleRule()
Cell.delUser()
Cell.delUserApiKey()
Cell.delUserRole()
Cell.delUserRule()
Cell.dyncall()
Cell.dyniter()
Cell.execmain()
Cell.feedBeholder()
Cell.fini()
Cell.genHttpSess()
Cell.genUserOnepass()
Cell.getAhaInfo()
Cell.getApiKeys()
Cell.getArgParser()
Cell.getAuthGate()
Cell.getAuthGates()
Cell.getAuthRoles()
Cell.getAuthUsers()
Cell.getBackupInfo()
Cell.getBackups()
Cell.getCachedSslCtx()
Cell.getCellApi()
Cell.getCellIden()
Cell.getCellInfo()
Cell.getCellNexsRoot()
Cell.getCellRunId()
Cell.getCellType()
Cell.getConfOpt()
Cell.getDmonSessions()
Cell.getDmonUser()
Cell.getDriveData()
Cell.getDriveDataVersions()
Cell.getDriveInfo()
Cell.getDriveKids()
Cell.getDrivePath()
Cell.getEnvPrefix()
Cell.getHealthCheck()
Cell.getHiveKey()
Cell.getHiveKeys()
Cell.getHttpSessDict()
Cell.getLocalProxy()
Cell.getLocalUrl()
Cell.getLogExtra()
Cell.getMirrorUrls()
Cell.getMyUrl()
Cell.getNexsIndx()
Cell.getNexusChanges()
Cell.getPermDef()
Cell.getPermDefs()
Cell.getReloadableSystems()
Cell.getRoleDef()
Cell.getRoleDefByName()
Cell.getRoleDefs()
Cell.getSpooledDict()
Cell.getSpooledSet()
Cell.getSystemInfo()
Cell.getTeleApi()
Cell.getTempDir()
Cell.getUserApiKey()
Cell.getUserDef()
Cell.getUserDefByName()
Cell.getUserDefs()
Cell.getUserName()
Cell.getUserProfInfo()
Cell.getUserProfile()
Cell.getUserVarValu()
Cell.handoff()
Cell.hasHttpSess()
Cell.initCellConf()
Cell.initCellStorage()
Cell.initFromArgv()
Cell.initNexusSubsystem()
Cell.initServiceActive()
Cell.initServiceEarly()
Cell.initServiceNetwork()
Cell.initServicePassive()
Cell.initServiceRuntime()
Cell.initServiceStorage()
Cell.initSslCtx()
Cell.isActiveCoro()
Cell.isCellActive()
Cell.isRoleAllowed()
Cell.isUserAllowed()
Cell.iterBackupArchive()
Cell.iterNewBackupArchive()
Cell.iterSlabData()
Cell.iterUserProfInfo()
Cell.iterUserVars()
Cell.kill()
Cell.listHiveKey()
Cell.listUserApiKeys()
Cell.loadHiveTree()
Cell.modCellConf()
Cell.modUserApiKey()
Cell.popCellConf()
Cell.popHiveKey()
Cell.popUserProfInfo()
Cell.popUserVarValu()
Cell.promote()
Cell.ps()
Cell.readyToMirror()
Cell.reload()
Cell.reqAhaProxy()
Cell.reqGateKeys()
Cell.rotateNexsLog()
Cell.runActiveTask()
Cell.runBackup()
Cell.saveHiveTree()
Cell.setCellActive()
Cell.setCellVers()
Cell.setDriveData()
Cell.setDriveInfoPath()
Cell.setDriveInfoPerm()
Cell.setHiveKey()
Cell.setHttpSessInfo()
Cell.setNexsIndx()
Cell.setNexsVers()
Cell.setRoleName()
Cell.setRoleRules()
Cell.setUserAdmin()
Cell.setUserArchived()
Cell.setUserEmail()
Cell.setUserLocked()
Cell.setUserName()
Cell.setUserPasswd()
Cell.setUserProfInfo()
Cell.setUserRoles()
Cell.setUserRules()
Cell.setUserVarValu()
Cell.sync()
Cell.trimNexsLog()
Cell.tryUserPasswd()
Cell.updateHttpSessInfo()
Cell.waitNexsOffs()
CellApi
CellApi.addAuthRole()
CellApi.addAuthRule()
CellApi.addRole()
CellApi.addRoleRule()
CellApi.addUser()
CellApi.addUserRole()
CellApi.addUserRule()
CellApi.allowed()
CellApi.behold()
CellApi.checkUserApiKey()
CellApi.cullNexsLog()
CellApi.delAuthRole()
CellApi.delAuthRule()
CellApi.delAuthUser()
CellApi.delBackup()
CellApi.delRole()
CellApi.delRoleRule()
CellApi.delUser()
CellApi.delUserRole()
CellApi.delUserRule()
CellApi.dyncall()
CellApi.dyniter()
CellApi.genUserOnepass()
CellApi.getAuthGate()
CellApi.getAuthGates()
CellApi.getAuthInfo()
CellApi.getAuthRoles()
CellApi.getAuthUsers()
CellApi.getBackupInfo()
CellApi.getBackups()
CellApi.getCellIden()
CellApi.getCellInfo()
CellApi.getCellRunId()
CellApi.getCellType()
CellApi.getCellUser()
CellApi.getDiagInfo()
CellApi.getDmonSessions()
CellApi.getGcInfo()
CellApi.getHealthCheck()
CellApi.getHiveKey()
CellApi.getHiveKeys()
CellApi.getMirrorUrls()
CellApi.getNexsIndx()
CellApi.getNexusChanges()
CellApi.getPermDef()
CellApi.getPermDefs()
CellApi.getReloadableSystems()
CellApi.getRoleDef()
CellApi.getRoleDefByName()
CellApi.getRoleDefs()
CellApi.getRoleInfo()
CellApi.getSystemInfo()
CellApi.getUserDef()
CellApi.getUserDefByName()
CellApi.getUserDefs()
CellApi.getUserInfo()
CellApi.getUserProfInfo()
CellApi.getUserProfile()
CellApi.handoff()
CellApi.initCellApi()
CellApi.isCellActive()
CellApi.isRoleAllowed()
CellApi.isUserAllowed()
CellApi.issue()
CellApi.iterBackupArchive()
CellApi.iterNewBackupArchive()
CellApi.kill()
CellApi.listHiveKey()
CellApi.popHiveKey()
CellApi.popUserProfInfo()
CellApi.promote()
CellApi.ps()
CellApi.readyToMirror()
CellApi.reload()
CellApi.rotateNexsLog()
CellApi.runBackup()
CellApi.runGcCollect()
CellApi.saveHiveTree()
CellApi.setAuthAdmin()
CellApi.setCellUser()
CellApi.setHiveKey()
CellApi.setRoleRules()
CellApi.setUserAdmin()
CellApi.setUserArchived()
CellApi.setUserEmail()
CellApi.setUserLocked()
CellApi.setUserPasswd()
CellApi.setUserProfInfo()
CellApi.setUserRoles()
CellApi.setUserRules()
CellApi.trimNexsLog()
CellApi.tryUserPasswd()
CellApi.waitNexsOffs()
SSLCTX_CACHE_SIZE
adminapi()
from_leader()
- synapse.lib.certdir module
CertDir
CertDir.addCertPath()
CertDir.delCertPath()
CertDir.genCaCert()
CertDir.genCaCrl()
CertDir.genClientCert()
CertDir.genCodeCert()
CertDir.genCrlPath()
CertDir.genHostCert()
CertDir.genHostCsr()
CertDir.genUserCert()
CertDir.genUserCsr()
CertDir.getCaCert()
CertDir.getCaCertBytes()
CertDir.getCaCertPath()
CertDir.getCaCerts()
CertDir.getCaKey()
CertDir.getCaKeyPath()
CertDir.getClientCert()
CertDir.getClientCertPath()
CertDir.getClientSSLContext()
CertDir.getCodeCert()
CertDir.getCodeCertPath()
CertDir.getCodeKey()
CertDir.getCodeKeyPath()
CertDir.getCrlPath()
CertDir.getHostCaPath()
CertDir.getHostCert()
CertDir.getHostCertHash()
CertDir.getHostCertPath()
CertDir.getHostCsrPath()
CertDir.getHostKey()
CertDir.getHostKeyPath()
CertDir.getServerSSLContext()
CertDir.getUserCaPath()
CertDir.getUserCert()
CertDir.getUserCertPath()
CertDir.getUserCsrPath()
CertDir.getUserForHost()
CertDir.getUserKey()
CertDir.getUserKeyPath()
CertDir.importFile()
CertDir.isCaCert()
CertDir.isClientCert()
CertDir.isCodeCert()
CertDir.isHostCert()
CertDir.isUserCert()
CertDir.loadCertByts()
CertDir.saveCaCertByts()
CertDir.saveCertPem()
CertDir.saveCodeCertBytes()
CertDir.saveHostCertByts()
CertDir.savePkeyPem()
CertDir.saveUserCertByts()
CertDir.selfSignCert()
CertDir.signCertAs()
CertDir.signHostCsr()
CertDir.signUserCsr()
CertDir.valCodeCert()
CertDir.valUserCert()
Crl
addCertPath()
delCertPath()
getCertDir()
getCertDirn()
getServerSSLContext()
iterFqdnUp()
- synapse.lib.chop module
- synapse.lib.cli module
- synapse.lib.cmd module
- synapse.lib.cmdr module
- synapse.lib.config module
- synapse.lib.const module
- synapse.lib.coro module
- synapse.lib.datfile module
- synapse.lib.drive module
Drive
Drive.addItemInfo()
Drive.delItemData()
Drive.delItemInfo()
Drive.getItemData()
Drive.getItemDataVersions()
Drive.getItemInfo()
Drive.getItemKids()
Drive.getItemPath()
Drive.getItemsByType()
Drive.getPathInfo()
Drive.getPathNorm()
Drive.getStepInfo()
Drive.getTypeSchema()
Drive.getTypeValidator()
Drive.hasItemInfo()
Drive.hasPathInfo()
Drive.reqFreeStep()
Drive.reqItemInfo()
Drive.reqTypeValidator()
Drive.reqValidData()
Drive.setItemData()
Drive.setItemPath()
Drive.setItemPerm()
Drive.setTypeSchema()
Drive.walkItemInfo()
Drive.walkPathInfo()
getVersIndx()
reqValidName()
- synapse.lib.dyndeps module
- synapse.lib.encoding module
- synapse.lib.gis module
- synapse.lib.grammar module
- synapse.lib.hashitem module
- synapse.lib.hashset module
- synapse.lib.health module
- synapse.lib.hive module
- synapse.lib.hiveauth module
Auth
Auth.addAuthGate()
Auth.addRole()
Auth.addUser()
Auth.checkUserLimit()
Auth.delAuthGate()
Auth.delRole()
Auth.delUser()
Auth.feedBeholder()
Auth.getAuthGate()
Auth.getAuthGates()
Auth.getRoleByName()
Auth.getUserByName()
Auth.getUserIdenByName()
Auth.reqAuthGate()
Auth.reqRole()
Auth.reqRoleByName()
Auth.reqUser()
Auth.reqUserByName()
Auth.reqUserByNameOrIden()
Auth.role()
Auth.roles()
Auth.setRoleInfo()
Auth.setRoleName()
Auth.setUserInfo()
Auth.setUserName()
Auth.user()
Auth.users()
AuthGate
HiveRole
HiveRuler
HiveUser
HiveUser.allow()
HiveUser.allowed()
HiveUser.clearAuthCache()
HiveUser.confirm()
HiveUser.genGateInfo()
HiveUser.getAllowedReason()
HiveUser.getRoles()
HiveUser.grant()
HiveUser.hasRole()
HiveUser.isAdmin()
HiveUser.isArchived()
HiveUser.isLocked()
HiveUser.pack()
HiveUser.raisePermDeny()
HiveUser.reqAdmin()
HiveUser.revoke()
HiveUser.setAdmin()
HiveUser.setArchived()
HiveUser.setLocked()
HiveUser.setName()
HiveUser.setPasswd()
HiveUser.setRoles()
HiveUser.tryPasswd()
getShadow()
textFromRule()
- synapse.lib.httpapi module
ActiveV1
AuthAddRoleV1
AuthAddUserV1
AuthDelRoleV1
AuthGrantV1
AuthRevokeV1
AuthRoleV1
AuthRolesV1
AuthUserPasswdV1
AuthUserV1
AuthUsersV1
BeholdSockV1
CoreInfoV1
ExtApiHandler
FeedV1
Handler
HandlerBase
HandlerBase.allowed()
HandlerBase.authenticated()
HandlerBase.check_origin()
HandlerBase.getAuthCell()
HandlerBase.getCustomHeaders()
HandlerBase.getJsonBody()
HandlerBase.getUseridenBody()
HandlerBase.handleApiKeyAuth()
HandlerBase.handleBasicAuth()
HandlerBase.initialize()
HandlerBase.isOrigHost()
HandlerBase.isUserAdmin()
HandlerBase.loadJsonMesg()
HandlerBase.logAuthIssue()
HandlerBase.options()
HandlerBase.reqAuthAdmin()
HandlerBase.reqAuthUser()
HandlerBase.sendAuthRequired()
HandlerBase.sendRestErr()
HandlerBase.sendRestExc()
HandlerBase.sendRestRetn()
HandlerBase.sess()
HandlerBase.set_default_headers()
HandlerBase.useriden()
HealthCheckV1
LoginV1
LogoutV1
ModelNormV1
ModelV1
OnePassIssueV1
ReqValidStormV1
RobotHandler
Sess
StormCallV1
StormExportV1
StormHandler
StormNodesV1
StormV1
StormVarsGetV1
StormVarsPopV1
StormVarsSetV1
StreamHandler
WebSocket
- synapse.lib.ingest module
- synapse.lib.interval module
- synapse.lib.jsonstor module
JsonStor
JsonStor.cmpDelPathObjProp()
JsonStor.copyPathObj()
JsonStor.copyPathObjs()
JsonStor.delPathObj()
JsonStor.delPathObjProp()
JsonStor.getPathList()
JsonStor.getPathObj()
JsonStor.getPathObjProp()
JsonStor.getPathObjs()
JsonStor.hasPathObj()
JsonStor.popPathObjProp()
JsonStor.setPathLink()
JsonStor.setPathObj()
JsonStor.setPathObjProp()
JsonStorApi
JsonStorApi.addQueue()
JsonStorApi.addUserNotif()
JsonStorApi.cmpDelPathObjProp()
JsonStorApi.copyPathObj()
JsonStorApi.copyPathObjs()
JsonStorApi.cullQueue()
JsonStorApi.delPathObj()
JsonStorApi.delPathObjProp()
JsonStorApi.delQueue()
JsonStorApi.delUserNotif()
JsonStorApi.getPathList()
JsonStorApi.getPathObj()
JsonStorApi.getPathObjProp()
JsonStorApi.getPathObjs()
JsonStorApi.getUserNotif()
JsonStorApi.getsQueue()
JsonStorApi.hasPathObj()
JsonStorApi.iterUserNotifs()
JsonStorApi.popPathObjProp()
JsonStorApi.putsQueue()
JsonStorApi.setPathLink()
JsonStorApi.setPathObj()
JsonStorApi.setPathObjProp()
JsonStorApi.watchAllUserNotifs()
JsonStorCell
JsonStorCell.addQueue()
JsonStorCell.addUserNotif()
JsonStorCell.cellapi
JsonStorCell.cmpDelPathObjProp()
JsonStorCell.copyPathObj()
JsonStorCell.copyPathObjs()
JsonStorCell.cullQueue()
JsonStorCell.delPathObj()
JsonStorCell.delPathObjProp()
JsonStorCell.delQueue()
JsonStorCell.delUserNotif()
JsonStorCell.getEnvPrefix()
JsonStorCell.getPathList()
JsonStorCell.getPathObj()
JsonStorCell.getPathObjProp()
JsonStorCell.getPathObjs()
JsonStorCell.getUserNotif()
JsonStorCell.getsQueue()
JsonStorCell.hasPathObj()
JsonStorCell.initServiceStorage()
JsonStorCell.iterUserNotifs()
JsonStorCell.popPathObjProp()
JsonStorCell.putsQueue()
JsonStorCell.setPathLink()
JsonStorCell.setPathObj()
JsonStorCell.setPathObjProp()
JsonStorCell.watchAllUserNotifs()
- synapse.lib.layer module
IndxBy
IndxBy.buidsByDups()
IndxBy.buidsByPref()
IndxBy.buidsByRange()
IndxBy.buidsByRangeBack()
IndxBy.getNodeValu()
IndxBy.hasIndxBuid()
IndxBy.keyBuidsByDups()
IndxBy.keyBuidsByDupsBack()
IndxBy.keyBuidsByPref()
IndxBy.keyBuidsByPrefBack()
IndxBy.keyBuidsByRange()
IndxBy.keyBuidsByRangeBack()
IndxBy.scanByDups()
IndxBy.scanByPref()
IndxBy.scanByPrefBack()
IndxBy.scanByRange()
IndxBy.scanByRangeBack()
IndxByForm
IndxByProp
IndxByPropArray
IndxByTag
IndxByTagProp
Layer
Layer.clone()
Layer.confirmLayerEditPerms()
Layer.delete()
Layer.getAbrvProp()
Layer.getEdgeVerbs()
Layer.getEdges()
Layer.getEditIndx()
Layer.getEditOffs()
Layer.getEditSize()
Layer.getFormCounts()
Layer.getFormProps()
Layer.getIdenFutu()
Layer.getLayerSize()
Layer.getMirrorStatus()
Layer.getModelVers()
Layer.getNdefRefs()
Layer.getNodeData()
Layer.getNodeEditWindow()
Layer.getNodeForm()
Layer.getNodeTag()
Layer.getNodeValu()
Layer.getPropAbrv()
Layer.getPropArrayCount()
Layer.getPropArrayValuCount()
Layer.getPropCount()
Layer.getPropValuCount()
Layer.getStorIndx()
Layer.getStorNode()
Layer.getStorNodeCount()
Layer.getStorNodes()
Layer.getStorNodesByForm()
Layer.getTagCount()
Layer.getTagPropAbrv()
Layer.getTagPropCount()
Layer.getTagPropValuCount()
Layer.getTagProps()
Layer.getUnivPropCount()
Layer.hasNodeData()
Layer.hasNodeEdge()
Layer.hasTagProp()
Layer.initLayerActive()
Layer.initLayerPassive()
Layer.initUpstreamSync()
Layer.iterEdgeVerbs()
Layer.iterFormRows()
Layer.iterLayerNodeEdits()
Layer.iterNodeData()
Layer.iterNodeDataKeys()
Layer.iterNodeEdgeVerbsN1()
Layer.iterNodeEdgesN1()
Layer.iterNodeEdgesN2()
Layer.iterNodeEditLog()
Layer.iterNodeEditLogBack()
Layer.iterPropIndxBuids()
Layer.iterPropRows()
Layer.iterPropValues()
Layer.iterTagPropRows()
Layer.iterTagRows()
Layer.iterUnivRows()
Layer.iterWipeNodeEdits()
Layer.liftByDataName()
Layer.liftByFormValu()
Layer.liftByProp()
Layer.liftByPropArray()
Layer.liftByPropValu()
Layer.liftByTag()
Layer.liftByTagProp()
Layer.liftByTagPropValu()
Layer.liftByTagValu()
Layer.liftByTags()
Layer.liftTagProp()
Layer.mayDelBuid()
Layer.nodeeditctor
Layer.pack()
Layer.saveNodeEdits()
Layer.setLayerInfo()
Layer.setModelVers()
Layer.setPropAbrv()
Layer.setSodeDirty()
Layer.setTagPropAbrv()
Layer.stat()
Layer.storNodeEdits()
Layer.storNodeEditsNoLift()
Layer.syncIndexEvents()
Layer.syncNodeEdits()
Layer.syncNodeEdits2()
Layer.verify()
Layer.verifyAllBuids()
Layer.verifyAllProps()
Layer.verifyAllTagProps()
Layer.verifyAllTags()
Layer.verifyBuidTag()
Layer.verifyByBuid()
Layer.verifyByProp()
Layer.verifyByPropArray()
Layer.verifyByTag()
Layer.verifyByTagProp()
Layer.waitEditOffs()
Layer.waitForHot()
Layer.waitUpstreamOffs()
LayerApi
StorType
StorTypeFloat
StorTypeFqdn
StorTypeGuid
StorTypeHier
StorTypeHugeNum
StorTypeInt
StorTypeIpv6
StorTypeIval
StorTypeLatLon
StorTypeLoc
StorTypeMsgp
StorTypeNdef
StorTypeTag
StorTypeTime
StorTypeUtf8
getFlatEdits()
- synapse.lib.link module
- synapse.lib.lmdbslab module
GuidStor
Hist
HotCount
HotKeyVal
LmdbBackup
MultiQueue
SafeKeyVal
Scan
ScanBack
ScanKeys
Slab
Slab.COMMIT_PERIOD
Slab.DEFAULT_GROWSIZE
Slab.DEFAULT_MAPSIZE
Slab.WARN_COMMIT_TIME_MS
Slab.addResizeCallback()
Slab.allslabs
Slab.copydb()
Slab.copyslab()
Slab.count()
Slab.countByPref()
Slab.dbexists()
Slab.delete()
Slab.dropdb()
Slab.fini()
Slab.firstkey()
Slab.forcecommit()
Slab.get()
Slab.getHotCount()
Slab.getMultiQueue()
Slab.getNameAbrv()
Slab.getSafeKeyVal()
Slab.getSeqn()
Slab.getSlabStats()
Slab.getSlabsInDir()
Slab.has()
Slab.hasdup()
Slab.initSyncLoop()
Slab.initdb()
Slab.last()
Slab.lastkey()
Slab.pop()
Slab.prefexists()
Slab.put()
Slab.putmulti()
Slab.rangeexists()
Slab.replace()
Slab.scanByDups()
Slab.scanByDupsBack()
Slab.scanByFull()
Slab.scanByFullBack()
Slab.scanByPref()
Slab.scanByPrefBack()
Slab.scanByRange()
Slab.scanByRangeBack()
Slab.scanKeys()
Slab.scanKeysByPref()
Slab.stat()
Slab.statinfo()
Slab.sync()
Slab.syncLoopOnce()
Slab.syncLoopTask()
Slab.syncevnt
Slab.synctask
Slab.trash()
SlabAbrv
SlabDict
- synapse.lib.modelrev module
ModelRev
ModelRev.revCoreLayers()
ModelRev.revModel20210126()
ModelRev.revModel20210312()
ModelRev.revModel20210528()
ModelRev.revModel20210801()
ModelRev.revModel20211112()
ModelRev.revModel20220307()
ModelRev.revModel20220315()
ModelRev.revModel20220509()
ModelRev.revModel20220706()
ModelRev.revModel20220803()
ModelRev.revModel20220901()
ModelRev.revModel20221025()
ModelRev.revModel20221123()
ModelRev.revModel20221212()
ModelRev.revModel20221220()
ModelRev.revModel20230209()
ModelRev.revModel_0_2_18()
ModelRev.revModel_0_2_19()
ModelRev.revModel_0_2_20()
ModelRev.revModel_0_2_21()
ModelRev.revModel_0_2_22()
ModelRev.revModel_0_2_23()
ModelRev.revModel_0_2_24()
ModelRev.revModel_0_2_25()
ModelRev.revModel_0_2_26()
ModelRev.revModel_0_2_27()
ModelRev.revModel_0_2_28()
ModelRev.revModel_0_2_29()
ModelRev.revModel_0_2_30()
ModelRev.runStorm()
- synapse.lib.module module
- synapse.lib.modules module
- synapse.lib.msgpack module
- synapse.lib.multislabseqn module
- synapse.lib.nexus module
ChangeDist
NexsRoot
NexsRoot.addWriteHold()
NexsRoot.cull()
NexsRoot.delWriteHold()
NexsRoot.eat()
NexsRoot.enNexsLog()
NexsRoot.getChangeDist()
NexsRoot.getNexsKids()
NexsRoot.index()
NexsRoot.isNexsReady()
NexsRoot.issue()
NexsRoot.iter()
NexsRoot.promote()
NexsRoot.recover()
NexsRoot.reqNotReadOnly()
NexsRoot.rotate()
NexsRoot.runMirrorLoop()
NexsRoot.setNexsReady()
NexsRoot.setindex()
NexsRoot.startup()
NexsRoot.waitOffs()
Pusher
RegMethType
- synapse.lib.node module
Node
Node.addEdge()
Node.addTag()
Node.delEdge()
Node.delTag()
Node.delTagProp()
Node.delete()
Node.filter()
Node.get()
Node.getByLayer()
Node.getData()
Node.getEmbeds()
Node.getNodeRefs()
Node.getStorNodes()
Node.getTag()
Node.getTagProp()
Node.getTagProps()
Node.getTags()
Node.has()
Node.hasData()
Node.hasTag()
Node.hasTagProp()
Node.iden()
Node.iterData()
Node.iterDataKeys()
Node.iterEdgeVerbs()
Node.iterEdgesN1()
Node.iterEdgesN2()
Node.pack()
Node.pop()
Node.popData()
Node.repr()
Node.reprs()
Node.set()
Node.setData()
Node.setTagProp()
Node.storm()
Node.tagpropreprs()
Path
iden()
ndef()
prop()
props()
reprNdef()
reprProp()
reprTag()
reprTagProps()
tagged()
tags()
tagsnice()
- synapse.lib.oauth module
- synapse.lib.output module
- synapse.lib.parser module
AstConverter
AstConverter.caseentry()
AstConverter.cmdrargs()
AstConverter.embedquery()
AstConverter.evalvalu()
AstConverter.exprdict()
AstConverter.exprlist()
AstConverter.funcargs()
AstConverter.funccall()
AstConverter.liftreverse()
AstConverter.metaToAstInfo()
AstConverter.operrelprop_join()
AstConverter.operrelprop_pivot()
AstConverter.raiseBadSyntax()
AstConverter.stormcmdargs()
AstConverter.subquery()
AstConverter.switchcase()
AstConverter.varderef()
AstConverter.varlist()
AstConverter.yieldvalu()
AstInfo
CmdStringer
Parser
format_unescape()
massage_vartokn()
parseEval()
parseQuery()
parse_cmd_string()
unescape()
- synapse.lib.queue module
- synapse.lib.ratelimit module
- synapse.lib.reflect module
- synapse.lib.rstorm module
- synapse.lib.schemas module
- synapse.lib.scope module
- synapse.lib.scrape module
- synapse.lib.share module
- synapse.lib.slaboffs module
- synapse.lib.slabseqn module
SlabSeqn
SlabSeqn.add()
SlabSeqn.aiter()
SlabSeqn.cull()
SlabSeqn.first()
SlabSeqn.get()
SlabSeqn.getByIndxByts()
SlabSeqn.getOffsetEvent()
SlabSeqn.getraw()
SlabSeqn.gets()
SlabSeqn.index()
SlabSeqn.iter()
SlabSeqn.iterBack()
SlabSeqn.last()
SlabSeqn.nextindx()
SlabSeqn.pop()
SlabSeqn.rows()
SlabSeqn.save()
SlabSeqn.slice()
SlabSeqn.sliceBack()
SlabSeqn.stat()
SlabSeqn.trim()
SlabSeqn.waitForOffset()
- synapse.lib.snap module
ProtoNode
ProtoNode.addEdge()
ProtoNode.addTag()
ProtoNode.delEdge()
ProtoNode.get()
ProtoNode.getData()
ProtoNode.getNodeEdit()
ProtoNode.getSetOps()
ProtoNode.getTag()
ProtoNode.getTagProp()
ProtoNode.hasData()
ProtoNode.hasTagProp()
ProtoNode.iden()
ProtoNode.set()
ProtoNode.setData()
ProtoNode.setTagProp()
Scrubber
Snap
Snap.addFeedData()
Snap.addFeedNodes()
Snap.addNode()
Snap.addNodes()
Snap.addStormRuntime()
Snap.applyNodeEdit()
Snap.applyNodeEdits()
Snap.buidcachesize
Snap.clearCache()
Snap.clearCachedNode()
Snap.eval()
Snap.getEditor()
Snap.getNdefRefs()
Snap.getNodeByBuid()
Snap.getNodeByNdef()
Snap.getNodeData()
Snap.getNodeEditor()
Snap.getRuntNodes()
Snap.getSnapMeta()
Snap.getStormRuntime()
Snap.getTagNode()
Snap.getTagNorm()
Snap.hasNodeData()
Snap.hasNodeEdge()
Snap.iterEdgeVerbs()
Snap.iterNodeData()
Snap.iterNodeDataKeys()
Snap.iterNodeEdgesN1()
Snap.iterNodeEdgesN2()
Snap.iterStormPodes()
Snap.keepalive()
Snap.nodes()
Snap.nodesByDataName()
Snap.nodesByProp()
Snap.nodesByPropArray()
Snap.nodesByPropTypeValu()
Snap.nodesByPropValu()
Snap.nodesByTag()
Snap.nodesByTagProp()
Snap.nodesByTagPropValu()
Snap.nodesByTagValu()
Snap.printf()
Snap.saveNodeEdits()
Snap.storm()
Snap.tagcachesize
Snap.warn()
Snap.warnonce()
SnapEditor
- synapse.lib.spooled module
- synapse.lib.storm module
BackgroundCmd
BatchCmd
Cmd
CopyToCmd
CountCmd
DelNodeCmd
DiffCmd
DivertCmd
DmonManager
EdgesDelCmd
GraphCmd
HelpCmd
IdenCmd
IntersectCmd
LiftByVerb
LimitCmd
MaxCmd
MergeCmd
MinCmd
MoveNodesCmd
MoveTagCmd
OnceCmd
ParallelCmd
Parser
PureCmd
ReIndexCmd
RunAsCmd
Runtime
Runtime.addInput()
Runtime.allowed()
Runtime.allowedEasyPerm()
Runtime.allowedReason()
Runtime.cancel()
Runtime.confirm()
Runtime.confirmEasyPerm()
Runtime.confirmPropDel()
Runtime.confirmPropSet()
Runtime.coreDynCall()
Runtime.dyncall()
Runtime.dyniter()
Runtime.emit()
Runtime.emitter()
Runtime.execute()
Runtime.getCmdRuntime()
Runtime.getGraph()
Runtime.getInput()
Runtime.getModRuntime()
Runtime.getOneNode()
Runtime.getOpt()
Runtime.getScopeVars()
Runtime.getStormQuery()
Runtime.getSubRuntime()
Runtime.getTeleProxy()
Runtime.getVar()
Runtime.initPath()
Runtime.initSubRuntime()
Runtime.isAdmin()
Runtime.isRuntVar()
Runtime.layerConfirm()
Runtime.popVar()
Runtime.printf()
Runtime.reqAdmin()
Runtime.reqGateKeys()
Runtime.reqUserCanReadLayer()
Runtime.setGraph()
Runtime.setOpt()
Runtime.setVar()
Runtime.storm()
Runtime.tick()
Runtime.warn()
Runtime.warnonce()
ScrapeCmd
SleepCmd
SpinCmd
StormDmon
TagPruneCmd
TeeCmd
TreeCmd
UniqCmd
ViewExecCmd
- synapse.lib.storm_format module
- synapse.lib.stormctrl module
- synapse.lib.stormhttp module
- synapse.lib.stormsvc module
- synapse.lib.stormtypes module
Bool
Bytes
CmdOpts
CronJob
Dict
Layer
Lib
LibAxon
LibBase
LibBase64
LibBytes
LibCron
LibCsv
LibDict
LibDmon
LibExport
LibFeed
LibGlobals
LibJsonStor
LibLayer
LibLift
LibPipe
LibPkg
LibPs
LibQueue
LibRegx
LibService
LibStr
LibTags
LibTelepath
LibTime
LibTrigger
LibVars
LibView
List
Node
NodeData
NodeProps
Number
Path
PathMeta
PathVars
Pipe
Prim
Proxy
ProxyGenrMethod
ProxyMethod
Query
Queue
Service
Set
StormHiveDict
StormType
StormTypesRegistry
StormTypesRegistry.addStormLib()
StormTypesRegistry.addStormType()
StormTypesRegistry.base_undefined_types
StormTypesRegistry.delStormLib()
StormTypesRegistry.delStormType()
StormTypesRegistry.getLibDocs()
StormTypesRegistry.getTypeDocs()
StormTypesRegistry.iterLibs()
StormTypesRegistry.iterTypes()
StormTypesRegistry.known_types
StormTypesRegistry.registerLib()
StormTypesRegistry.registerType()
StormTypesRegistry.rtypes
StormTypesRegistry.undefined_types
Str
Text
Trigger
Undef
View
View.addNode()
View.delMergeRequest()
View.delMergeVote()
View.detach()
View.getMergeRequest()
View.getMergeRequestSummary()
View.getMerges()
View.getMergingViews()
View.getObjLocals()
View.setMergeComment()
View.setMergeRequest()
View.setMergeVote()
View.setMergeVoteComment()
View.viewDynCall()
View.viewDynIter()
allowed()
allowedEasyPerm()
confirm()
confirmEasyPerm()
fromprim()
getCallSig()
getDoc()
intify()
ismutable()
kwarg_format()
stormfunc()
tobool()
tobuidhex()
tocmprvalu()
toint()
toiter()
tonumber()
toprim()
torepr()
tostor()
tostr()
totype()
typeerr()
- synapse.lib.stormwhois module
- synapse.lib.structlog module
- synapse.lib.task module
- synapse.lib.thishost module
- synapse.lib.thisplat module
- synapse.lib.threads module
- synapse.lib.time module
- synapse.lib.trigger module
- synapse.lib.types module
Array
Bool
Comp
Data
Duration
Edge
FieldHelper
Float
Guid
Hex
HugeNum
Int
IntBase
Ival
Loc
Ndef
NodeProp
Range
Str
Tag
TagPart
Taxon
Taxonomy
Time
TimeEdge
Type
Type.clone()
Type.cmpr()
Type.extend()
Type.getCmprCtor()
Type.getCompOffs()
Type.getLiftHintCmpr()
Type.getLiftHintCmprCtor()
Type.getStorCmprs()
Type.getStorNode()
Type.getTypeDef()
Type.getTypeVals()
Type.isarray
Type.merge()
Type.norm()
Type.pack()
Type.postTypeInit()
Type.repr()
Type.setCmprCtor()
Type.setLiftHintCmprCtor()
Type.setNormFunc()
Type.stortype
Velocity
- synapse.lib.urlhelp module
- synapse.lib.version module
- synapse.lib.view module
View
View.addLayer()
View.addNode()
View.addNodeEdits()
View.addTrigQueue()
View.addTrigger()
View.callStorm()
View.callStormIface()
View.delMergeRequest()
View.delMergeVote()
View.delTrigQueue()
View.delTrigger()
View.delete()
View.detach()
View.eval()
View.finiMergeTask()
View.finiTrigTask()
View.fork()
View.getEdgeVerbs()
View.getEdges()
View.getFormCounts()
View.getMergeRequest()
View.getMergeVotes()
View.getMerges()
View.getMergingViews()
View.getPropArrayCount()
View.getPropCount()
View.getStorNodes()
View.getTagPropCount()
View.getTrigger()
View.hasKids()
View.init2()
View.initMergeTask()
View.initTrigTask()
View.insertParentFork()
View.isForkOf()
View.isMergeReady()
View.isafork()
View.iterPropValues()
View.iterStormPodes()
View.listTriggers()
View.merge()
View.mergeAllowed()
View.mergeStormIface()
View.nodes()
View.pack()
View.reqNoParentQuorum()
View.reqParentQuorum()
View.reqValidVoter()
View.runEdgeAdd()
View.runEdgeDel()
View.runNodeAdd()
View.runNodeDel()
View.runPropSet()
View.runTagAdd()
View.runTagDel()
View.runViewMerge()
View.scrapeIface()
View.setLayers()
View.setMergeComment()
View.setMergeRequest()
View.setMergeVote()
View.setMergeVoteComment()
View.setTriggerInfo()
View.setViewInfo()
View.snap()
View.snapctor()
View.storNodeEdits()
View.storm()
View.stormlist()
View.swapLayer()
View.tryToMerge()
View.wipeAllowed()
View.wipeLayer()
ViewApi
- Subpackages
- synapse.lookup package
- synapse.models package
- Subpackages
- Submodules
- synapse.models.auth module
- synapse.models.base module
- synapse.models.belief module
- synapse.models.biz module
- synapse.models.crypto module
- synapse.models.dns module
- synapse.models.economic module
- synapse.models.entity module
- synapse.models.files module
- synapse.models.geopol module
- synapse.models.geospace module
- synapse.models.inet module
- synapse.models.infotech module
- synapse.models.language module
- synapse.models.material module
- synapse.models.math module
- synapse.models.media module
- synapse.models.orgs module
- synapse.models.person module
- synapse.models.planning module
- synapse.models.proj module
- synapse.models.risk module
- synapse.models.science module
- synapse.models.syn module
- synapse.models.telco module
- synapse.models.transport module
- synapse.servers package
- synapse.tests package
- Submodules
- synapse.tests.nopmod module
- synapse.tests.utils module
AsyncStreamEvent
CmdGenerator
DeprModule
HttpReflector
LibTst
PickleableMagicMock
ReloadCell
StormPkgTest
StreamEvent
SynTest
SynTest.addCreatorDeleterRoles()
SynTest.addSvcToAha()
SynTest.addSvcToCore()
SynTest.agenlen()
SynTest.agenraises()
SynTest.asyncraises()
SynTest.checkNode()
SynTest.checkNodes()
SynTest.eq()
SynTest.eqOrNan()
SynTest.eqish()
SynTest.execToolMain()
SynTest.extendOutpFromPatch()
SynTest.false()
SynTest.ge()
SynTest.genraises()
SynTest.getAsyncLoggerStream()
SynTest.getCellConf()
SynTest.getHttpSess()
SynTest.getLoggerStream()
SynTest.getMagicPromptColors()
SynTest.getMagicPromptLines()
SynTest.getRegrAxon()
SynTest.getRegrCore()
SynTest.getRegrDir()
SynTest.getStructuredAsyncLoggerStream()
SynTest.getTestAha()
SynTest.getTestAxon()
SynTest.getTestCell()
SynTest.getTestCertDir()
SynTest.getTestConfDir()
SynTest.getTestCore()
SynTest.getTestCoreAndProxy()
SynTest.getTestCoreProxSvc()
SynTest.getTestCryo()
SynTest.getTestCryoAndProxy()
SynTest.getTestDir()
SynTest.getTestDmon()
SynTest.getTestFilePath()
SynTest.getTestHive()
SynTest.getTestHiveDmon()
SynTest.getTestHiveFromDirn()
SynTest.getTestJsonStor()
SynTest.getTestOutp()
SynTest.getTestProxy()
SynTest.getTestReadWriteCores()
SynTest.getTestSynDir()
SynTest.getTestTeleHive()
SynTest.getTestUrl()
SynTest.gt()
SynTest.isin()
SynTest.isinstance()
SynTest.istufo()
SynTest.le()
SynTest.len()
SynTest.lt()
SynTest.mayTestDir()
SynTest.ne()
SynTest.nn()
SynTest.none()
SynTest.noprop()
SynTest.notin()
SynTest.printed()
SynTest.raises()
SynTest.redirectStdin()
SynTest.runCoreNodes()
SynTest.setSynDir()
SynTest.setTstEnvars()
SynTest.skip()
SynTest.skipIfNexusReplay()
SynTest.skipIfNoInternet()
SynTest.skipIfNoPath()
SynTest.skipLongTest()
SynTest.sorteq()
SynTest.stablebuid()
SynTest.stableguid()
SynTest.stormHasNoErr()
SynTest.stormHasNoWarnErr()
SynTest.stormIsInErr()
SynTest.stormIsInPrint()
SynTest.stormIsInWarn()
SynTest.stormNotInPrint()
SynTest.stormNotInWarn()
SynTest.thisHostMust()
SynTest.thisHostMustNot()
SynTest.true()
SynTest.withCliPromptMock()
SynTest.withCliPromptMockExtendOutp()
SynTest.withNexusReplay()
SynTest.withSetLoggingMock()
SynTest.withStableUids()
SynTest.withTestCmdr()
TestCmd
TestModule
TestRunt
TestSubType
TestType
ThreeType
TstEnv
TstOutPut
alist()
deguidify()
matchContexts()
norm()
waitForBehold()
- synapse.tools package
- Subpackages
- Submodules
- synapse.tools.autodoc module
- synapse.tools.axon2axon module
- synapse.tools.backup module
- synapse.tools.cellauth module
- synapse.tools.changelog module
- synapse.tools.cmdr module
- synapse.tools.csvtool module
- synapse.tools.easycert module
- synapse.tools.feed module
- synapse.tools.genpkg module
- synapse.tools.guid module
- synapse.tools.healthcheck module
- synapse.tools.json2mpk module
- synapse.tools.livebackup module
- synapse.tools.modrole module
- synapse.tools.moduser module
- synapse.tools.promote module
- synapse.tools.pullfile module
- synapse.tools.pushfile module
- synapse.tools.reload module
- synapse.tools.rstorm module
- synapse.tools.storm module
- synapse.utils package
Submodules
synapse.axon module
- class synapse.axon.Axon[source]
Bases:
Cell
- byterange = False
- confdefs = {'http:proxy': {'description': 'An aiohttp-socks compatible proxy URL to use in the wget API.', 'type': 'string'}, 'max:bytes': {'description': 'The maximum number of bytes that can be stored in the Axon.', 'hidecmdl': True, 'minimum': 1, 'type': 'integer'}, 'max:count': {'description': 'The maximum number of files that can be stored in the Axon.', 'hidecmdl': True, 'minimum': 1, 'type': 'integer'}, 'tls:ca:dir': {'description': 'An optional directory of CAs which are added to the TLS CA chain for wget and wput APIs.', 'type': 'string'}}
- async del_(sha256)[source]
Remove the given bytes from the Axon by sha256.
- Parameters:
sha256 (bytes) – The sha256, in bytes, to remove from the Axon.
- Returns:
True if the file is removed; false if the file is not present.
- Return type:
boolean
- async dels(sha256s)[source]
Given a list of sha256 hashes, delete the files from the Axon.
- Parameters:
sha256s (list) – A list of sha256 hashes in bytes form.
- Returns:
A list of booleans, indicating if the file was deleted or not.
- Return type:
list
- async get(sha256, offs=None, size=None)[source]
Get bytes of a file.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
offs (int) – The offset to start reading from.
size (int) – The total number of bytes to read.
Examples
Get the bytes from an Axon and process them:
buf = b'' async for bytz in axon.get(sha256): buf =+ bytz await dostuff(buf)
- Yields:
bytes – Chunks of the file bytes.
- Raises:
synapse.exc.NoSuchFile – If the file does not exist.
- async getCellInfo()[source]
Return metadata specific for the Cell.
Notes
By default, this function returns information about the base Cell implementation, which reflects the base information in the Synapse Cell.
It is expected that implementers override the following Class attributes in order to provide meaningful version information:
COMMIT
- A Git CommitVERSION
- A Version tuple.VERSTRING
- A Version string.- Returns:
A Dictionary of metadata.
- Return type:
- async has(sha256)[source]
Check if the Axon has a file.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
- Returns:
True if the Axon has the file; false otherwise.
- Return type:
boolean
- async hashes(offs, wait=False, timeout=None)[source]
Yield hash rows for files that exist in the Axon in added order starting at an offset.
- Parameters:
offs (int) – The index offset.
wait (boolean) – Wait for new results and yield them in realtime.
timeout (int) – Max time to wait for new results.
- Yields:
(int, (bytes, int)) – An index offset and the file SHA-256 and size.
Note
If the same hash was deleted and then added back, the same hash will be yielded twice.
- async hashset(sha256)[source]
Calculate additional hashes for a file in the Axon.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
- Returns:
A dictionary containing hashes of the file.
- Return type:
dict
- async history(tick, tock=None)[source]
Yield hash rows for files that existing in the Axon after a given point in time.
- Parameters:
tick (int) – The starting time (in epoch milliseconds).
tock (int) – The ending time to stop iterating at (in epoch milliseconds).
- Yields:
(int, (bytes, int)) – A tuple containing time of the hash was added and the file SHA-256 and size.
- holdHashLock(hashbyts)[source]
A context manager that synchronizes edit access to a blob.
- Parameters:
hashbyts (bytes) – The blob to hold the lock for.
- async iterMpkFile(sha256)[source]
Yield items from a MsgPack (.mpk) file in the Axon.
- Parameters:
sha256 (str) – The sha256 hash of the file as a string.
- Yields:
Unpacked items from the bytes.
- async metrics()[source]
Get the runtime metrics of the Axon.
- Returns:
A dictionary of runtime data about the Axon.
- Return type:
dict
- async postfiles(fields, url, params=None, headers=None, method='POST', ssl=True, timeout=None, proxy=None, ssl_opts=None)[source]
Send files from the axon as fields in a multipart/form-data HTTP request.
- Parameters:
fields (list) – List of dicts containing the fields to add to the request as form-data.
url (str) – The URL to retrieve.
params (dict) – Additional parameters to add to the URL.
headers (dict) – Additional HTTP headers to add in the request.
method (str) – The HTTP method to use.
ssl (bool) – Perform SSL verification.
timeout (int) – The timeout of the request, in seconds.
proxy (bool|str|null) – Use a specific proxy or disable proxy use.
ssl_opts (dict) – Additional SSL/TLS options.
Notes
The dictionaries in the fields list may contain the following values:
{ 'name': <str> - Name of the field. 'sha256': <str> - SHA256 hash of the file to submit for this field. 'value': <str> - Value for the field. Ignored if a sha256 has been specified. 'filename': <str> - Optional filename for the field. 'content_type': <str> - Optional content type for the field. 'content_transfer_encoding': <str> - Optional content-transfer-encoding header for the field. }
The ssl_opts dictionary may contain the following values:
{ 'verify': <bool> - Perform SSL/TLS verification. Is overridden by the ssl argument. 'client_cert': <str> - PEM encoded full chain certificate for use in mTLS. 'client_key': <str> - PEM encoded key for use in mTLS. Alternatively, can be included in client_cert. }
The dictionary returned by this may contain the following values:
{ 'ok': <boolean> - False if there were exceptions retrieving the URL. 'err': <tuple> - Tuple of the error type and information if an exception occurred. 'url': <str> - The URL retrieved (which could have been redirected) 'code': <int> - The response code. 'body': <bytes> - The response body. 'reason': <str> - The reason phrase for the HTTP status code. 'headers': <dict> - The response headers as a dictionary. }
- Returns:
An information dictionary containing the results of the request.
- Return type:
dict
- async put(byts)[source]
Store bytes in the Axon.
- Parameters:
byts (bytes) – The bytes to store in the Axon.
Notes
This API should not be used for files greater than 128 MiB in size.
- Returns:
A tuple with the file size and sha256 hash of the bytes.
- Return type:
tuple(int, bytes)
- async puts(files)[source]
Store a set of bytes in the Axon.
- Parameters:
files (list) – A list of bytes to store in the Axon.
Notes
This API should not be used for storing more than 128 MiB of bytes at once.
- Returns:
A list containing tuples of file size and sha256 hash of the saved bytes.
- Return type:
list(tuple(int, bytes))
- async save(sha256, genr, size)[source]
Save a generator of bytes to the Axon.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
genr – The bytes generator function.
- Returns:
The size of the bytes saved.
- Return type:
int
- async size(sha256)[source]
Get the size of a file in the Axon.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
- Returns:
The size of the file, in bytes. If not present, None is returned.
- Return type:
int
- async upload()[source]
Get an Upload object.
Notes
The UpLoad object should be used to manage uploads greater than 128 MiB in size.
Examples
Use an UpLoad object to upload a file to the Axon:
async with await axon.upload() as upfd: # Assumes bytesGenerator yields bytes async for byts in bytsgenerator(): await upfd.write(byts) await upfd.save()
Use a single UpLoad object to save multiple files:
async with await axon.upload() as upfd: for fp in file_paths: # Assumes bytesGenerator yields bytes async for byts in bytsgenerator(fp): await upfd.write(byts) await upfd.save()
- Returns:
An Upload manager object.
- Return type:
- async wants(sha256s)[source]
Get a list of sha256 values the axon does not have from a input list.
- Parameters:
sha256s (list) – A list of sha256 values as bytes.
- Returns:
A list of bytes containing the sha256 hashes the Axon does not have.
- Return type:
list
- async wget(url, params=None, headers=None, json=None, body=None, method='GET', ssl=True, timeout=None, proxy=None, ssl_opts=None)[source]
Stream a file download directly into the Axon.
- Parameters:
url (str) – The URL to retrieve.
params (dict) – Additional parameters to add to the URL.
headers (dict) – Additional HTTP headers to add in the request.
json – A JSON body which is included with the request.
body – The body to be included in the request.
method (str) – The HTTP method to use.
ssl (bool) – Perform SSL verification.
timeout (int) – The timeout of the request, in seconds.
proxy (bool|str|null) – Use a specific proxy or disable proxy use.
ssl_opts (dict) – Additional SSL/TLS options.
Notes
The response body will be stored, regardless of the response code. The
ok
value in the response does not reflect that a status code, such as a 404, was encountered when retrieving the URL.The ssl_opts dictionary may contain the following values:
{ 'verify': <bool> - Perform SSL/TLS verification. Is overridden by the ssl argument. 'client_cert': <str> - PEM encoded full chain certificate for use in mTLS. 'client_key': <str> - PEM encoded key for use in mTLS. Alternatively, can be included in client_cert. }
The dictionary returned by this may contain the following values:
{ 'ok': <boolean> - False if there were exceptions retrieving the URL. 'url': <str> - The URL retrieved (which could have been redirected). This is a url-decoded string. 'code': <int> - The response code. 'reason': <str> - The reason phrase for the HTTP status code. 'mesg': <str> - An error message if there was an exception when retrieving the URL. 'err': <tuple> - An error tuple if there was an exception when retrieving the URL. 'headers': <dict> - The response headers as a dictionary. 'size': <int> - The size in bytes of the response body. 'hashes': { 'md5': <str> - The MD5 hash of the response body. 'sha1': <str> - The SHA1 hash of the response body. 'sha256': <str> - The SHA256 hash of the response body. 'sha512': <str> - The SHA512 hash of the response body. }, 'request': { 'url': The request URL. This is a url-decoded string. 'headers': The request headers. 'method': The request method. } 'history': A sequence of response bodies to track any redirects, not including hashes. }
- Returns:
An information dictionary containing the results of the request.
- Return type:
dict
- class synapse.axon.AxonApi[source]
-
- async csvrows(sha256, dialect='excel', errors='ignore', **fmtparams)[source]
Yield CSV rows from a CSV file.
- Parameters:
sha256 (bytes) – The sha256 hash of the file.
dialect (str) – The CSV dialect to use.
errors (str) – Specify how encoding errors should handled.
**fmtparams – The CSV dialect format parameters.
Notes
The dialect and fmtparams expose the Python csv.reader() parameters.
Examples
Get the rows from a CSV file and process them:
async for row in axon.csvrows(sha256): await dostuff(row)
Get the rows from a tab separated file and process them:
async for row in axon.csvrows(sha256, delimiter=' '): await dostuff(row)
- Yields:
list – Decoded CSV rows.
- async del_(sha256)[source]
Remove the given bytes from the Axon by sha256.
- Parameters:
sha256 (bytes) – The sha256, in bytes, to remove from the Axon.
- Returns:
True if the file is removed; false if the file is not present.
- Return type:
boolean
- async dels(sha256s)[source]
Given a list of sha256 hashes, delete the files from the Axon.
- Parameters:
sha256s (list) – A list of sha256 hashes in bytes form.
- Returns:
A list of booleans, indicating if the file was deleted or not.
- Return type:
list
- async get(sha256, offs=None, size=None)[source]
Get bytes of a file.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
offs (int) – The offset to start reading from.
size (int) – The total number of bytes to read.
Examples
Get the bytes from an Axon and process them:
buf = b'' async for bytz in axon.get(sha256): buf += bytz await dostuff(buf)
- Yields:
bytes – Chunks of the file bytes.
- Raises:
synapse.exc.NoSuchFile – If the file does not exist.
- async has(sha256)[source]
Check if the Axon has a file.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
- Returns:
True if the Axon has the file; false otherwise.
- Return type:
boolean
- async hashes(offs, wait=False, timeout=None)[source]
Yield hash rows for files that exist in the Axon in added order starting at an offset.
- Parameters:
offs (int) – The index offset.
wait (boolean) – Wait for new results and yield them in realtime.
timeout (int) – Max time to wait for new results.
- Yields:
(int, (bytes, int)) – An index offset and the file SHA-256 and size.
- async hashset(sha256)[source]
Calculate additional hashes for a file in the Axon.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
- Returns:
A dictionary containing hashes of the file.
- Return type:
dict
- async history(tick, tock=None)[source]
Yield hash rows for files that existing in the Axon after a given point in time.
- Parameters:
tick (int) – The starting time (in epoch milliseconds).
tock (int) – The ending time to stop iterating at (in epoch milliseconds).
- Yields:
(int, (bytes, int)) – A tuple containing time of the hash was added and the file SHA-256 and size.
- async iterMpkFile(sha256)[source]
Yield items from a MsgPack (.mpk) file in the Axon.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
- Yields:
Unpacked items from the bytes.
- async jsonlines(sha256, errors='ignore')[source]
Yield JSON objects from JSONL (JSON lines) file.
- Parameters:
sha256 (bytes) – The sha256 hash of the file.
errors (str) – Specify how encoding errors should handled.
- Yields:
object – Decoded JSON objects.
- async metrics()[source]
Get the runtime metrics of the Axon.
- Returns:
A dictionary of runtime data about the Axon.
- Return type:
dict
- async postfiles(fields, url, params=None, headers=None, method='POST', ssl=True, timeout=None, proxy=None, ssl_opts=None)[source]
- async put(byts)[source]
Store bytes in the Axon.
- Parameters:
byts (bytes) – The bytes to store in the Axon.
Notes
This API should not be used for files greater than 128 MiB in size.
- Returns:
A tuple with the file size and sha256 hash of the bytes.
- Return type:
tuple(int, bytes)
- async puts(files)[source]
Store a set of bytes in the Axon.
- Parameters:
files (list) – A list of bytes to store in the Axon.
Notes
This API should not be used for storing more than 128 MiB of bytes at once.
- Returns:
A list containing tuples of file size and sha256 hash of the saved bytes.
- Return type:
list(tuple(int, bytes))
- async readlines(sha256, errors='ignore')[source]
Yield lines from a multi-line text file in the axon.
- Parameters:
sha256 (bytes) – The sha256 hash of the file.
errors (str) – Specify how encoding errors should handled.
- Yields:
str – Lines of text
- async size(sha256)[source]
Get the size of a file in the Axon.
- Parameters:
sha256 (bytes) – The sha256 hash of the file in bytes.
- Returns:
The size of the file, in bytes. If not present, None is returned.
- Return type:
int
- async upload()[source]
Get an Upload object.
Notes
The UpLoad object should be used to manage uploads greater than 128 MiB in size.
Examples
Use an UpLoad object to upload a file to the Axon:
async with axonProxy.upload() as upfd: # Assumes bytesGenerator yields bytes async for byts in bytsgenerator(): upfd.write(byts) upfd.save()
Use a single UpLoad object to save multiple files:
async with axonProxy.upload() as upfd: for fp in file_paths: # Assumes bytesGenerator yields bytes async for byts in bytsgenerator(fp): upfd.write(byts) upfd.save()
- Returns:
An Upload manager object.
- Return type:
- async wants(sha256s)[source]
Get a list of sha256 values the axon does not have from an input list.
- Parameters:
sha256s (list) – A list of sha256 values as bytes.
- Returns:
A list of bytes containing the sha256 hashes the Axon does not have.
- Return type:
list
- async wget(url, params=None, headers=None, json=None, body=None, method='GET', ssl=True, timeout=None, proxy=None, ssl_opts=None)[source]
Stream a file download directly into the Axon.
- Parameters:
url (str) – The URL to retrieve.
params (dict) – Additional parameters to add to the URL.
headers (dict) – Additional HTTP headers to add in the request.
json – A JSON body which is included with the request.
body – The body to be included in the request.
method (str) – The HTTP method to use.
ssl (bool) – Perform SSL verification.
timeout (int) – The timeout of the request, in seconds.
ssl_opts (dict) – Additional SSL/TLS options.
Notes
The response body will be stored, regardless of the response code. The
ok
value in the response does not reflect that a status code, such as a 404, was encountered when retrieving the URL.The ssl_opts dictionary may contain the following values:
{ 'verify': <bool> - Perform SSL/TLS verification. Is overridden by the ssl argument. 'client_cert': <str> - PEM encoded full chain certificate for use in mTLS. 'client_key': <str> - PEM encoded key for use in mTLS. Alternatively, can be included in client_cert. }
The dictionary returned by this may contain the following values:
{ 'ok': <boolean> - False if there were exceptions retrieving the URL. 'url': <str> - The URL retrieved (which could have been redirected). This is a url-decoded string. 'code': <int> - The response code. 'reason': <str> - The reason phrase for the HTTP status code. 'mesg': <str> - An error message if there was an exception when retrieving the URL. 'err': <tuple> - An error tuple if there was an exception when retrieving the URL. 'headers': <dict> - The response headers as a dictionary. 'size': <int> - The size in bytes of the response body. 'hashes': { 'md5': <str> - The MD5 hash of the response body. 'sha1': <str> - The SHA1 hash of the response body. 'sha256': <str> - The SHA256 hash of the response body. 'sha512': <str> - The SHA512 hash of the response body. }, 'request': { 'url': The request URL. This is a url-decoded string. 'headers': The request headers. 'method': The request method. } 'history': A sequence of response bodies to track any redirects, not including hashes. }
- Returns:
An information dictionary containing the results of the request.
- Return type:
dict
- class synapse.axon.AxonFileHandler(application: Application, request: HTTPServerRequest, **kwargs: Any)[source]
Bases:
AxonHandlerMixin
,Handler
- class synapse.axon.AxonHttpBySha256InvalidV1(application: Application, request: HTTPServerRequest, **kwargs: Any)[source]
Bases:
AxonFileHandler
- async get