MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 4 callersMethodcreateTagsMap
(String topic, int partition, String group)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/status/ConsumerStatusMonitor.java:63
↓ 4 callersMethoddelivered
(List<ConsumerMessage<T>> msgs)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/Committer.java:9
↓ 4 callersMethodderegister
(long token)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckManager.java:20
↓ 4 callersMethodencodePartial
(PartialDecodedMessage msg, ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/MessageCodec.java:19
↓ 4 callersMethodequals
(Object obj)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/TestObjectMessage.java:61
↓ 4 callersMethodequals
<p> Compares two Strings, returning <code>true</code> if they are equal. </p> <p> <code>null</code>s are handled without exceptions. Two <code>null</
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:188
↓ 4 callersMethodfindExchange
(String exchangeName)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:42
↓ 4 callersMethodfindLatestConsumerOffset
(String groupId)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:32
↓ 4 callersMethodfindMessageOffsetByTime
(long time)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:34
↓ 4 callersMethodgenerateBrokers
(int size, String prefix)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/LeastAdjustmentBrokerPartitionAssigningStrategyTest.java:28
↓ 4 callersMethodgenerateTopicsWithIncrementalPartitionCount
(int size, String prefix)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/LeastAdjustmentBrokerPartitionAssigningStrategyTest.java:36
↓ 4 callersMethodgetAllValidLeases
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:17
↓ 4 callersMethodgetAssignments
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaServerAssignmentHolder.java:161
↓ 4 callersMethodgetBornTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:79
↓ 4 callersMethodgetBrokerSenderAcceptTimeoutMillis
()
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:332
↓ 4 callersMethodgetClientTimeDiff
(long clientTimestamp)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:483
↓ 4 callersMethodgetCodecByType
(String codecString)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecFactory.java:26
↓ 4 callersMethodgetCurServerAndFixStatusByIDC
(Meta baseMeta)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/BaseEventHandler.java:69
↓ 4 callersMethodgetDurableSysProperty
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:135
↓ 4 callersMethodgetFilterPatternCacheSize
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:55
↓ 4 callersMethodgetFuture
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueFlusher.java:357
↓ 4 callersMethodgetGroupId
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/PullMessageCommandV3.java:43
↓ 4 callersMethodgetGroupId
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/QueryLatestConsumerOffsetCommandV3.java:41
↓ 4 callersMethodgetGroupId
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v4/PullMessageCommandV4.java:47
↓ 4 callersMethodgetGroupId
(String exchangeName, String idAndQueueName)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:59
↓ 4 callersMethodgetLastResizeTimeMillis
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCache.java:16
↓ 4 callersMethodgetLeader
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:214
↓ 4 callersMethodgetLeaderInfo
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaServerStatusResponse.java:83
↓ 4 callersMethodgetLevel
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecFactory.java:89
↓ 4 callersMethodgetMessageListenerConfig
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/Subscriber.java:81
↓ 4 callersMethodgetMessages
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/MessageBatchWithRawData.java:57
↓ 4 callersMethodgetMeta
()
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:380
↓ 4 callersMethodgetMetaServerAssignmentZkPath
(String topic)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKPathUtils.java:57
↓ 4 callersMethodgetMetaServerConnectTimeout
()
hermes-core/src/main/java/com/ctrip/hermes/core/config/CoreConfig.java:116
↓ 4 callersMethodgetMetaServerReadTimeout
()
hermes-core/src/main/java/com/ctrip/hermes/core/config/CoreConfig.java:120
↓ 4 callersMethodgetMetricRegistry
@return
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:106
↓ 4 callersMethodgetName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerLeaseHolder.java:46
↓ 4 callersMethodgetName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ConsumerLeaseHolder.java:45
↓ 4 callersMethodgetName
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:337
↓ 4 callersMethodgetNewEndpoint
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageAckCommandV5.java:38
↓ 4 callersMethodgetOffsetAfter
(String topic, int partition, long startOffsetExclusive, int batchSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCache.java:13
↓ 4 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/QueryLatestConsumerOffsetCommandV3.java:37
↓ 4 callersMethodgetPartitionProduceBytesRateLimiter
(String topic, int partition)
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:91
↓ 4 callersMethodgetPartitionProduceQPSRateLimiter
(String topic, int partition)
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:93
↓ 4 callersMethodgetProducerConfig
(String topic)
hermes-env/src/main/java/com/ctrip/hermes/env/ClientEnvironment.java:8
↓ 4 callersMethodgetRawData
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/MessageBatchWithRawData.java:49
↓ 4 callersMethodgetRecords
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/PartitionOperation.java:20
↓ 4 callersMethodgetResendOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Offset.java:40
↓ 4 callersMethodgetResults
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageResultCommandV6.java:60
↓ 4 callersMethodgetRole
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/ManagementResource.java:101
↓ 4 callersMethodgetSize
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/PullMessageCommand.java:53
↓ 4 callersMethodgetStartOffset
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:107
↓ 4 callersMethodgetToBeNacks
()
hermes-example/src/test/java/com/ctrip/hermes/example/ConsumerVerifier.java:357
↓ 4 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/QueryLatestConsumerOffsetCommandV3.java:33
↓ 4 callersMethodgetTopic
(String exchangeName)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:47
↓ 4 callersMethodgetTz
Gets the value of the 'tz' field.
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:86
↓ 4 callersMethodgetUrl
Gets the value of the 'url' field.
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:71
↓ 4 callersMethodgetVersion
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfig.java:47
↓ 4 callersMethodgetZookeeperEnsembles
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/ManagementResource.java:133
↓ 4 callersMethodhasError
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueCursor.java:25
↓ 4 callersMethodhasStorageForPriority
(String topicName, int priority)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:851
↓ 4 callersMethodinited
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:27
↓ 4 callersMethodisAllResultsSet
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageResultCommand.java:31
↓ 4 callersMethodisAssignTo
(Key key, String client)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:15
↓ 4 callersMethodisCatEnabled
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/config/ProducerConfig.java:156
↓ 4 callersMethodisClosed
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:238
↓ 4 callersMethodisDirty
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:48
↓ 4 callersMethodisManualConfigModeOn
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfigService.java:18
↓ 4 callersMethodisShouldResponse
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/SendMessageResult.java:36
↓ 4 callersMethodlast
(List<T> list)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CollectionUtil.java:11
↓ 4 callersMethodlastSegment
(String path)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKPathUtils.java:43
↓ 4 callersMethodloadLocalMeta
(Object testCase)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/TestHelper.java:39
↓ 4 callersMethodlogError
(QueryLatestConsumerOffsetCommand cmd, String errorInfo, Exception e)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/QueryLatestConsumerOffsetCommandProcessor.java:86
↓ 4 callersMethodlogIfOfferFail
(String type, boolean offered)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:234
↓ 4 callersMethodmakeEndpoint
(String id, String host, int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/meta/MetaMegerTest.java:90
↓ 4 callersMethodmakeMessage
(int partition, boolean priority, String body, long offset, boolean resend, int remainingRetries)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/pull/DefaultPullConsumerHolderTest.java:602
↓ 4 callersMethodmakeServer
(String host, int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/meta/MetaMegerTest.java:100
↓ 4 callersMethodmatches
(String name, Metric metric)
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:33
↓ 4 callersMethodmsgReceived
(String topic, int partition, String clientIp, int totalBytes, int msgCount)
hermes-broker/src/main/java/com/ctrip/hermes/broker/status/BrokerStatusMonitor.java:118
↓ 4 callersMethodnextAwaitingNormalOffset
(T key, long doneOffset, Object arg)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/AbstractSelectorManager.java:20
↓ 4 callersMethodnextAwaitingSafeTriggerOffset
(T key, Object arg)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/AbstractSelectorManager.java:22
↓ 4 callersMethodnormalAssert
(Map<String, ClientContext> brokers, List<Topic> topics, Map<String, Assignment<Integer>> newAssignment
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/LeastAdjustmentBrokerPartitionAssigningStrategyTest.java:70
↓ 4 callersMethodparse
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Header.java:66
↓ 4 callersMethodprintResult
(Map<String, Assignment<Integer>> originAssignments, Map<String, Assignment<Integer>> newAssignments)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/LeastAdjustmentBrokerPartitionAssigningStrategyTest.java:48
↓ 4 callersMethodrandomString
(int len)
hermes-example/src/test/java/com/ctrip/hermes/example/BrokerBenchmarkTest.java:19
↓ 4 callersMethodreRegister
(T key, CallbackContext callbackCtx, TriggerResult triggerResult, ExpireTimeHolder expireTimeHolder, SelectorC
hermes-core/src/main/java/com/ctrip/hermes/core/selector/SelectorManager.java:15
↓ 4 callersMethodreadMsgs
(HermesPrimitiveCodec codec)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:124
↓ 4 callersMethodreadMsgs
(HermesPrimitiveCodec codec)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/AckMessageCommandV3.java:115
↓ 4 callersMethodreadMsgs
(HermesPrimitiveCodec codec)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v4/AckMessageCommandV4.java:124
↓ 4 callersMethodrebalance
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ConsumerAssignmentHolder.java:89
↓ 4 callersMethodreceived
(AckMessageResultCommandV5 cmd)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/AckMessageResultMonitor.java:15
↓ 4 callersMethodschedulePush
(PullMessageTask task)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/LongPollingService.java:10
↓ 4 callersMethodscheduleRenewLeaseTask
(final ConsumerLeaseKey key, long delay)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/strategy/BaseConsumerTask.java:387
↓ 4 callersMethodsetBatchesResult
(boolean isPriority, Collection<Pair<MessageBatchWithRawData, Map<Integer, SendMessageResult>>> todos,
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueFlusher.java:287
↓ 4 callersMethodsetBrokerAccepted
(boolean accepted)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v2/PullMessageResultCommandV2.java:41
↓ 4 callersMethodsetBrokerLease
(Lease brokerLease)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:87
↓ 4 callersMethodsetConsumerRetryPolicy
(String consumerRetryPolicy)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:365
↓ 4 callersMethodsetDirty
(boolean dirty)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:44
↓ 4 callersMethodsetName
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:381
↓ 4 callersMethodsetPartition
(int partition)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:62
← previousnext →501–600 of 4,501, ranked by callers