Types & classes — github.com/MyCATApache/Mycat-Server

CodeHub MCPcopy Create free account

hub / github.com/MyCATApache/Mycat-Server / types & classes

Types & classes1,168 in github.com/MyCATApache/Mycat-Server

⨍ Functions 7,572◇ Types & classes 1,168

src/test/java/io/mycat/model/M2.java:62

src/test/java/io/mycat/model/M1.java:62

ClassAIOAcceptor

src/main/java/io/mycat/net/AIOAcceptor.java:44

ClassAIOConnector

src/main/java/io/mycat/net/AIOConnector.java:36

ClassAIOReadHandler

src/main/java/io/mycat/net/AIOSocketWR.java:207

ClassAIOSocketWR

src/main/java/io/mycat/net/AIOSocketWR.java:12

ClassAIOWriteHandler

src/main/java/io/mycat/net/AIOSocketWR.java:179

ClassAbstractBytesToBytesMapSuite

src/test/java/io/mycat/memory/unsafe/map/AbstractBytesToBytesMapSuite.java:46

ClassAbstractConnection

src/main/java/io/mycat/net/AbstractConnection.java:49

ClassAbstractDataNodeMerge

Created by zagnix on 2016/7/6.

src/main/java/io/mycat/sqlengine/mpp/AbstractDataNodeMerge.java:21

ClassAbstractMultiTreadBatchTester

src/test/java/io/mycat/performance/AbstractMultiTreadBatchTester.java:38

ClassAbstractPartitionAlgorithm

路由分片函数抽象类为了实现一个默认的支持范围分片的函数 calcualteRange 重写它以实现自己的范围路由规则 @author lxy

src/main/java/io/mycat/route/function/AbstractPartitionAlgorithm.java:17

ClassAbstractRouteStrategy

src/main/java/io/mycat/route/impl/AbstractRouteStrategy.java:21

ClassAbstractScalaRowIterator

Created by zagnix 2016/6/6.

src/main/java/io/mycat/memory/unsafe/utils/sort/AbstractScalaRowIterator.java:8

ClassAbstractSequencer

@author lmax.Disruptor @version 3.3.5 @date 2016/7/24

src/main/java/io/mycat/memory/unsafe/ringbuffer/producer/AbstractSequencer.java:17

ClassAcceptIdGenerator

前端连接ID生成器 @author mycat

src/main/java/io/mycat/net/AIOAcceptor.java:142

ClassAcceptIdGenerator

前端连接ID生成器 @author mycat

src/main/java/io/mycat/net/NIOAcceptor.java:175

InterfaceAlarms

Mycat报警关键词定义 @author mycat

src/main/java/io/mycat/config/Alarms.java:31

ClassAlertException

@author lmax.Disruptor @version 3.3.5 @date 2016/7/24

src/main/java/io/mycat/memory/unsafe/ringbuffer/exception/AlertException.java:8

InterfaceAllJobFinishedListener

called when all jobs in EngineCxt finished @author wuzhih

src/main/java/io/mycat/sqlengine/AllJobFinishedListener.java:7

ClassArrayPerformanceMain

src/test/java/io/mycat/util/ArrayPerformanceMain.java:32

src/main/java/io/mycat/config/util/OrderRetainingMap.java:68

src/main/java/io/mycat/route/parser/util/ArrayUtil.java:29

ClassAuthPacket

From client to server during initial handshake. <pre> Bytes Name ----- ---- 4

src/main/java/io/mycat/net/mysql/AuthPacket.java:55

src/main/java/io/mycat/backend/postgresql/packet/AuthenticationPacket.java:8

ClassAuthenticationCleartextPassword

<pre> AuthenticationCleartextPassword (B) Byte1('R') Identifies the message as an authentication request. Int32(8) Length of message contents in bytes

src/main/java/io/mycat/net/postgres/AuthenticationCleartextPassword.java:36

ClassAuthenticationGSS

<pre> AuthenticationGSS (B) Byte1('R') Identifies the message as an authentication request. Int32(8) Length of message contents in bytes, including se

