def createTopic()

in aios/apps/facility/swift/py_tools/swift_tools/swift_admin_delegate.py [0:0]
86 lines of code
36 McCabe index (conditional complexity)

    def createTopic(self, topicName, partCnt, rangeCnt=None, partBufSize=None,
                    partMinBufSize=None, partMaxBufSize=None,
                    partResource=None, partLimit=None, topicMode=None,
                    needFieldFilter=None, obsoleteFileTimeInterval=None,
                    reservedFileCount=None, partFileBufSize=None,
                    deleteTopicData=None, securityCommitTime=None,
                    securityCommitData=None, compressMsg=None, compressThres=None,
                    dfsRoot=None, topicGroup=None, extendDfsRoot=None, expiredTime=None,
                    owners=None, needSchema=None, schemaVersions=None,
                    requestTimeout=None, sealed=None, topicType=None,
                    physicTopicLst=None, enableTTLDel=None, enableLongPolling=None,
                    versionControl=None, enableMergeData=None, permitUser=None, readNotCommmitMsg=None):
        request = swift_proto_admin.TopicCreationRequest()
        request.topicName = topicName
        request.partitionCount = partCnt
        if rangeCnt is not None:
            request.rangeCountInPartition = rangeCnt
        if partBufSize is not None:
            request.partitionBufferSize = partBufSize
        if partMinBufSize is not None:
            request.partitionMinBufferSize = partMinBufSize
        if partMaxBufSize is not None:
            request.partitionMaxBufferSize = partMaxBufSize
        if partResource is not None:
            request.resource = partResource
        if partLimit is not None:
            request.partitionLimit = partLimit
        if topicMode is not None:
            request.topicMode = topicMode
        if needFieldFilter is not None:
            request.needFieldFilter = needFieldFilter
        if obsoleteFileTimeInterval is not None:
            request.obsoleteFileTimeInterval = obsoleteFileTimeInterval
        if reservedFileCount is not None:
            request.reservedFileCount = reservedFileCount
        if partFileBufSize is not None:
            request.partitionFileBufferSize = partFileBufSize
        if deleteTopicData is not None:
            request.deleteTopicData = deleteTopicData
        if securityCommitTime is not None:
            request.maxWaitTimeForSecurityCommit = securityCommitTime
        if securityCommitData is not None:
            request.maxDataSizeForSecurityCommit = securityCommitData
        if compressMsg is not None:
            request.compressMsg = compressMsg
        if compressThres is not None:
            request.compressThres = compressThres
        if dfsRoot is not None:
            request.dfsRoot = dfsRoot
        if topicGroup is not None:
            request.topicGroup = topicGroup
        if extendDfsRoot is not None:
            dfsRoots = extendDfsRoot.split(',')
            for path in dfsRoots:
                request.extendDfsRoot.append(path)
        if expiredTime is not None:
            request.topicExpiredTime = expiredTime
        if owners is not None:
            request.owners.extend(owners.split(','))
        if needSchema is not None:
            request.needSchema = needSchema
            if schemaVersions is not None:
                versions = schemaVersions.split(',')
                for ver in versions:
                    request.schemaVersions.append(long(ver))
        if requestTimeout is not None:
            request.timeout = requestTimeout
        if sealed is not None:
            request.sealed = sealed
        if topicType is not None:
            request.topicType = topicType
        if physicTopicLst is not None:
            request.physicTopicLst.extend(physicTopicLst.split(','))
        if enableTTLDel is not None:
            request.enableTTLDel = enableTTLDel
        if enableLongPolling is not None:
            request.enableLongPolling = enableLongPolling
        if versionControl is not None:
            request.versionControl = versionControl
        if enableMergeData is not None:
            request.enableMergeData = enableMergeData
        if permitUser:
            request.permitUser.extend(permitUser.split(","))
        if readNotCommmitMsg is not None:
            request.readNotCommittedMsg = readNotCommmitMsg

        return self._run(swift_common_define.SWIFT_METHOD_CREATE_TOPIC, request)