Functions — github.com/NorthWard/awesome-netty

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

Functions459 in github.com/NorthWard/awesome-netty

⨍ Functions 459◇ Types & classes 103

↓ 11 callersMethodgetBytes

(Object object)

awesome-netty-redis/src/main/java/com/north/netty/redis/utils/EncodeUtils.java:7

↓ 10 callersMethodinvokeCmd

(Cmd<T> cmd, CmdResp<T, RETURN> cmdResp)

awesome-netty-redis/src/main/java/com/north/netty/redis/clients/AbstractRedisClient.java:22

↓ 10 callersMethodserializable

(ByteBuf out)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequest.java:7

↓ 10 callersMethodwriteVarint

(int value, ByteBuf out)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:83

↓ 8 callersMethodsizeOfVarint

Number of bytes needed to encode an integer in variable-length format. @param value The signed value

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:110

↓ 7 callersMethodreadVarint

Read an integer stored in variable-length format using zig-zag decoding from ByteBuf @param buffer The buffer to read from @return The integer read

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:42

↓ 7 callersMethodwriteAndFlush

代理channel的几个方法

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:46

↓ 5 callersMethodreadStringToBuffer2

字符串长度是2个字节 @param in @return

awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:93

↓ 5 callersMethodwriteStringToBuffer

长度用int表示, 占4个字节 @param msg @param out

awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:45

↓ 5 callersMethodwriteStringToBuffer2

长度用short表示占2个字节 @param msg @param out

awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:61

↓ 4 callersMethodclose

()

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:54

↓ 4 callersMethodgetBytes

(String str)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/StringSerializer.java:7

↓ 4 callersMethodgetCorrelationId

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaResponseHeader.java:16

↓ 4 callersMethodgetValue

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/PureJavaCrc32C.java:45

↓ 4 callersMethodgetXid

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/RequestHeader.java:9

↓ 4 callersMethodisActive

()

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:58

↓ 4 callersMethodputKafkaResponse

(Integer correlationId, AbstractKafkaResponse kafkaResponse)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/caches/RequestCacheCenter.java:18

↓ 4 callersMethodsetXid

(int xid)

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/RequestHeader.java:13

↓ 3 callersMethodbuild

(String message)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:486

↓ 3 callersMethodbuild

构建RESP 协议 @return

awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/Cmd.java:11

↓ 3 callersMethoddeserialize

反序列化这个响应体 @param byteBuf

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaResponse.java:14

↓ 3 callersMethodget

get命令 @param key @return

awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisClient.java:51

↓ 3 callersMethodputResp

(Integer requestId, ZkResponse zkResponse)

awesome-netty-zk/src/main/java/org/north/netty/zk/registrys/ZkCaches.java:36

↓ 3 callersMethodreadStringToBuffer

字符串长度是4个字节 @param in @return

awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:77

↓ 3 callersMethodserializeObject

(T object, Class<T> clz)

awesome-netty-common/src/main/java/org/north/netty/common/utils/ProtostuffHelper.java:14

↓ 3 callersMethodsetApiKey

(Short apiKey)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:28

↓ 3 callersMethodsetApiVersion

(Short apiVersion)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:36

↓ 3 callersMethodsetClientId

(String clientId)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:52

↓ 3 callersMethodsetCorrelationId

(Integer correlationId)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaRequestHeader.java:44

↓ 3 callersMethodwaitForResp

(Integer correlationId, long timeoutMs)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/caches/RequestCacheCenter.java:26

↓ 2 callersMethodbuildBinary

构建成的RESP文本是: " arrLen\r\n" +"$cmdLen\r\n" + "cmd\r\n" +"$param0Len\r\n" + "param0\r\n" +"$param1Len\r\n" + "param1\r\n" +"$param2Len\r\n" + "para

awesome-netty-redis/src/main/java/com/north/netty/redis/utils/CmdBuildUtils.java:23

↓ 2 callersMethodbuildString

构建成的RESP文本是: " arrLen\r\n" +"$cmdLen\r\n" + "cmd\r\n" +"$param0Len\r\n" + "param0\r\n" +"$param1Len\r\n" + "param1\r\n" +"$param2Len\r\n" + "para

awesome-netty-redis/src/main/java/com/north/netty/redis/utils/CmdBuildUtils.java:73

↓ 2 callersMethodcheckChannel

(RedisConnection channel)

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/ConnectionPool.java:103

↓ 2 callersMethodcode

The error code for the exception

awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:543

↓ 2 callersMethodconnectToServer

()

awesome-netty-zk/src/main/java/org/north/netty/zk/NettyZkClient.java:68

↓ 2 callersMethodgetAcl

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:30

↓ 2 callersMethodgetCmd

()

awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/setcmd/AbstractSetCmd.java:31

↓ 2 callersMethodgetCmd

()

awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/impl/getcmd/AbstractGetCmd.java:21

↓ 2 callersMethodgetInstance

()

awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisBinaryClient.java:24

↓ 2 callersMethodgetInstance

()

awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisStringClient.java:22

↓ 2 callersMethodgetKafkaMsgRecordBatchList

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/Record.java:48

↓ 2 callersMethodgetKey

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:211

↓ 2 callersMethodgetKey

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/ConsumerRecord.java:27

↓ 2 callersMethodgetMaxBytes

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:99

↓ 2 callersMethodgetMaxWaitTime

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:83

↓ 2 callersMethodgetMsgSize

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:179

↓ 2 callersMethodgetName

()

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:30

↓ 2 callersMethodgetPath

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:14

↓ 2 callersMethodgetResp

