MCPcopy Create free account

hub / github.com/NorthWard/awesome-netty / functions

Functions459 in github.com/NorthWard/awesome-netty

↓ 1 callersMethodsetTransactionalId
(String transactionalId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:50
↓ 1 callersMethodsetVal
(String val)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/ConsumerRecord.java:39
↓ 1 callersMethodsetWatch
(boolean watch)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/getchildren/ZkGetChildrenRequest.java:27
↓ 1 callersMethodsetZkLoginResp
(ZkLoginResp zkLoginResp)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:55
↓ 1 callersMethodsizeOfVarlong
Number of bytes needed to encode a long in variable-length format. @param value The signed value
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:149
↓ 1 callersMethodunlock
()
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:41
↓ 1 callersMethodupdate
(byte[] b, int off, int len)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/PureJavaCrc32C.java:56
↓ 1 callersMethodutf8Length
Get the length for UTF8-encoding a string without encoding it first @param s The string to calculate the length for @return The length when serialize
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:126
↓ 1 callersMethodwriteByteArrToBuffer
(byte [] buffer, ByteBuf out)
awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:115
↓ 1 callersMethodwriteStringListToBuffer
(List<String> lists, ByteBuf out)
awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:103
↓ 1 callersMethodwriteVarlong
(long value, ByteBuf out)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:94
MethodAbstractGetCmd
(T key)
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/AbstractGetCmd.java:15
MethodAbstractRedisClient
(ClientType clientType)
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/AbstractRedisClient.java:17
MethodAbstractSetCmd
(T key, T value, T expireMode, T expireTime, T xmode)
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/AbstractSetCmd.java:15
MethodApiKeys
(int id, String name, short apiVersion)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/ApiKeys.java:43
MethodAwesomeNettyRedisException
(String message)
awesome-netty-redis/src/main/java/com/north/netty/redis/exceptions/AwesomeNettyRedisException.java:7
MethodConnectionPool
(ClientType clientType)
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/ConnectionPool.java:25
MethodCrc32C
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/Crc32C.java:36
MethodCreateMode
(int flag)
awesome-netty-zk/src/main/java/org/north/netty/zk/utils/CreateMode.java:21
MethodErrors
(int code, String defaultExceptionString, ApiExceptionBuilder builder)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:505
MethodExpireMode
(String type)
awesome-netty-redis/src/main/java/com/north/netty/redis/enums/ExpireMode.java:17
MethodFailedToGetConnectionException
(String message)
awesome-netty-redis/src/main/java/com/north/netty/redis/exceptions/FailedToGetConnectionException.java:7
MethodFetchRequest
(String clientId, Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:14
MethodGetBinaryCmd
(byte[] key)
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/binary/GetBinaryCmd.java:14
MethodGetStringCmd
(String key)
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/str/GetStringCmd.java:12
MethodKafkaClient
(String clientId, String host, int port)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/KafkaClient.java:42
MethodKafkaMetaRequest
(String clientId, Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaRequest.java:19
MethodKafkaMsgRecordBatch
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:14
MethodKafkaMsgRecordV2
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:18
MethodKafkaResponseDecoder
(RequestCacheCenter requestCacheCenter)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/codec/KafkaResponseDecoder.java:14
MethodKey
()
awesome-netty-redis/src/test/java/org/nort/netty/redis/test/RedisBinaryClientTest.java:36
MethodNettyZkClient
(int timeout)
awesome-netty-zk/src/main/java/org/north/netty/zk/NettyZkClient.java:48
MethodProduceRequest
(String clientId, Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:18
MethodProtostuffHelper
()
awesome-netty-common/src/main/java/org/north/netty/common/utils/ProtostuffHelper.java:11
MethodPureJavaCrc32C
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/PureJavaCrc32C.java:41
MethodRedisBinaryClient
()
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisBinaryClient.java:21
MethodRedisConnection
(String name, NioSocketChannel socketChannel, SynchronousQueue<T> synchronousQueue)
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:19
MethodRedisRespHandler
(SynchronousQueue<T> synchronousQueue)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/RedisRespHandler.java:14
MethodRedisStringClient
()
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisStringClient.java:14
MethodSetBinaryCmd
没有过期时间 @param key @param value
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/binary/SetBinaryCmd.java:22
MethodSetStringCmd
没有过期时间 @param key @param value
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/str/SetStringCmd.java:21
MethodVal
()
awesome-netty-redis/src/test/java/org/nort/netty/redis/test/RedisBinaryClientTest.java:53
MethodVarLengthUtils
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:30
MethodXmode
(String type)
awesome-netty-redis/src/main/java/com/north/netty/redis/enums/Xmode.java:17
MethodZkAbstractCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkAbstractCodec.java:8
MethodZkCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkCodec.java:18
MethodZkCreateCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/createcodec/ZkCreateCodec.java:19
MethodZkGetChildrenCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/getchildren/ZkGetChildrenCodec.java:18
MethodZkLoginCodec
()
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginCodec.java:17
MethodZkLoginHandler
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:25
Methodbuild
(String message)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:37
Methodbuild
构建请求参数RESP @return
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/str/SetStringCmd.java:52
Methodbuild
()
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/binary/SetBinaryCmd.java:40
Methodbuild
()
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/str/GetStringCmd.java:16
Methodbuild
()
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/binary/GetBinaryCmd.java:18
MethodbyteArrayToObj
(byte[] bytes)
awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:24
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/RedisRespHandler.java:18
Methodcreate
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/Crc32C.java:62
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/codec/KafkaResponseDecoder.java:17
Methoddecode
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkCodec.java:41
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/createcodec/ZkCreateCodec.java:48
Methoddecode
@param ctx @param in @param out @throws Exception
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginCodec.java:37
Methoddecode
(ChannelHandlerContext ctx, ZkLoginResp zkLoginResp, List<Object> out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:28
Methoddecode
内容: 4字节的xid 8字节的zxid 4字节的err 如果 err==0 后面紧接着是resp 4个字节的len, 表示children的长度 再读len个字符串(每个字符串是4个字节的长度 + 字符串内容字节数组) @param ctx @param in @param o
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/getchildren/ZkGetChildrenCodec.java:44
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/ByteBufToByteDecoder.java:13
Methoddeserialize
(ByteBuf in)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchResponse.java:19
Methoddeserialize
(ByteBuf in)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionHeader.java:16
Methoddeserialize
(ByteBuf in)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/Record.java:30
Methoddeserialize
(ByteBuf byteBuf)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceResponse.java:15
Methoddeserialize
(ByteBuf byteBuf)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:67
Methodencode
(ChannelHandlerContext channelHandlerContext, ZkRequest zkRequest, ByteBuf byteBuf)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkCodec.java:22
Methodencode
(ChannelHandlerContext ctx, ZkCreateRequest msg, ByteBuf out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/createcodec/ZkCreateCodec.java:23
Methodencode
(ChannelHandlerContext ctx, ZkLoginRequest msg, ByteBuf outByteBuf)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginCodec.java:20
Methodencode
(ChannelHandlerContext ctx, ZkGetChildrenRequest msg, ByteBuf out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/getchildren/ZkGetChildrenCodec.java:22
Methodencode
(ChannelHandlerContext ctx, byte[] msg, ByteBuf out)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/ByteToByteBufEncoder.java:12
Methodexception
An instance of the exception
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:514
MethodexceptionName
Returns the class name of the exception or null if this is {@code Errors.NONE}.
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:536
MethodforException
Return the error instance associated with this exception or any of its superclasses (or UNKNOWN if there is none). If there are multiple matches in th
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:575
MethodgetAbortedTransactions
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionHeader.java:74
MethodgetAcks
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:54
MethodgetApiKey
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:24
MethodgetApiVersion
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:32
MethodgetAttributes
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:199
MethodgetAttributes
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:187
MethodgetBaseOffset
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:159
MethodgetBrokers
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:35
MethodgetClientId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:48
MethodgetClusterId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:51
MethodgetCmd
redis命令 @return
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/AbstractCmd.java:21
MethodgetControllerId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:43
MethodgetCorrelationId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:40
MethodgetCrc
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:191
MethodgetData
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/TopicProduceData.java:32
MethodgetEpoch
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:239
MethodgetErrorCode
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/PartitionResponse.java:29
MethodgetErrorCode
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/partition/PartitionMateData.java:23
MethodgetErrorCode
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/topic/TopicMetaData.java:25
MethodgetFetchOffset
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicPartitionRequest.java:27
MethodgetHeader
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:67
MethodgetHeaders
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:227
← previousnext →201–300 of 459, ranked by callers