src/main/java/io/mycat/net/postgres/AuthenticationGSS.java:36

ClassAuthenticationGSSContinue

<pre> AuthenticationGSSContinue (B) Byte1('R') Identifies the message as an authentication request. Int32 Length of message contents in bytes, includi

src/main/java/io/mycat/net/postgres/AuthenticationGSSContinue.java:37

ClassAuthenticationKerberosV5

<pre> AuthenticationKerberosV5 (B) Byte1('R') Identifies the message as an authentication request. Int32(8) Length of message contents in bytes, inclu

src/main/java/io/mycat/net/postgres/AuthenticationKerberosV5.java:36

ClassAuthenticationMD5Password

<pre> AuthenticationMD5Password (B) Byte1('R') Identifies the message as an authentication request. Int32(12) Length of message contents in bytes, inc

src/main/java/io/mycat/net/postgres/AuthenticationMD5Password.java:37

ClassAuthenticationOk

<pre> AuthenticationOk (B) Byte1('R') Identifies the message as an authentication request. Int32(8) Length of message contents in bytes, including sel

src/main/java/io/mycat/net/postgres/AuthenticationOk.java:36

ClassAuthenticationPacket

src/main/java/io/mycat/backend/postgresql/packet/AuthenticationPacket.java:7

ClassAuthenticationSCMCredential

<pre> AuthenticationSCMCredential (B) Byte1('R') Identifies the message as an authentication request. Int32(8) Length of message contents in bytes, in

src/main/java/io/mycat/net/postgres/AuthenticationSCMCredential.java:36

ClassAuthenticationSSPI

<pre> AuthenticationSSPI (B) Byte1('R') Identifies the message as an authentication request. Int32(8) Length of message contents in bytes, including s

src/main/java/io/mycat/net/postgres/AuthenticationSSPI.java:36

ClassAutoPartitionByLong

auto partition by Long ,can be used in auto increment primary key partition @author wuzhi

src/main/java/io/mycat/route/function/AutoPartitionByLong.java:40

ClassAutoPartitionByLongTest

src/test/java/io/mycat/route/function/AutoPartitionByLongTest.java:30

src/test/java/io/mycat/model/M1.java:77

InterfaceBIOConnection

src/main/java/io/mycat/net/BIOConnection.java:3

ClassBackendAIOConnection

src/main/java/io/mycat/net/BackendAIOConnection.java:35

ClassBackendAsyncHandler

src/main/java/io/mycat/net/handler/BackendAsyncHandler.java:33

InterfaceBackendConnection

src/main/java/io/mycat/backend/BackendConnection.java:11

ClassBackendConnectionFactory

src/main/java/io/mycat/net/factory/BackendConnectionFactory.java:36

EnumBackendConnectionState

src/main/java/io/mycat/backend/postgresql/PostgreSQLBackendConnection.java:35

ClassBackendKeyData

src/main/java/io/mycat/backend/postgresql/packet/BackendKeyData.java:24

ClassBackendKeyData

<pre> BackendKeyData (B) Byte1('K') Identifies the message as cancellation key data. The frontend must save these values if it wishes to be

src/main/java/io/mycat/net/postgres/BackendKeyData.java:39

src/main/java/io/mycat/util/DecryptUtil.java:233

ClassBaseOrdering

src/main/java/io/mycat/memory/unsafe/utils/sort/UnsafeKVExternalSorter.java:304

ClassBaseSQLExeTest

base sql test cases,some data should in database first @author wuzhih

src/test/java/io/mycat/sqlexecute/BaseSQLExeTest.java:40

ClassBatchInsertSequence

执行批量插入sequence Id @author 兵临城下 @date 2015/03/20

src/main/java/io/mycat/route/sequence/BatchInsertSequence.java:31

ClassBatchSQLJob

src/main/java/io/mycat/sqlengine/BatchSQLJob.java:9

ClassBeanConfig

src/main/java/io/mycat/config/util/BeanConfig.java:35

ClassBeginHandler

src/main/java/io/mycat/server/handler/BeginHandler.java:31

