MCPcopy Create free account

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

Functions459 in github.com/NorthWard/awesome-netty

⨍ Functions 459◇ Types & classes 103
↓ 1 callersMethodgetIsLogon
()
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:43
↓ 1 callersMethodgetKafkaResponse
(Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/caches/RequestCacheCenter.java:22
↓ 1 callersMethodgetLastZxidSeen
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginRequest.java:24
↓ 1 callersMethodgetMinBytes
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:91
↓ 1 callersMethodgetMsgs
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:263
↓ 1 callersMethodgetOffsetDelta
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:203
↓ 1 callersMethodgetPartion
(String topic, byte [] key, byte[] val)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/SimplePartitioner.java:4
↓ 1 callersMethodgetPartition
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionHeader.java:34
↓ 1 callersMethodgetPartitionHeaders
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchPartitionResp.java:22
↓ 1 callersMethodgetPartitionResps
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicResponse.java:36
↓ 1 callersMethodgetPartitions
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicRequest.java:32
↓ 1 callersMethodgetPassword
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:36
↓ 1 callersMethodgetPerms
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAcl.java:9
↓ 1 callersMethodgetProtocolVersion
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:12
↓ 1 callersMethodgetRecordSset
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/PartitionData.java:13
↓ 1 callersMethodgetRequestId
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/ZkRequest.java:6
↓ 1 callersMethodgetResp
(long timeout)
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:26
↓ 1 callersMethodgetResponses
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchResponse.java:41
↓ 1 callersMethodgetScheme
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAclId.java:9
↓ 1 callersMethodgetTimeout
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:20
↓ 1 callersMethodgetTimestampDelta
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:195
↓ 1 callersMethodgetTopic
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicRequest.java:24
↓ 1 callersMethodgetTopics
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:115
↓ 1 callersMethodgetTotalSize
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordBatch.java:151
↓ 1 callersMethodgetValues
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/KafkaMsgRecordV2.java:219
↓ 1 callersMethodgetZkLoginResp
()
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:51
↓ 1 callersMethodinit
(final ClientType clientType)
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/ConnectionPool.java:29
↓ 1 callersMethodisReadOnly
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:44
↓ 1 callersMethodisSocketConnected
()
awesome-netty-zk/src/main/java/org/north/netty/zk/NettyZkClient.java:98
↓ 1 callersMethodisWatch
()
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/getchildren/ZkGetChildrenRequest.java:23
↓ 1 callersMethodlock
()
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/RedisConnection.java:38
↓ 1 callersMethodlogin
0. header, 4个字节, 表示报文的大小 1. 4个字节的protocolVersion(Integer, 默认为0即可) 2. 8个字节的lastZxidSeen(Long , 默认为0即可) 3. 4个字节的超时时间(Integer) 4. 8个字节的s
awesome-netty-zk/src/main/java/org/north/netty/zk/NettyZkClient.java:116
↓ 1 callersMethodmessage
Get a friendly description of the error (if one is available). @return the error message
awesome-netty-kafka/src/main/java/com/north/netty/kafka/enums/Errors.java:553
↓ 1 callersMethodparseResp
kafka poll 返回的数据结构非常复杂, 这里解析出我们想要的数据 @param response @return
awesome-netty-kafka/src/main/java/com/north/netty/kafka/KafkaClient.java:188
↓ 1 callersMethodparseResp
解析redis的resp @param resp @return
awesome-netty-redis/src/main/java/com/north/netty/redis/cmd/CmdResp.java:13
↓ 1 callersMethodputCodec
(Integer requestId, ByteToMessageCodec codec)
awesome-netty-zk/src/main/java/org/north/netty/zk/registrys/ZkCaches.java:25
↓ 1 callersMethodreadVarlong
Read a long stored in variable-length format using zig-zag decoding from ByteBuf @param buffer The buffer to read from @return The long value read @
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/VarLengthUtils.java:67
↓ 1 callersMethodremoveResp
(Integer requestId)
awesome-netty-zk/src/main/java/org/north/netty/zk/registrys/ZkCaches.java:55
↓ 1 callersMethodreset
()
awesome-netty-kafka/src/main/java/com/north/netty/kafka/utils/PureJavaCrc32C.java:51
↓ 1 callersMethodreturnConnection
(RedisConnection channel)
awesome-netty-redis/src/main/java/com/north/netty/redis/connections/ConnectionPool.java:89
↓ 1 callersMethodsend
(KafkaProduceConfig config, String topic , String key, String val)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/KafkaClient.java:84
↓ 1 callersMethodserializable
(ByteBuf out)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:48
↓ 1 callersMethodserializable
(ByteBuf out)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:28
↓ 1 callersMethodserializable
(ByteBuf out)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaRequest.java:43
↓ 1 callersMethodset
(byte [] key, byte [] v)
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisBinaryClient.java:29
↓ 1 callersMethodset
(String key, String v)
awesome-netty-redis/src/main/java/com/north/netty/redis/clients/RedisStringClient.java:26
↓ 1 callersMethodsetAck
(short ack)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/config/KafkaProduceConfig.java:21
↓ 1 callersMethodsetAcks
(Short acks)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:58
↓ 1 callersMethodsetAcl
(List<ZkAcl> acl)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:34
↓ 1 callersMethodsetChildren
(List<String> children)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/getchildren/ZkGetChildrenResponse.java:18
↓ 1 callersMethodsetCorrelationId
(Integer correlationId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/AbstractKafkaResponse.java:22
↓ 1 callersMethodsetData
(List<PartitionData> data)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/TopicProduceData.java:36
↓ 1 callersMethodsetData
(byte[] data)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:26
↓ 1 callersMethodsetFetchOffset
(Long fetchOffset)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicPartitionRequest.java:31
↓ 1 callersMethodsetFlags
(int flags)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:42
↓ 1 callersMethodsetId
(ZkAclId id)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAcl.java:21
↓ 1 callersMethodsetId
(String id)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAclId.java:21
↓ 1 callersMethodsetIsLogon
(boolean isLogon)
awesome-netty-zk/src/main/java/org/north/netty/zk/zkcodec/login/ZkLoginHandler.java:47
↓ 1 callersMethodsetIsolationLevel
(Byte isolationLevel)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:111
↓ 1 callersMethodsetKafkaMsgRecordBatchList
(List<KafkaMsgRecordBatch> kafkaMsgRecordBatchList)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/Record.java:52
↓ 1 callersMethodsetKafkaResponseHeader
(KafkaResponseHeader kafkaResponseHeader)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/AbstractKafkaResponse.java:14
↓ 1 callersMethodsetKey
(String key)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/ConsumerRecord.java:31
↓ 1 callersMethodsetLastZxidSeen
(Long lastZxidSeen)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginRequest.java:28
↓ 1 callersMethodsetLogStartOffset
(Long logStartOffset)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicPartitionRequest.java:39
↓ 1 callersMethodsetMaxBytes
(Integer maxBytes)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicPartitionRequest.java:47
↓ 1 callersMethodsetMaxBytes
(Integer maxBytes)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:103
↓ 1 callersMethodsetMaxBytes
(Integer maxBytes)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/config/KafkaConsumerConfig.java:39
↓ 1 callersMethodsetMaxWaitTime
(Integer maxWaitTime)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:87
↓ 1 callersMethodsetMaxWaitTime
(Integer maxWaitTime)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/config/KafkaConsumerConfig.java:23
↓ 1 callersMethodsetMinBytes
(Integer minBytes)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:95
↓ 1 callersMethodsetMinBytes
(Integer minBytes)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/config/KafkaConsumerConfig.java:31
↓ 1 callersMethodsetOffset
(long offset)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/ConsumerRecord.java:15
↓ 1 callersMethodsetPartition
(Integer partition)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicPartitionRequest.java:23
↓ 1 callersMethodsetPartition
(Integer partition)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/Record.java:44
↓ 1 callersMethodsetPartitions
(List<FetchTopicPartitionRequest> partitions)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicRequest.java:36
↓ 1 callersMethodsetPassword
(String password)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:40
↓ 1 callersMethodsetPassword
(String password)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginRequest.java:52
↓ 1 callersMethodsetPath
(String path)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateRequest.java:18
↓ 1 callersMethodsetPath
(String path)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkCreateResponse.java:13
↓ 1 callersMethodsetPath
(String path)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/getchildren/ZkGetChildrenRequest.java:19
↓ 1 callersMethodsetPerms
(int perms)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAcl.java:13
↓ 1 callersMethodsetProtocolVersion
(Integer protocolVersion)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:16
↓ 1 callersMethodsetProtocolVersion
(Integer protocolVersion)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginRequest.java:20
↓ 1 callersMethodsetReadOnly
(boolean readOnly)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:48
↓ 1 callersMethodsetReadOnly
(boolean readOnly)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginRequest.java:60
↓ 1 callersMethodsetRecordSset
(Record recordSset)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/PartitionData.java:17
↓ 1 callersMethodsetReplicaId
(Integer replicaId)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:79
↓ 1 callersMethodsetScheme
(String scheme)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/create/ZkAclId.java:13
↓ 1 callersMethodsetSessionId
(Long sessionId)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:32
↓ 1 callersMethodsetSessionId
(Long sessionId)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginRequest.java:44
↓ 1 callersMethodsetTimeOut
(Integer timeOut)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:66
↓ 1 callersMethodsetTimeStamp
(long timeStamp)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/msg/ConsumerRecord.java:23
↓ 1 callersMethodsetTimeout
(int timeout)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/config/KafkaProduceConfig.java:29
↓ 1 callersMethodsetTimeout
(int timeout)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginResp.java:24
↓ 1 callersMethodsetTimeout
(int timeout)
awesome-netty-zk/src/main/java/org/north/netty/zk/bean/login/ZkLoginRequest.java:36
↓ 1 callersMethodsetTopic
(String topic)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchTopicRequest.java:28
↓ 1 callersMethodsetTopic
(String topic)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/TopicProduceData.java:28
↓ 1 callersMethodsetTopicData
(List<TopicProduceData> topicData)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/produce/ProduceRequest.java:74
↓ 1 callersMethodsetTopics
(List<FetchTopicRequest> topics)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/fetch/FetchRequest.java:119
↓ 1 callersMethodsetTopics
(List<String> topics)
awesome-netty-kafka/src/main/java/com/north/netty/kafka/bean/meta/KafkaMetaRequest.java:31
← previousnext →101–200 of 459, ranked by callers