MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 2 callersMethodapply
(EventHandler handler)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/EventHandlerRegistry.java:16
↓ 2 callersMethodassertAllMetaServerHaveTopic
(Topic topic)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:257
↓ 2 callersMethodassertMetaServerAssignmentRight
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:316
↓ 2 callersMethodassertRawData
(MessageBatchWithRawData actual, String topic, List<Integer> seqs, List<ProducerMessage<String>> pmsgs)
hermes-core/src/test/java/com/ctrip/hermes/core/transport/command/SendMessageCommandTest.java:213
↓ 2 callersMethodassign
(Map<String, ClientContext> brokers, List<Topic> topics, Map<String, Assignment<Integer>> originAssignm
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerPartitionAssigningStrategy.java:16
↓ 2 callersMethodassign
(List<Partition> partitions, Map<String, ClientContext> consumers, Map<Integer, Map<String, ClientConte
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ConsumerPartitionAssigningStrategy.java:15
↓ 2 callersMethodassign
(List<Server> metaServers, List<Topic> topics, Assignment<String> originAssignments)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaServerAssigningStrategy.java:15
↓ 2 callersMethodbaseMetaDeleteTopic
(Topic topic)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:545
↓ 2 callersMethodbecomeFollower
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:110
↓ 2 callersMethodbefore
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/pull/DefaultPullConsumerHolderTest.java:56
↓ 2 callersMethodbiggerOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/SlotMatchResult.java:41
↓ 2 callersMethodbizLogAcked
(Tpp tpp, String consumerIp, String groupId, List<AckContext> ackContexts, boolean isResend, boolean ac
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessor.java:104
↓ 2 callersMethodbuildCache
(int size)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:158
↓ 2 callersMethodbuildRandomTopic
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:560
↓ 2 callersMethodbuildRecentlyExpiredPagesCache
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:153
↓ 2 callersMethodbuildTopic
(String name)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:564
↓ 2 callersMethodcalRenewDelay
(Lease lease)
hermes-broker/src/main/java/com/ctrip/hermes/broker/lease/BrokerLeaseContainer.java:124
↓ 2 callersMethodcancel
(long correlationId)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/AckMessageResultMonitor.java:17
↓ 2 callersMethodcheckManualConfigureMode
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/DefaultManualConfigService.java:110
↓ 2 callersMethodcollectOffset
(List<Pair<Long, MessageMeta>> msgId2Metas)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:597
↓ 2 callersMethodconfigureNonClientProperties
Sets properties for this deserializer without overriding the schema registry client itself. Useful for testing, where a mock client is injected.
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/assist/kafka/avro/AbstractKafkaAvroDeserializer.java:60
↓ 2 callersMethodcontainsEndpoint
(Endpoint endpoint)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:56
↓ 2 callersMethodconvert
(com.ctrip.hermes.metaservice.model.Meta model)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/converter/MetaModelToEntityConverter.java:14
↓ 2 callersMethodcoreSize
(int coreSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:72
↓ 2 callersMethodcrc32
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/ChecksumUtil.java:9
↓ 2 callersMethodcreate
(String groupId, Lease lease, Offset offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:498
↓ 2 callersMethodcreate
(String groupId, Lease lease, Offset offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueue.java:41
↓ 2 callersMethodcreateMessageHolder
(String topic, String partitionKey, Object body, String refKey, List<Pair<String, String>> appPropertie
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:145
↓ 2 callersMethodcreateOrFindRecords
(int partition)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/RetriveSnapshot.java:144
↓ 2 callersMethodcreateOrGetPartitionStatus
(int partition, int por, boolean isPriority)
hermes-example/src/test/java/com/ctrip/hermes/example/ConsumerVerifier.java:274
↓ 2 callersMethoddecode
(byte[] raw, Class<T> clazz)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecCompositor.java:32
↓ 2 callersMethoddecodePartial
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/MessageCodec.java:17
↓ 2 callersMethoddeleteChildren
(String path, boolean deleteSelf)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/ZKSuppportTestCase.java:88
↓ 2 callersMethoddeleteTopic
Delete may not work @param topic
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/server/MockKafka.java:82
↓ 2 callersMethoddelivered
(long token, ConsumerMessage<?> msg)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckManager.java:18
↓ 2 callersMethoddelivered
(List<Pair<Long, T>> range, long develiveredTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/AckHolder.java:12
↓ 2 callersMethoddeserializeExistingLeases
(String jsonStr)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/BaseLeaseHolder.java:166
↓ 2 callersMethoddoAck
(boolean resend, boolean isPriority, String groupId, long msgSeq)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:503
↓ 2 callersMethoddoAppendMessageSync
(boolean isPriority, Collection<Pair<MessageBatchWithRawData, Map<Integer, SendMessageResult>>> todos)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueFlusher.java:222
↓ 2 callersMethoddoLoadAsync
(final Tp tp, final int priority, final Selector<Tp> selector)
hermes-broker/src/main/java/com/ctrip/hermes/broker/selector/DefaultPullMessageSelectorManager.java:105
↓ 2 callersMethoddoNack
(boolean resend, boolean isPriority, String groupId, List<Pair<Long, MessageMeta>> msgId2Metas)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:500
↓ 2 callersMethoddoProcess
(final Event event)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/BaseMetaChangedEventHandler.java:68
↓ 2 callersMethoddoRegister
(String id, int order)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/AbstractValveRegistry.java:46
↓ 2 callersMethoddoStop
(ConsumerContext consumerContext)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/engine/KafkaConsumerBootstrap.java:114
↓ 2 callersMethodencodePartial
(PartialDecodedMessage msg, ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/DefaultMessageCodec.java:47
↓ 2 callersMethodencodePropertiesStr
(Map<String, String> properties)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/remote/RemoteMetaProxy.java:289
↓ 2 callersMethodequalsIgnoreCase
<p> Compares two Strings, returning <code>true</code> if they are equal ignoring the case. </p> <p> <code>null</code>s are handled without exceptions
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:217
↓ 2 callersMethodevenRetry
(int retryIntervalMills, int retryTimes)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/MessageListenerConfig.java:28
↓ 2 callersMethodexecuteTask
(final PullMessageTask pullMessageTask, CallbackContext callbackCtx)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/DefaultLongPollingService.java:104
↓ 2 callersMethodfail
(long frameLength)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/netty/HermesLengthFieldBasedFrameDecoder.java:334
↓ 2 callersMethodfailIfNecessary
(boolean firstDetectionOfTooLongFrame)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/netty/HermesLengthFieldBasedFrameDecoder.java:302
↓ 2 callersMethodfetchBaseMetaAndRoleChangeIfNeeded
(ClusterStateHolder clusterStateHolder)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/FollowerInitEventHandler.java:165
↓ 2 callersMethodfetchResendMessages
(Tpg tpg, Object startOffset, int batchSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/MessageQueueStorage.java:32
↓ 2 callersMethodfetchTopicMeta
(String topic)
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/server/MockKafka.java:68
↓ 2 callersMethodfilterSensitiveField
(Meta meta)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaUtils.java:18
↓ 2 callersMethodfindAllocator
(String topicName, String consumerGroupName)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ConsumerLeaseAllocatorLocator.java:9
↓ 2 callersMethodfindConsumerBootstrap
(String endpointType)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/ConsumerBootstrapRegistry.java:12
↓ 2 callersMethodfindDb
(String topic, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV5.java:284
↓ 2 callersMethodfindDb
(String topic, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV6.java:263
↓ 2 callersMethodfindDb
(String topic, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV3.java:287
↓ 2 callersMethodfindDb
(String topic, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessor.java:288
↓ 2 callersMethodfindLeader
(List<String> a_seedBrokers, int a_port, String a_topic, int a_partition)
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/SimpleConsumerExample.java:184
↓ 2 callersMethodfindMessageOffsetByTime
(String topic, int partition, long time)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:60
↓ 2 callersMethodfindMessageOffsetByTime
(String topic, int partition, long time)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/MetaProxy.java:28
↓ 2 callersMethodfindNacks
(String groupId)
hermes-example/src/test/java/com/ctrip/hermes/example/OneBoxTest.java:211
↓ 2 callersMethodfindOrCreateObserveContext
(T key, InitialLastUpdateTime initialLastUpdateTime)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/DefaultSelector.java:84
↓ 2 callersMethodfindTimesByRefKey
(String refKey)
hermes-broker/src/test/java/com/ctrip/hermes/broker/selector/BizLogAnalyzer.java:112
↓ 2 callersMethodfire
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/DefaultSelector.java:158
↓ 2 callersMethodfirst
(List<T> list)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CollectionUtil.java:15
↓ 2 callersMethodflush
(final String topic, final int partition, CallbackContext ctx)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:357
↓ 2 callersMethodgetAckCheckerIntervalMillis
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:214
↓ 2 callersMethodgetAckCheckerResultTimeoutMillis
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:222
↓ 2 callersMethodgetAckFlushThreadCount
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:107
↓ 2 callersMethodgetAckMessagesTaskExecutorCheckIntervalMillis
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:51
↓ 2 callersMethodgetAckOpCheckIntervalMillis
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:23
↓ 2 callersMethodgetAckedMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/AckMessageCommandV3.java:187
↓ 2 callersMethodgetAckedMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v4/AckMessageCommandV4.java:196
↓ 2 callersMethodgetAcquireBrokerLease
(String topic, int partition, String sessionId, int brokerPort, int metaServerPort)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:701
↓ 2 callersMethodgetAssignment
(Pair<String, String> topicGroup)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ConsumerAssignmentHolder.java:74
↓ 2 callersMethodgetAssignmentWithoutCache
(String topic)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaServerAssignmentHolder.java:151
↓ 2 callersMethodgetBaseConsumerMessage
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/NackDelayedBrokerConsumerMessage.java:138
↓ 2 callersMethodgetBrokerAssignments
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaServerStatusResponse.java:59
↓ 2 callersMethodgetBrokerLease
(String uri, String topic, int partition, Long leaseId, String sessionId, int brokerPort, int metaServ
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:746
↓ 2 callersMethodgetBrokerSenderConcurrentLevel
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/status/ProducerConfigComponentStatus.java:56
↓ 2 callersMethodgetClazz
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/CommandType.java:132
↓ 2 callersMethodgetClientMaxIdleSeconds
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:39
↓ 2 callersMethodgetCodecByTopicName
(String topicName)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecFactory.java:19
↓ 2 callersMethodgetCommitterThreadCount
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PullConsumerConfig.java:47
↓ 2 callersMethodgetConnection
(String datasourceName)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:325
↓ 2 callersMethodgetConnectionString
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/server/MockKafka.java:90
↓ 2 callersMethodgetConnectionString
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/zk/ZKClient.java:114
↓ 2 callersMethodgetConsumer
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/Subscriber.java:77
↓ 2 callersMethodgetConsumerHeartbeatTimeoutMillis
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:42
↓ 2 callersMethodgetConsumerLease
(String uri, String sessionId, Long leaseId, Tpg tpg, int metaServerPort)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:724
↓ 2 callersMethodgetConsumerProperties
(String topic, String group)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/engine/KafkaConsumerBootstrap.java:223
↓ 2 callersMethodgetCurNonresendOffset
()
hermes-example/src/test/java/com/ctrip/hermes/example/ConsumerVerifier.java:353
↓ 2 callersMethodgetCursor
(String groupId, Lease lease, Offset offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:30
↓ 2 callersMethodgetDatas
()
hermes-core/src/main/java/com/ctrip/hermes/core/log/BizEvent.java:38
↓ 2 callersMethodgetDefaultLeaseAcquireDelayMillis
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:35
↓ 2 callersMethodgetDefaultLeaseRenewDelayMillis
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:33
← previousnext →801–900 of 4,501, ranked by callers