MCPcopy Create free account

hub / github.com/apache/bifromq / types & classes

Types & classes1,945 in github.com/apache/bifromq

⨍ Functions 8,818◇ Types & classes 1,945
Class$
bifromq-plugin/bifromq-plugin-archetype/src/main/resources/archetype-resources/auth-provider/src/main/java/__pluginName__AuthProvider.java:40
Class$
bifromq-plugin/bifromq-plugin-archetype/src/main/resources/archetype-resources/plugin-build/src/main/java/__pluginName__.java:32
Class$
bifromq-plugin/bifromq-plugin-archetype/src/main/resources/archetype-resources/plugin-context/src/main/java/__pluginContextName__.java:27
ClassAPIServer
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/APIServer.java:53
ClassAPIServerTest
bifromq-apiserver/src/test/java/org/apache/bifromq/apiserver/APIServerTest.java:55
ClassAWORSet
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/AWORSet.java:28
ClassAWORSetCoalesceOperation
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/AWORSetCoalesceOperation.java:30
ClassAWORSetInflater
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/AWORSetInflater.java:30
ClassAWORSetOperation
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/api/AWORSetOperation.java:25
ClassAWORSetTest
base-crdt/base-crdt-store/src/test/java/org/apache/bifromq/basecrdt/core/internal/AWORSetTest.java:36
ClassAbnormalTest
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/functest/AbnormalTest.java:34
ClassAbortException
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/exception/RecoveryException.java:57
ClassAbortException
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/exception/AbortException.java:22
EnumAbortReason
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/RaftNodeStateLeader.java:907
ClassAbstractBalancerStateProposerHandler
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/http/handler/AbstractBalancerStateProposerHandler.java:29
ClassAbstractCPableEngineTest
base-kv/base-kv-local-engine-spi/src/test/java/org/apache/bifromq/basekv/localengine/AbstractCPableEngineTest.java:31
ClassAbstractHTTPRequestHandlerTest
bifromq-apiserver/src/test/java/org/apache/bifromq/apiserver/http/handler/AbstractHTTPRequestHandlerTest.java:46
ClassAbstractInMemKVSpaceReader
base-kv/base-kv-local-engine-memory/src/main/java/org/apache/bifromq/basekv/localengine/memory/AbstractInMemKVSpaceReader.java:30
ClassAbstractKVEngine
The abstract class of KVEngine. @param <T> the type of KV space created by the engine
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/AbstractKVEngine.java:45
ClassAbstractKVEngineTest
base-kv/base-kv-local-engine-spi/src/test/java/org/apache/bifromq/basekv/localengine/AbstractKVEngineTest.java:31
ClassAbstractKVRangeTest
base-kv/base-kv-store-server/src/test/java/org/apache/bifromq/basekv/store/range/AbstractKVRangeTest.java:39
ClassAbstractKVSpace
Base implementation of IKVSpace. @param <P> the type of epoch
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/AbstractKVSpace.java:41
ClassAbstractKVSpaceReader
The base implementation of IKVSpaceReader with operation metrics.
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/AbstractKVSpaceReader.java:31
ClassAbstractLandscapeHandler
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/http/handler/AbstractLandscapeHandler.java:29
ClassAbstractRawRocksDBTest
base-kv/base-kv-local-engine-rocksdb/src/test/java/org/apache/bifromq/basekv/localengine/rocksdb/AbstractRawRocksDBTest.java:33
ClassAbstractResponsePipeline
base-rpc/base-rpc-server/src/main/java/org/apache/bifromq/baserpc/server/AbstractResponsePipeline.java:32
ClassAbstractRocksDBCPableEngineTest
base-kv/base-kv-local-engine-rocksdb/src/test/java/org/apache/bifromq/basekv/localengine/rocksdb/AbstractRocksDBCPableEngineTest.java:40
ClassAbstractRocksDBKVSpaceReader
base-kv/base-kv-local-engine-rocksdb/src/main/java/org/apache/bifromq/basekv/localengine/rocksdb/AbstractRocksDBKVSpaceReader.java:35
ClassAbstractRocksDBWALableEngineTest
base-kv/base-kv-local-engine-rocksdb/src/test/java/org/apache/bifromq/basekv/localengine/rocksdb/AbstractRocksDBWALableEngineTest.java:36
ClassAbstractServerInitializer
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/AbstractServerInitializer.java:27
ClassAbstractStreamObserver
base-rpc/base-rpc-server/src/main/java/org/apache/bifromq/baserpc/server/AbstractStreamObserver.java:29
ClassAbstractTrafficRulesHandler
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/http/handler/AbstractTrafficRulesHandler.java:29
ClassAbstractTrafficRulesHandlerTest
bifromq-apiserver/src/test/java/org/apache/bifromq/apiserver/http/handler/AbstractTrafficRulesHandlerTest.java:40
ClassAbstractTransport
base-cluster/src/main/java/org/apache/bifromq/basecluster/transport/AbstractTransport.java:37
ClassAbstractWALableEngineTest
base-kv/base-kv-local-engine-spi/src/test/java/org/apache/bifromq/basekv/localengine/AbstractWALableEngineTest.java:22
ClassAccessControlError
bifromq-plugin/bifromq-plugin-event-collector/src/main/java/org/apache/bifromq/plugin/eventcollector/mqttbroker/accessctrl/AccessControlError.java:29
ClassAckStream
base-rpc/base-rpc-server/src/main/java/org/apache/bifromq/baserpc/server/AckStream.java:28
EnumAction
base-kv/base-kv-store-server/src/test/java/org/apache/bifromq/basekv/store/KVRangeStoreTestCluster.java:748
EnumAction
The action to take when selecting the branches.
bifromq-util/src/main/java/org/apache/bifromq/util/index/TopicLevelTrie.java:404
EnumAction
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/record/ProtocolResponse.java:26
ClassAdaptiveReceiveQuota
Adaptive, congestion-aware receive quota controller for MQTT sessions. <p/> Estimates a proper in-flight window by tracking RTT with dual EWMAs, detec
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/AdaptiveReceiveQuota.java:32
ClassAdaptiveReceiveQuotaTest
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/handler/AdaptiveReceiveQuotaTest.java:28
ClassAdaptiveWriteBudget
base-kv/base-kv-local-engine-rocksdb/src/main/java/org/apache/bifromq/basekv/localengine/rocksdb/AdaptiveWriteBudget.java:24
ClassAdaptiveWriteBudgetTest
base-kv/base-kv-local-engine-rocksdb/src/test/java/org/apache/bifromq/basekv/localengine/rocksdb/AdaptiveWriteBudgetTest.java:28
ClassAddRouteException
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/service/LocalTopicRouter.java:209
ClassAgent
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/agent/Agent.java:55
ClassAgentAddressProvider
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/agent/AgentAddressProvider.java:30
ClassAgentHost
base-cluster/src/main/java/org/apache/bifromq/basecluster/AgentHost.java:64
ClassAgentHostMeta
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentTestCluster.java:173
ClassAgentHostNode1
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentHostNode1.java:35
ClassAgentHostNode2
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentHostNode2.java:34
ClassAgentHostNode3
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentHostNode3.java:32
ClassAgentHostOptions
base-cluster/src/main/java/org/apache/bifromq/basecluster/AgentHostOptions.java:33
ClassAgentHostProviderTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/memberlist/agent/AgentHostProviderTest.java:37
ClassAgentHostStoreMessenger
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/server/AgentHostStoreMessenger.java:41
ClassAgentHostStoreMessengerTest
base-kv/base-kv-store-server/src/test/java/org/apache/bifromq/basekv/server/AgentHostStoreMessengerTest.java:50
ClassAgentHostTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentHostTest.java:24
ClassAgentHostsTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentHostsTest.java:44
ClassAgentMember
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/agent/AgentMember.java:49
ClassAgentMemberTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/memberlist/agent/AgentMemberTest.java:68
ClassAgentMessenger
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/agent/AgentMessenger.java:34
ClassAgentMessengerTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/memberlist/agent/AgentMessengerTest.java:53
ClassAgentTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/memberlist/agent/AgentTest.java:65
ClassAgentTestCluster
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentTestCluster.java:45
ClassAgentTestTemplate
base-cluster/src/test/java/org/apache/bifromq/basecluster/AgentTestTemplate.java:31
ClassAgentUtil
base-crdt/base-crdt-service/src/main/java/org/apache/bifromq/basecrdt/service/AgentUtil.java:27
ClassAggregatedUserPropsCustomizer
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/spi/UserPropsCustomizer.java:80
ClassAliasCreationResult
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/SenderTopicAliasManager.java:31
ClassAliasEntry
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/SenderTopicAliasManager.java:99
ClassAliasManagerState
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/SenderTopicAliasManager.java:53
ClassAnnotationUtil
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/http/AnnotationUtil.java:33
ClassAntiEntropy
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/store/AntiEntropy.java:44
ClassAntiEntropyManager
Manage a hosted replica's anti-entropy process with its neighbors.
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/store/AntiEntropyManager.java:56
ClassAntiEntropyResilienceTest
base-crdt/base-crdt-store/src/test/java/org/apache/bifromq/basecrdt/store/AntiEntropyResilienceTest.java:45
ClassAsyncRetry
An asynchronous retry utility with exponential backoff, supporting cooperative cancellation: cancel() on the returned future cancels the in-flight tas
base-util/src/main/java/org/apache/bifromq/base/util/AsyncRetry.java:41
ClassAsyncRetryTest
base-util/src/test/java/org/apache/bifromq/base/util/AsyncRetryTest.java:38
ClassAsyncRunner
AsyncRunner is a utility class that allows for the execution of tasks asynchronously in submission order.
base-util/src/main/java/org/apache/bifromq/base/util/AsyncRunner.java:38
ClassAsyncRunnerTest
base-util/src/test/java/org/apache/bifromq/base/util/AsyncRunnerTest.java:45
ClassAuthBuilder
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/MQTT5MessageBuilders.java:100
ClassAuthError
bifromq-plugin/bifromq-plugin-event-collector/src/main/java/org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/AuthError.java:25
ClassAuthProviderManager
bifromq-plugin/bifromq-plugin-auth-provider-helper/src/main/java/org/apache/bifromq/plugin/authprovider/AuthProviderManager.java:51
ClassAuthProviderManagerTest
bifromq-plugin/bifromq-plugin-auth-provider-helper/src/test/java/org/apache/bifromq/plugin/authprovider/AuthProviderManagerTest.java:66
ClassAuthResult
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/MQTTConnectHandler.java:673
ClassAuthUtil
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/utils/AuthUtil.java:52
ClassAutoCleaner
base-kv/base-kv-local-engine-rocksdb/src/main/java/org/apache/bifromq/basekv/localengine/rocksdb/AutoCleaner.java:25
ClassAutoDropper
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/AutoDropper.java:68
ClassAutoHealer
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/AutoHealer.java:48
ClassAutoHealerTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/memberlist/AutoHealerTest.java:64
ClassAutoSeeder
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/AutoSeeder.java:45
ClassAutoSeederTest
base-cluster/src/test/java/org/apache/bifromq/basecluster/memberlist/AutoSeederTest.java:61
ClassAwaitBalance
Await some time to generate balance command.
base-kv/base-kv-store-balance-spi/src/main/java/org/apache/bifromq/basekv/balance/AwaitBalance.java:27
ClassBSUtil
bifromq-util/src/main/java/org/apache/bifromq/util/BSUtil.java:28
ClassBackPressureException
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/exception/BackPressureException.java:22
ClassBadPacket
bifromq-plugin/bifromq-plugin-event-collector/src/main/java/org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/BadPacket.java:28
ClassBadRequest
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/exception/KVRangeException.java:70
ClassBadRequestException
base-kv/base-kv-store-client/src/main/java/org/apache/bifromq/basekv/client/exception/BadRequestException.java:22
ClassBadVersion
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/exception/KVRangeException.java:57
ClassBadVersionException
base-kv/base-kv-store-client/src/main/java/org/apache/bifromq/basekv/client/exception/BadVersionException.java:22
ClassBalanceCommand
base-kv/base-kv-store-balance-spi/src/main/java/org/apache/bifromq/basekv/balance/command/BalanceCommand.java:27
EnumBalanceMode
THe balance mod of method.
base-rpc/base-rpc-common/src/main/java/org/apache/bifromq/baserpc/BluePrint.java:112
next →1–100 of 1,945, ranked by callers