Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/NorthWard/awesome-netty
/ functions
Functions
459 in github.com/NorthWard/awesome-netty
⨍
Functions
459
◇
Types & classes
103
↓ 1 callers
Method
setTransactionalId
(String transactionalId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:50
↓ 1 callers
Method
setVal
(String val)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/ConsumerRecord.java:39
↓ 1 callers
Method
setWatch
(boolean watch)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/getchildren/ZkGetChildrenRequest.java:27
↓ 1 callers
Method
setZkLoginResp
(ZkLoginResp zkLoginResp)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:55
↓ 1 callers
Method
sizeOfVarlong
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 callers
Method
unlock
()
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:41
↓ 1 callers
Method
update
(byte[] b, int off, int len)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/PureJavaCrc32C.java:56
↓ 1 callers
Method
utf8Length
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 callers
Method
writeByteArrToBuffer
(byte [] buffer, ByteBuf out)
awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:115
↓ 1 callers
Method
writeStringListToBuffer
(List<String> lists, ByteBuf out)
awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:103
↓ 1 callers
Method
writeVarlong
(long value, ByteBuf out)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:94
Method
AbstractGetCmd
(T key)
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/AbstractGetCmd.java:15
Method
AbstractRedisClient
(ClientType clientType)
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/AbstractRedisClient.java:17
Method
AbstractSetCmd
(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
Method
ApiKeys
(int id, String name, short apiVersion)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/ApiKeys.java:43
Method
AwesomeNettyRedisException
(String message)
awesome-netty-redis/src/main/java/com/north/netty/redis/exceptions/AwesomeNettyRedisException.java:7
Method
ConnectionPool
(ClientType clientType)
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/ConnectionPool.java:25
Method
Crc32C
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/Crc32C.java:36
Method
CreateMode
(int flag)
awesome-netty-zk/src/main/java/org/north/netty/zk/utils/CreateMode.java:21
Method
Errors
(int code, String defaultExceptionString, ApiExceptionBuilder builder)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:505
Method
ExpireMode
(String type)
awesome-netty-redis/src/main/java/com/north/netty/redis/enums/ExpireMode.java:17
Method
FailedToGetConnectionException
(String message)
awesome-netty-redis/src/main/java/com/north/netty/redis/exceptions/FailedToGetConnectionException.java:7
Method
FetchRequest
(String clientId, Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:14
Method
GetBinaryCmd
(byte[] key)
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/binary/GetBinaryCmd.java:14
Method
GetStringCmd
(String key)
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/str/GetStringCmd.java:12
Method
KafkaClient
(String clientId, String host, int port)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/KafkaClient.java:42
Method
KafkaMetaRequest
(String clientId, Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaRequest.java:19
Method
KafkaMsgRecordBatch
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:14
Method
KafkaMsgRecordV2
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:18
Method
KafkaResponseDecoder
(RequestCacheCenter requestCacheCenter)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/codec/KafkaResponseDecoder.java:14
Method
Key
()
awesome-netty-redis/src/test/java/org/nort/netty/redis/test/RedisBinaryClientTest.java:36
Method
NettyZkClient
(int timeout)
awesome-netty-zk/src/main/java/org/north/netty/zk/NettyZkClient.java:48
Method
ProduceRequest
(String clientId, Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:18
Method
ProtostuffHelper
()
awesome-netty-common/src/main/java/org/north/netty/common/utils/ProtostuffHelper.java:11
Method
PureJavaCrc32C
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/PureJavaCrc32C.java:41
Method
RedisBinaryClient
()
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisBinaryClient.java:21
Method
RedisConnection
(String name, NioSocketChannel socketChannel, SynchronousQueue<T> synchronousQueue)
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:19
Method
RedisRespHandler
(SynchronousQueue<T> synchronousQueue)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/RedisRespHandler.java:14
Method
RedisStringClient
()
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisStringClient.java:14
Method
SetBinaryCmd
没有过期时间 @param key @param value
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/binary/SetBinaryCmd.java:22
Method
SetStringCmd
没有过期时间 @param key @param value
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/str/SetStringCmd.java:21
Method
Val
()
awesome-netty-redis/src/test/java/org/nort/netty/redis/test/RedisBinaryClientTest.java:53
Method
VarLengthUtils
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:30
Method
Xmode
(String type)
awesome-netty-redis/src/main/java/com/north/netty/redis/enums/Xmode.java:17
Method
ZkAbstractCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkAbstractCodec.java:8
Method
ZkCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkCodec.java:18
Method
ZkCreateCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/createcodec/ZkCreateCodec.java:19
Method
ZkGetChildrenCodec
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/getchildren/ZkGetChildrenCodec.java:18
Method
ZkLoginCodec
()
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginCodec.java:17
Method
ZkLoginHandler
(ZkCaches codecRegistry)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:25
Method
build
(String message)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:37
Method
build
构建请求参数RESP @return
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/str/SetStringCmd.java:52
Method
build
()
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/binary/SetBinaryCmd.java:40
Method
build
()
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/str/GetStringCmd.java:16
Method
build
()
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/binary/GetBinaryCmd.java:18
Method
byteArrayToObj
(byte[] bytes)
awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:24
Method
channelRead
(ChannelHandlerContext ctx, Object msg)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/RedisRespHandler.java:18
Method
create
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/Crc32C.java:62
Method
decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/codec/KafkaResponseDecoder.java:17
Method
decode
(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkCodec.java:41
Method
decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/createcodec/ZkCreateCodec.java:48
Method
decode
@param ctx @param in @param out @throws Exception
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginCodec.java:37
Method
decode
(ChannelHandlerContext ctx, ZkLoginResp zkLoginResp, List<Object> out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:28
Method
decode
内容: 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
Method
decode
(ChannelHandlerContext ctx, ByteBuf in, List<Object> out)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/ByteBufToByteDecoder.java:13
Method
deserialize
(ByteBuf in)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchResponse.java:19
Method
deserialize
(ByteBuf in)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionHeader.java:16
Method
deserialize
(ByteBuf in)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/Record.java:30
Method
deserialize
(ByteBuf byteBuf)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceResponse.java:15
Method
deserialize
(ByteBuf byteBuf)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:67
Method
encode
(ChannelHandlerContext channelHandlerContext, ZkRequest zkRequest, ByteBuf byteBuf)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/ZkCodec.java:22
Method
encode
(ChannelHandlerContext ctx, ZkCreateRequest msg, ByteBuf out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/createcodec/ZkCreateCodec.java:23
Method
encode
(ChannelHandlerContext ctx, ZkLoginRequest msg, ByteBuf outByteBuf)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginCodec.java:20
Method
encode
(ChannelHandlerContext ctx, ZkGetChildrenRequest msg, ByteBuf out)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/getchildren/ZkGetChildrenCodec.java:22
Method
encode
(ChannelHandlerContext ctx, byte[] msg, ByteBuf out)
awesome-netty-redis/src/main/java/com/north/netty/redis/codecs/ByteToByteBufEncoder.java:12
Method
exception
An instance of the exception
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:514
Method
exceptionName
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
Method
forException
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
Method
getAbortedTransactions
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionHeader.java:74
Method
getAcks
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:54
Method
getApiKey
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:24
Method
getApiVersion
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:32
Method
getAttributes
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:199
Method
getAttributes
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:187
Method
getBaseOffset
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:159
Method
getBrokers
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:35
Method
getClientId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:48
Method
getClusterId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:51
Method
getCmd
redis命令 @return
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/AbstractCmd.java:21
Method
getControllerId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaResponse.java:43
Method
getCorrelationId
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:40
Method
getCrc
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:191
Method
getData
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/TopicProduceData.java:32
Method
getEpoch
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:239
Method
getErrorCode
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/PartitionResponse.java:29
Method
getErrorCode
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/partition/PartitionMateData.java:23
Method
getErrorCode
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/topic/TopicMetaData.java:25
Method
getFetchOffset
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicPartitionRequest.java:27
Method
getHeader
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:67
Method
getHeaders
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:227
← previous
next →
201–300 of 459, ranked by callers