ClassBestHolder

Provides a lexicographical comparer implementation; either a Java implementation or a faster implementation based on {@link Unsafe}. <p/> <p>Uses refl

src/main/java/io/mycat/util/FastByteOperations.java:95

ClassBinDataPathChildrenCacheListener

Created by magicdoom on 2016/10/27.

src/main/java/io/mycat/config/loader/zkprocess/zktoxml/listen/BinDataPathChildrenCacheListener.java:19

ClassBinaryOpResultHandler

src/main/java/io/mycat/route/impl/middlerResultStrategy/BinaryOpResultHandler.java:16

ClassBinaryPacket

src/main/java/io/mycat/net/mysql/BinaryPacket.java:38

ClassBinaryPrefixComparator

src/main/java/io/mycat/memory/unsafe/utils/sort/PrefixComparators.java:25

ClassBinaryRowDataPacket

ProtocolBinary::ResultsetRow: row of a binary resultset (COM_STMT_EXECUTE) Payload 1 packet header [00] string[$len] NULL-bitmap, lengt

src/main/java/io/mycat/net/mysql/BinaryRowDataPacket.java:38

src/main/java/io/mycat/backend/postgresql/packet/Bind.java:46

<pre> Bind (F) Byte1('B') Identifies the message as a Bind command. Int32 Length of message contents in bytes, including self. String The name of the

src/main/java/io/mycat/net/postgres/Bind.java:57

ClassBindComplete

绑定预编译sql成功 @author Coollf

src/main/java/io/mycat/backend/postgresql/packet/BindComplete.java:20

ClassBindComplete

<pre> BindComplete (B) Byte1('2') Identifies the message as a Bind-complete indicator. Int32(4) Length of message contents in bytes, including self. <

src/main/java/io/mycat/net/postgres/BindComplete.java:35

src/main/java/io/mycat/backend/mysql/BindValue.java:29

ClassBindValueUtil

src/main/java/io/mycat/backend/mysql/BindValueUtil.java:35

ClassBindataToZK

Created by magicdoom on 2016/10/26. only for test

src/main/java/io/mycat/config/loader/zkprocess/xmltozk/BindataToZK.java:17

ClassBinlogIdleCheck

Created by magicdoom on 2016/12/14.

src/main/java/io/mycat/migrate/BinlogIdleCheck.java:16

ClassBinlogStream

src/main/java/io/mycat/migrate/BinlogStream.java:31

ClassBinlogStreamHoder

Created by magicdoom on 2016/12/25.

src/main/java/io/mycat/migrate/BinlogStreamHoder.java:9

ClassBioConnection

src/test/java/io/mycat/EchoBioServer.java:58

ClassBitSetMethods

Methods for working with fixed-size uncompressed bitsets. We assume that the bitset data is word-aligned (that is, a multiple of 8 bytes in length).

src/main/java/io/mycat/memory/unsafe/bitset/BitSetMethods.java:30

src/test/java/io/mycat/util/BitTest.java:31

ClassBlockManagerTest

Created by zagnix on 2016/6/4.

src/test/java/io/mycat/memory/unsafe/storage/BlockManagerTest.java:15

ClassBlockingWaitStrategy

@author lmax.Disruptor @version 3.3.5 @date 2016/8/1

src/main/java/io/mycat/memory/unsafe/ringbuffer/common/waitStrategy/impl/BlockingWaitStrategy.java:18

ClassBufferArray

used for large data write ,composed by buffer array, when a large MySQL package write ,shoud use this object to write data use DirectByteBuffer for

src/main/java/io/mycat/buffer/BufferArray.java:18

ClassBufferHolder

A helper class to manage the data buffer for an unsafe row. The data buffer can grow and automatically re-point the unsafe row to it. This class can

src/main/java/io/mycat/memory/unsafe/row/BufferHolder.java:37

ClassBufferPerformanceMain

src/test/java/io/mycat/BufferPerformanceMain.java:31

InterfaceBufferPool

缓冲池 @author Hash Zhang @version 1.0 @time 12:19 2016/5/23

