本文整理汇总了Python中util.encode.encodestring函数的典型用法代码示例。如果您正苦于以下问题:Python encodestring函数的具体用法?Python encodestring怎么用?Python encodestring使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了encodestring函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: encodeRequest
def encodeRequest(cls, name, value):
clientMessage = ClientMessage()
clientMessage.setOperationType(ListAddCodec.REQUEST_TYPE)
clientMessage.setRetryable(ListAddCodec.RETRYABLE)
clientMessage.set(encode.encodestring(name))
clientMessage.set(value)
clientMessage.updateSize()
return clientMessage
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:8,代码来源:listcodec.py
示例2: EntryProcessor
def EntryProcessor(self, key, entryProcessor, arguments, completionId):
msg=cachecodec.CacheEntryProcessorCodec.encodeRequest( encode.encodestring(self.title), key, entryProcessor, arguments, encode.encodeint32(completionId))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheEntryProcessorCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例3: Destroy
def Destroy(self, ):
msg=cachecodec.CacheDestroyCodec.encodeRequest( encode.encodestring(self.title))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheDestroyCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例4: RemoveInvalidationListener
def RemoveInvalidationListener(self, registrationId):
msg=cachecodec.CacheRemoveInvalidationListenerCodec.encodeRequest( encode.encodestring(self.title), encode.encodestring(registrationId))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheRemoveInvalidationListenerCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例5: RemoveAll
def RemoveAll(self, completionId):
msg=cachecodec.CacheRemoveAllCodec.encodeRequest( encode.encodestring(self.title), encode.encodeint32(completionId))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheRemoveAllCodec.decodeResponse(msg2)
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例6: ManagementConfig
def ManagementConfig(self, isStat, enabled, hostname, port):
msg=cachecodec.CacheManagementConfigCodec.encodeRequest( encode.encodestring(self.title), encode.encodeboolean(isStat), encode.encodeboolean(enabled), encode.encodestring(hostname), encode.encodeint32(port))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheManagementConfigCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例7: LoadGivenKeys
def LoadGivenKeys(self, keys, replaceExistingValues):
msg=mapcodec.MapLoadGivenKeysCodec.encodeRequest( encode.encodestring(self.title), keys, encode.encodeboolean(replaceExistingValues))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.getPackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return mapcodec.MapLoadGivenKeysCodec.decodeResponse(msg2)
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:mapproxy.py
示例8: GetAll
def GetAll(self, ):
msg=setcodec.SetGetAllCodec.encodeRequest( encode.encodestring(self.title))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return setcodec.SetGetAllCodec.decodeResponse(msg2).list
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:setproxy.py
示例9: Iterate
def Iterate(self, partitionId, tableIndex, batch):
msg=cachecodec.CacheIterateCodec.encodeRequest( encode.encodestring(self.title), encode.encodeint32(partitionId), encode.encodeint32(tableIndex), encode.encodeint32(batch))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheIterateCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例10: DrainToMaxSize
def DrainToMaxSize(self, maxSize):
msg=queuecodec.QueueDrainToMaxSizeCodec.encodeRequest( encode.encodestring(self.title), encode.encodeint32(maxSize))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return queuecodec.QueueDrainToMaxSizeCodec.decodeResponse(msg2)
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:queueproxy.py
示例11: Contains
def Contains(self, value):
msg=queuecodec.QueueContainsCodec.encodeRequest( encode.encodestring(self.title), value)
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return queuecodec.QueueContainsCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:queueproxy.py
示例12: CompareAndRemoveAll
def CompareAndRemoveAll(self, dataList):
msg=queuecodec.QueueCompareAndRemoveAllCodec.encodeRequest( encode.encodestring(self.title), dataList)
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return queuecodec.QueueCompareAndRemoveAllCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:queueproxy.py
示例13: Poll
def Poll(self, timeoutMillis):
msg=queuecodec.QueuePollCodec.encodeRequest( encode.encodestring(self.title),encode.encodeint64(timeoutMillis))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return queuecodec.QueuePollCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:queueproxy.py
示例14: ContainsAll
def ContainsAll(self, valueSet):
msg=listcodec.ListContainsAllCodec.encodeRequest( encode.encodestring(self.title), valueSet)
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg)
response=self.connection.getPackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return listcodec.ListContainsAllCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:listproxy.py
示例15: AddWithIndex
def AddWithIndex(self, index, value):
msg=listcodec.ListAddWithIndexCodec.encodeRequest( encode.encodestring(self.title), encode.encodeint32(index), value)
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg)
response=self.connection.getPackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return listcodec.ListAddWithIndexCodec.decodeResponse(msg2)
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:listproxy.py
示例16: GetAndReplace
def GetAndReplace(self, key, value, expiryPolicy, completionId):
msg=cachecodec.CacheGetAndReplaceCodec.encodeRequest( encode.encodestring(self.title), key, value, expiryPolicy, encode.encodeint32(completionId))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheGetAndReplaceCodec.decodeResponse(msg2).response
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例17: ListenerRegistration
def ListenerRegistration(self, listenerConfig, register, hostname, port):
msg=cachecodec.CacheListenerRegistrationCodec.encodeRequest( encode.encodestring(self.title), listenerConfig, encode.encodeboolean(register), encode.encodestring(hostname), encode.encodeint32(port))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheListenerRegistrationCodec.decodeResponse(msg2)
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例18: ExecuteOnAllKeys
def ExecuteOnAllKeys(self, entryProcessor):
msg=mapcodec.MapExecuteOnAllKeysCodec.encodeRequest( encode.encodestring(self.title), entryProcessor)
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.getPackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return mapcodec.MapExecuteOnAllKeysCodec.decodeResponse(msg2).entrySet
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:mapproxy.py
示例19: LoadAll
def LoadAll(self, keys, replaceExistingValues):
msg=cachecodec.CacheLoadAllCodec.encodeRequest( encode.encodestring(self.title), keys, encode.encodeboolean(replaceExistingValues))
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheLoadAllCodec.decodeResponse(msg2)
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
示例20: GetAll
def GetAll(self, keys, expiryPolicy):
msg=cachecodec.CacheGetAllCodec.encodeRequest( encode.encodestring(self.title), keys, expiryPolicy)
retryable=msg.retryable
self.connection.adjustCorrelationId(msg)
correlationid=msg.correlation
self.connection.sendPackage(msg.encodeMessage())
response=self.connection.receivePackageWithCorrelationId(correlationid,retryable)
msg2=ClientMessage.decodeMessage(response)
return cachecodec.CacheGetAllCodec.decodeResponse(msg2).entrySet
开发者ID:hazelcast-incubator,项目名称:hazelcast-python-client,代码行数:9,代码来源:cacheproxy.py
注:本文中的util.encode.encodestring函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论