(Integer requestId, long duration, TimeUnit unit)

awesome-netty-zk/src/main/java/org/north/netty/zk/registrys/ZkCaches.java:40

↓ 2 callersMethodgetSessionId

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:28

↓ 2 callersMethodgetString

(byte [] bytes)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/StringSerializer.java:19

↓ 2 callersMethodgetTimeout

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/config/KafkaProduceConfig.java:25

↓ 2 callersMethodgetType

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/RequestHeader.java:17

↓ 2 callersMethodgetType

()

awesome-netty-redis/src/main/java/com/north/netty/redis/enums/Xmode.java:21

↓ 2 callersMethodgetVal

()

awesome-netty-redis/src/test/java/org/nort/netty/redis/test/RedisBinaryClientTest.java:61

↓ 2 callersMethodpoll

(KafkaConsumerConfig consumerConfig, String topic, int partition, long fetchOffset)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/KafkaClient.java:136

↓ 2 callersMethodremoveCodec

(Integer requestId)

awesome-netty-zk/src/main/java/org/north/netty/zk/registrys/ZkCaches.java:33

↓ 2 callersMethodsetErr

(int err)

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/AbstractZkResonse.java:16

↓ 2 callersMethodsetType

(int type)

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/RequestHeader.java:21

↓ 2 callersMethodsetZxid

(long zxid)

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/AbstractZkResonse.java:12

↓ 2 callersMethodtoByteArray

(Object obj)

awesome-netty-common/src/main/java/org/north/netty/common/utils/SerializeUtils.java:11

↓ 1 callersMethodborrowConnection

()

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/ConnectionPool.java:78

↓ 1 callersMethodcalcCrc32

(ByteBuf buf)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:83

↓ 1 callersMethodcalcMsgSize

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:31

↓ 1 callersMethodcleanUp

()

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:24

↓ 1 callersMethodcompute

Compute the CRC32C (Castagnoli) of the segment of the byte array given by the specified size and offset @param bytes The bytes to checksum @param off

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/Crc32C.java:46

↓ 1 callersMethodcreate

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/Crc32C.java:53

↓ 1 callersMethodcreate

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/Crc32C.java:58

↓ 1 callersMethodcreate

(String path, Object data, CreateMode mode)

awesome-netty-zk/src/main/java/org/north/netty/zk/NettyZkClient.java:156

↓ 1 callersMethoddeSerializeObject

(byte[] object, Class<T> clz)

awesome-netty-common/src/main/java/org/north/netty/common/utils/ProtostuffHelper.java:20

↓ 1 callersMethoddeserialize

(ByteBuf byteBuf)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/KafkaResponseHeader.java:12

↓ 1 callersMethoddeserialize

(ByteBuf in)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionResp.java:15

↓ 1 callersMethoddeserialize

(ByteBuf in)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/AbortedTransaction.java:8

↓ 1 callersMethoddeserialize

(ByteBuf in)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicResponse.java:15

↓ 1 callersMethoddeserialize

(ByteBuf byteBuf)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/PartitionResponse.java:13

↓ 1 callersMethoddeserialize

(ByteBuf byteBuf)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/TopicProduceRes.java:13

↓ 1 callersMethoddeserialize

(ByteBuf byteBuf)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/partition/PartitionMateData.java:71

↓ 1 callersMethoddeserialize

(ByteBuf in)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:29

↓ 1 callersMethoddeserialize

(ByteBuf in)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:114

↓ 1 callersMethoddeserialize

(ByteBuf byteBuf)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/topic/TopicMetaData.java:57

↓ 1 callersMethoddeserialize

(ByteBuf byteBuf)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/broker/Broker.java:49

↓ 1 callersMethoddisconnect

()

awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:50

↓ 1 callersMethodfetchMataData

(String topic)

awesome-netty-kafka/src/main/java/com/north/netty/kafka/KafkaClient.java:68

↓ 1 callersMethodforCode

Throw the exception if there is one

awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:562

↓ 1 callersMethodget

(byte [] key)

awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisBinaryClient.java:74

↓ 1 callersMethodget

(String key)

awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisStringClient.java:70

↓ 1 callersMethodgetAck

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/config/KafkaProduceConfig.java:17

↓ 1 callersMethodgetBaseOffset

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/PartitionResponse.java:37

↓ 1 callersMethodgetChildren

(String path)

awesome-netty-zk/src/main/java/org/north/netty/zk/NettyZkClient.java:140

↓ 1 callersMethodgetChildren

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/getchildren/ZkGetChildrenResponse.java:14

↓ 1 callersMethodgetCodec

(ZkRequest zkRequest, ZkCaches codecRegistry)

awesome-netty-zk/src/main/java/org/north/netty/zk/factories/ZkCodecFactories.java:16

↓ 1 callersMethodgetCodec

(Integer requestId)

awesome-netty-zk/src/main/java/org/north/netty/zk/registrys/ZkCaches.java:29

↓ 1 callersMethodgetCorrelationId

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/AbstractKafkaResponse.java:18

↓ 1 callersMethodgetData

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:22

↓ 1 callersMethodgetErrorCode

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionHeader.java:42

↓ 1 callersMethodgetFirstTimestamp

()

awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:215

↓ 1 callersMethodgetFlag

()

awesome-netty-zk/src/main/java/org/north/netty/zk/utils/CreateMode.java:25

↓ 1 callersMethodgetFlags

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:38

↓ 1 callersMethodgetId

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAcl.java:17

↓ 1 callersMethodgetId

()

awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAclId.java:17

next →1–100 of 459, ranked by callers