Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Meituan-Dianping/octo-ns
/ functions
Functions
3,969 in github.com/Meituan-Dianping/octo-ns
⨍
Functions
3,969
◇
Types & classes
1,259
Method
drainPendingTask
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:1184
Function
dyn_create
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:507
Function
dyn_destroy
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:523
Function
dyn_lock
sg_agent/thrid_party/thrift/include/transport/TSSLSocket.cpp:511
Method
echo
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:247
Method
echo
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:302
Function
enableMutexProfiling
sg_agent/thrid_party/thrift/include/concurrency/Mutex.cpp:43
Method
encode
(ChannelHandlerContext channelHandlerContext, Header header, ByteBuf byteBuf)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatCodec.java:40
Method
encode
encodes input (uint4) into output (unsigned char). Assumes len is a multiple of 4.
sg_agent/src/comm/md5.cc:147
Method
endItem
sg_agent/thrid_party/thrift/include/protocol/TDebugProtocol.cpp:114
Method
enqueueEvent
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:233
Method
ensureCanWrite
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:321
Method
errorMessage
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.h:44
Method
errorTimeWrapper
sg_agent/thrid_party/thrift/include/Thrift.h:128
Method
escapeNum
Numbers must be turned into strings if they are the key part of a pair
sg_agent/thrid_party/thrift/include/protocol/TJSONProtocol.cpp:316
Method
eventHandler
* C-callable event handler for connection events. Provides a callback * that libevent can understand which invokes connection_->workSocket(). *
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:264
Method
eventHandler
* C-callable event handler for listener events. Provides a callback * that libevent can understand which invokes server->handleEvent(). * *
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:736
Method
eventInfo
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:57
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
scanner/src/main/java/com/meituan/octo/mns/scanner/util/heartbeat/HeartbeatHandler.java:39
Method
expireClose
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.cpp:1199
Method
expiredTaskCount
sg_agent/thrid_party/thrift/include/concurrency/ThreadManager.cpp:113
Method
fieldTypeName
sg_agent/thrid_party/thrift/include/protocol/TDebugProtocol.cpp:43
Method
finish
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:259
Method
finish
static */
sg_agent/thrid_party/thrift/include/async/TAsyncProtocolProcessor.cpp:42
Method
flush
sg_agent/thrid_party/thrift/include/transport/THttpClient.cpp:86
Method
flush
sg_agent/thrid_party/thrift/include/transport/TShortReadTransport.h:74
Method
flush
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:84
Method
flush
sg_agent/thrid_party/thrift/include/transport/TFileTransport.cpp:560
Method
flush
sg_agent/thrid_party/thrift/include/transport/THttpServer.cpp:79
Method
flush
* Flushes any pending data to be written. Typically used with buffered * transport mechanisms. * * @throws TTransportException if an error oc
sg_agent/thrid_party/thrift/include/transport/TTransport.h:183
Method
flush
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.cpp:119
Method
flushToTransport
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:268
Method
flushToZlib
sg_agent/thrid_party/thrift/include/transport/TZlibTransport.cpp:282
Method
foo
sg_agent/thrid_party/thrift/include/concurrency/test/ThreadFactoryTests.h:310
Function
get
* Used to retrieve an object from the registry. (The registry * owns the returned pointer.) */
sg_agent/thrid_party/logs/include/spi/factory.h:172
Function
get
* Used to retrieve an object from the registry. (The registry * owns the returned pointer.) */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/factory.h:172
Method
getAllAppkeys
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheApiTest.java:41
Method
getAppKey
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/http/HttpServerPublisher.java:49
Method
getAppKeyByIP
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheServiceTest.java:39
Method
getAppkeyList
(@PathVariable("ip") String ip)
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ApiController.java:81
Method
getAppkeyListByIP
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:921
Method
getAppkeyListByIP
common/gen-cpp/MNSCacheService.h:921
Method
getAppkeys
()
nsc/src/main/java/com/meituan/octo/mnsc/web/api/ApiController.java:95
Method
getAsyncServer
sg_agent/thrid_party/thrift/include/async/TAsyncProcessor.h:58
Method
getAtomic_avaliable_conn_num_
sdk/mns-sdk/src/mns_worker.h:285
Method
getAtomic_avaliable_conn_num_
sg_agent/thrid_party/thrid/include/mns_sdk/mns_worker.h:285
Function
getBuffer
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/helpers/socketbuffer.h:48
Method
getBufferAsString
sg_agent/thrid_party/thrift/include/transport/TBufferTransports.h:578
Method
getCachedAddress
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:800
Method
getChannel
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:319
Method
getChunkSize
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:230
Method
getClient
sg_agent/thrid_party/thrid/include/mns_sdk/thrift_client.h:44
Method
getConnectionStackLimit
* Get the maximum number of unused TConnection we will hold in reserve. * * @return the current limit on TConnection pool size. */
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:376
Method
getCurChunk
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.cpp:166
Function
getCurrentThreadId
sg_agent/thrid_party/logs/include/thread/impl/threads-impl.h:54
Function
getCurrentThreadId
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/thread/impl/threads-impl.h:54
Method
getCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:302
Method
getCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/BoostThreadFactory.cpp:165
Method
getCurrentThreadId
sg_agent/thrid_party/thrift/include/concurrency/BoostThreadFactory.cpp:180
Method
getEnv
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/AgentInfo.java:37
Method
getEofSleepTimeUs
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:283
Method
getEventBase
sg_agent/thrid_party/thrift/include/async/TEvhttpServer.cpp:164
Method
getEventBufferSize
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:242
Method
getEventHandler
sg_agent/thrid_party/thrift/include/TProcessor.h:150
Method
getEventHandler
sg_agent/thrid_party/thrift/include/async/TAsyncProcessor.h:50
Method
getFD
sg_agent/thrid_party/thrift/include/transport/TFDTransport.h:66
Method
getFileReaderTransport
sg_agent/thrid_party/thrift/include/transport/TTransportUtils.h:323
Function
getFilter
* Get the filter chain on this Appender. */
sg_agent/thrid_party/logs/include/appender.h:216
Function
getFilter
* Get the filter chain on this Appender. */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/appender.h:216
Method
getFlushMaxBytes
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:260
Method
getFlushMaxUs
sg_agent/thrid_party/thrift/include/transport/TFileTransport.h:251
Method
getHandler
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:41
Method
getHandler
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:40
Method
getHandler
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:42
Method
getHandler
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:290
Method
getHandler
common/gen-cpp/MNSCacheService.h:41
Method
getHost
sg_agent/thrid_party/thrift/include/transport/TSocket.cpp:593
Method
getHostInfo
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:80
Function
getId
sg_agent/thrid_party/thrift/include/concurrency/PosixThreadFactory.cpp:163
Method
getIdcs
()
sdk/mns-invoker/src/test/java/com/meituan/octo/mns/util/ProcessInfoUtilTests.java:40
Method
getIdleBufferMemLimit
* [NOTE: This is for backwards compatibility, use getIdleReadBufferLimit().] * Get the maximum size of read buffer allocated to idle TConnection ob
sg_agent/thrid_party/thrift/include/server/TNonblockingServer.h:620
Method
getInputProtocol
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:780
Method
getInputProtocol
sg_agent/thrid_party/thrid/include/octoidl/ServiceAgent.h:635
Method
getInputProtocol
sg_agent/thrid_party/cthrift/include/cthrift/Echo.h:191
Method
getInputProtocol
common/gen-cpp/MNSCacheService.h:780
Method
getInputProtocol
common/gen-cpp/ServiceAgent.h:635
Method
getInputTransport
TODO: remove these two calls, they are for backwards compatibility
sg_agent/thrid_party/thrift/include/protocol/TProtocol.h:653
Method
getIp
()
sdk/mns-invoker/src/main/java/com/meituan/octo/mns/model/AgentInfo.java:45
Function
getLine
The is the line where this log statement was written */
sg_agent/thrid_party/logs/include/spi/loggingevent.h:185
Function
getLine
The is the line where this log statement was written */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/loggingevent.h:185
Function
getLogLevel
* Returns the assigned LogLevel, if any, for this Logger. * * @return LogLevel - the assigned LogLevel.
sg_agent/thrid_party/logs/include/spi/loggerimpl.h:113
Function
getLogLevel
LogLevel of logging event. */
sg_agent/thrid_party/logs/include/spi/loggingevent.h:119
Function
getLogLevel
* Returns the assigned LogLevel, if any, for this Logger. * * @return LogLevel - the assigned LogLevel.
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/loggerimpl.h:113
Function
getLogLevel
LogLevel of logging event. */
sg_agent/thrid_party/logs/log4cplus/include/log4cplus/spi/loggingevent.h:119
Method
getMNSCache
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheServiceTest.java:83
Method
getMNSCache
(String appkey, String version, String env)
nsc/src/main/java/com/meituan/octo/mnsc/thrift/service/impl/MNSCacheServiceImpl.java:35
Method
getMNSCache
sg_agent/thrid_party/thrid/include/octoidl/MNSCacheService.h:861
Method
getMNSCache
common/gen-cpp/MNSCacheService.h:861
Method
getMNSCacheByAppkeys
()
nsc/src/test/java/com/meituan/octo/mnsc/MNSCacheServiceTest.java:70
Method
getMNSCacheByAppkeys
(List<String> appkeys, String protocol)
nsc/src/main/java/com/meituan/octo/mnsc/thrift/service/impl/MNSCacheServiceImpl.java:55
← previous
next →
2,301–2,400 of 3,969, ranked by callers