src/main/java/io/mycat/buffer/BufferPool.java:13

ClassBufferUtil

src/main/java/io/mycat/backend/mysql/BufferUtil.java:31

ClassBusySpinWaitStrategy

@author lmax.Disruptor @version 3.3.5 @date 2016/8/1

src/main/java/io/mycat/memory/unsafe/ringbuffer/common/waitStrategy/impl/BusySpinWaitStrategy.java:13

src/main/java/io/mycat/memory/unsafe/types/ByteArray.java:24

ClassByteArrayMethods

src/main/java/io/mycat/memory/unsafe/array/ByteArrayMethods.java:23

ClassByteArrayToHexArray

src/test/java/demo/test/ByteArrayToHexArray.java:5

ClassByteBufferArena

仿照Netty的思路，针对MyCat内存缓冲策略优化 ByteBufferArena维护着锁还有所有list @author Hash Zhang @version 1.0 @time 17:19 2016/5/17 @see @https://github.com/netty/netty

src/main/java/io/mycat/buffer/ByteBufferArena.java:21

ClassByteBufferChunk

仿照Netty的思路，针对MyCat内存缓冲策略优化 Chunk由Page组成，是一块连续内存，由memoryMap和depthMap定义成一种平衡二叉树的管理结构 @author Hash Zhang @version 1.0 @time 17:19 2016/5/17 @see @https:

src/main/java/io/mycat/buffer/ByteBufferChunk.java:18

ClassByteBufferChunkList

仿照Netty的思路，针对MyCat内存缓冲策略优化 ChunkList维护着一个指向一串Chunk的头结点，访问策略由minUsage，maxUsage决定 @author Hash Zhang @version 1.0 @time 17:19 2016/5/17 @see @https://g

src/main/java/io/mycat/buffer/ByteBufferChunkList.java:21

ClassByteBufferPage

src/main/java/io/mycat/buffer/ByteBufferPage.java:13

ClassByteBufferUtil

Utility methods to make ByteBuffers less painful The following should illustrate the different ways byte buffers can be used public void testA

src/main/java/io/mycat/util/ByteBufferUtil.java:77

InterfaceByteOperations

src/main/java/io/mycat/util/FastByteOperations.java:74

src/main/java/io/mycat/memory/unsafe/utils/ByteUnit.java:19

src/main/java/io/mycat/backend/mysql/ByteUtil.java:29

src/main/java/io/mycat/util/ByteUtil.java:29

ClassBytesToBytesMap

An append-only hash map where keys and values are contiguous regions of bytes. This is backed by a power-of-2-sized hash table, using quadratic probi

src/main/java/io/mycat/memory/unsafe/map/BytesToBytesMap.java:63

ClassBytesToBytesMapOffHeapSuite

src/test/java/io/mycat/memory/unsafe/map/BytesToBytesMapOffHeapSuite.java:20

ClassBytesToBytesMapOnHeapSuite

src/test/java/io/mycat/memory/unsafe/map/BytesToBytesMapOnHeapSuite.java:20

ClassBytesTools

Utility class that handles byte arrays, conversions to/from other types,

src/main/java/io/mycat/memory/unsafe/utils/BytesTools.java:39

src/test/java/io/mycat/model/M2.java:84

src/test/java/io/mycat/model/M1.java:93

缓存配制信息源文件名：CacheInfo.java 文件版本：1.0.0 创建作者：liujun 创建日期：2016年9月19日修改作者：liujun 修改日期：2016年9月19日文件描述：TODO 版权所有：Copyright 2016 zjhz, Inc. All Rights Rese

src/main/java/io/mycat/config/loader/zkprocess/entity/cache/CacheInfo.java:19

InterfaceCachePool

simple cache pool for implement @author wuzhih

src/main/java/io/mycat/cache/CachePool.java:32

ClassCachePoolFactory

factory used to create cachePool @author wuzhih

src/main/java/io/mycat/cache/CachePoolFactory.java:30

next →1–100 of 1,168, ranked by callers