Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/MyCATApache/Mycat-NIO
/ functions
Functions
708 in github.com/MyCATApache/Mycat-NIO
⨍
Functions
708
◇
Types & classes
84
Method
createNewConnection
(String schema)
src/main/java/io/mycat/net2/mysql/connection/back/MySQLDataSource.java:44
Method
disableRead
()
src/main/java/io/mycat/net2/Connection.java:439
Method
enableRead
()
src/main/java/io/mycat/net2/Connection.java:445
Method
finishResponse
(BackendConnection conn)
src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontConnectionHandler.java:198
Method
getAbsByteBufPosion
获取当前ByteBuffer Posion位置相对应的绝对位置,比如此ByteBuffer之前有2个ByteBuffer,则绝对位置为 第一个的长度+第二个的长度+本身的postion @return
src/main/java/io/mycat/net2/ByteBufferArray.java:59
Method
getAcceptCount
()
src/main/java/io/mycat/net2/NIOAcceptor.java:50
Method
getActiveCountForSchema
(String schema)
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:113
Method
getActiveCountForSchema
(String schema, PhysicalDatasource dataSouce)
src/main/java/io/mycat/net2/mysql/connection/back/ConMap.java:60
Method
getBackSocketNoDelay
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:510
Method
getBackSocketSoRcvbuf
()
src/main/java/io/mycat/net2/SystemConfig.java:155
Method
getBackSocketSoRcvbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:486
Method
getBackSocketSoSndbuf
()
src/main/java/io/mycat/net2/SystemConfig.java:163
Method
getBackSocketSoSndbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:494
Method
getBacksocketsorcvbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:414
Method
getBacksocketsosndbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:418
Method
getBindIp
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:217
Method
getBlock
(int i)
src/main/java/io/mycat/net2/ByteBufferArray.java:114
Method
getBlockCount
()
src/main/java/io/mycat/net2/ByteBufferArray.java:110
Method
getBufferSize
()
src/main/java/io/mycat/net2/SharedBufferPool.java:92
Method
getCapactiy
()
src/main/java/io/mycat/net2/SharedBufferPool.java:104
Method
getCatletClassCheckSeconds
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:197
Method
getCharset
()
src/main/java/io/mycat/net2/ClosableConnection.java:27
Method
getCharset
()
src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontendConnection.java:37
Method
getCharset
()
src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:87
Method
getCharset
()
src/main/java/io/mycat/net2/mysql/connection/back/ConnectionMeta.java:52
Method
getCharset
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:278
Method
getCharsetName
()
src/main/java/io/mycat/net2/mysql/packet/util/CharsetUtil.java:118
Method
getClusterHeartbeatPass
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:382
Method
getClusterHeartbeatPeriod
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:390
Method
getClusterHeartbeatRetry
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:422
Method
getClusterHeartbeatTimeout
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:398
Method
getClusterHeartbeatUser
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:366
Method
getCollationIndex
()
src/main/java/io/mycat/net2/mysql/packet/util/CharsetUtil.java:126
Method
getCollationName
()
src/main/java/io/mycat/net2/mysql/packet/util/CharsetUtil.java:134
Method
getConnectCount
()
src/main/java/io/mycat/net2/NIOConnector.java:37
Method
getConnection
(String schema, boolean autocommit, final Object attachment)
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:200
Method
getDataNodeHeartbeatPeriod
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:358
Method
getDataNodeIdleCheckPeriod
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:350
Method
getDatabase
()
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBNode.java:52
Method
getDatasource
()
src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:278
Method
getDbPool
()
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:70
Method
getDbPool
()
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBNode.java:48
Method
getDbType
()
src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:57
Method
getDefaultMaxLimit
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:225
Method
getDefaultSqlParser
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:124
Method
getExecuteCount
()
src/main/java/io/mycat/net2/mysql/connection/back/ConQueue.java:34
Method
getExecuteCountForSchema
(String schema)
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:108
Method
getExecutor
()
src/main/java/io/mycat/net2/NetSystem.java:80
Method
getFilters
()
src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:129
Method
getFreeBuffers
()
src/main/java/io/mycat/net2/SharedBufferPool.java:88
Method
getFrontSocketNoDelay
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:502
Method
getFrontSocketSoRcvbuf
()
src/main/java/io/mycat/net2/SystemConfig.java:139
Method
getFrontSocketSoRcvbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:470
Method
getFrontSocketSoSndbuf
()
src/main/java/io/mycat/net2/SystemConfig.java:147
Method
getFrontSocketSoSndbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:478
Method
getFrontWriteQueueSize
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:209
Method
getFrontsocketsorcvbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:406
Method
getFrontsocketsosndbuf
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:410
Method
getGlableTableCheckPeriod
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:161
Method
getHeartbeatRecoveryTime
()
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:258
Method
getHomePath
()
src/main/java/io/mycat/net2/SystemConfig.java:72
Method
getHomePath
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:233
Method
getHost
()
src/main/java/io/mycat/net2/Connection.java:93
Method
getHost
()
src/main/java/io/mycat/net2/ClosableConnection.java:39
Method
getId
()
src/main/java/io/mycat/net2/ConnectIdGenerator.java:19
Method
getIdleConsToClose
(int count)
src/main/java/io/mycat/net2/mysql/connection/back/ConQueue.java:65
Method
getIdleCountForSchema
(String schema)
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:117
Method
getIdleTimeout
()
src/main/java/io/mycat/net2/Connection.java:85
Method
getIdleTimeout
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:334
Method
getLastPerfCollectTime
()
src/main/java/io/mycat/net2/Connection.java:81
Method
getLastReadTime
()
src/main/java/io/mycat/net2/Connection.java:138
Method
getLastWriteTime
()
src/main/java/io/mycat/net2/Connection.java:142
Method
getLocalPort
()
src/main/java/io/mycat/net2/Connection.java:113
Method
getLocalPort
()
src/main/java/io/mycat/net2/ClosableConnection.java:43
Method
getLogTime
()
src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:145
Method
getManagerExecutor
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:318
Method
getManagerPort
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:294
Method
getMaxPacketSize
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:193
Method
getMaxStringLiteralLength
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:518
Method
getMetaSimilarity
get metadata similarity @param theCon @return
src/main/java/io/mycat/net2/mysql/connection/back/ConnectionMeta.java:74
Method
getMutiNodeLimitType
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:526
Method
getMutiNodePatchSize
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:534
Method
getMycatNodeId
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:574
Method
getNIOHandler
()
src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontendConnectionFactory.java:25
Method
getName
()
src/main/java/io/mycat/net2/NamebleScheduledExecutor.java:16
Method
getName
()
src/main/java/io/mycat/net2/NameableExecutor.java:19
Method
getName
()
src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBNode.java:44
Method
getNetConfig
()
src/main/java/io/mycat/net2/NetSystem.java:72
Method
getNetInBytes
()
src/main/java/io/mycat/net2/NetSystem.java:88
Method
getNetInBytes
()
src/main/java/io/mycat/net2/Connection.java:146
Method
getNetInBytes
()
src/main/java/io/mycat/net2/ClosableConnection.java:45
Method
getNetOutBytes
()
src/main/java/io/mycat/net2/NetSystem.java:96
Method
getNetOutBytes
()
src/main/java/io/mycat/net2/Connection.java:150
Method
getNetOutBytes
()
src/main/java/io/mycat/net2/ClosableConnection.java:47
Method
getPacketHeaderSize
()
src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:185
Method
getPacketInfo
()
src/main/java/io/mycat/net2/mysql/packet/AuthPacket.java:156
Method
getPacketInfo
()
src/main/java/io/mycat/net2/mysql/packet/FieldPacket.java:119
Method
getPacketInfo
()
src/main/java/io/mycat/net2/mysql/packet/Reply323Packet.java:70
Method
getPacketInfo
()
src/main/java/io/mycat/net2/mysql/packet/ErrorPacket.java:145
Method
getPacketInfo
()
src/main/java/io/mycat/net2/mysql/packet/RowDataPacket.java:147
← previous
next →
401–500 of 708, ranked by callers