MCPcopy Create free account

hub / github.com/apache/bifromq / functions

Functions8,818 in github.com/apache/bifromq

⨍ Functions 8,818◇ Types & classes 1,945
↓ 4,247 callersMethodbuild
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/IMQTTBrokerBuilder.java:33
↓ 1,632 callersMethodnewBuilder
()
base-kv/base-kv-store-client/src/main/java/org/apache/bifromq/basekv/client/IBaseKVStoreClient.java:52
↓ 1,159 callersMethodnewBuilder
()
bifromq-inbox/bifromq-inbox-client/src/main/java/org/apache/bifromq/inbox/client/IInboxClient.java:49
↓ 734 callersMethodverify
(Map<Boundary, ClusterConfig> rangeLayout, Set<KVRangeStoreDescriptor> landscape)
base-kv/base-kv-store-balance-controller/src/main/java/org/apache/bifromq/basekv/balance/impl/RuleBasedPlacementBalancer.java:158
↓ 663 callersMethodget
Get the value of the specified key in the KVRange. @param ver the version of the KVRange @param id the id of the KVRange @param key the key to be get
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/IKVRangeStore.java:165
↓ 651 callersMethodjoin
Join the cluster as a running node by communicating with some existing running node of the cluster as the seeds. @param seeds the seeds of the cluste
base-cluster/src/main/java/org/apache/bifromq/basecluster/IAgentHost.java:73
↓ 606 callersMethodadd
Add a call task to the batch. @param task the task to be fulfilled in the batch
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/IBatchCall.java:37
↓ 599 callersMethodnewBuilder
()
bifromq-mqtt/bifromq-mqtt-broker-client/src/main/java/org/apache/bifromq/mqtt/inbox/IMqttBrokerClient.java:31
↓ 595 callersMethodput
Put a key-value pair into the KVRange. @param ver the version of the KVRange @param id the id of the KVRange @param key the key to be put @param valu
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/IKVRangeStore.java:187
↓ 573 callersMethodnanoTime
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/session/MQTTSessionContext.java:101
↓ 508 callersMethodof
(CausalCRDTType valueType)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/api/ORMapOperation.java:44
↓ 501 callersMethodawait
(int ticks)
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/functest/RaftNodeGroup.java:267
↓ 499 callersMethodget
(MethodDescriptor<?, ?> methodDescriptor)
base-rpc/base-rpc-common/src/main/java/org/apache/bifromq/baserpc/metrics/IRPCMeter.java:36
↓ 462 callersMethoddebug
(String msg)
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:179
↓ 444 callersMethodget
(int size)
base-kv/base-kv-type-proto/src/main/java/org/apache/bifromq/basekv/utils/BoundaryUtil.java:544
↓ 434 callersMethodisEmpty
()
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/api/IRWORSet.java:31
↓ 364 callersMethodgetId
()
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/metrics/KVSpaceMeters.java:176
↓ 352 callersMethodgetValue
()
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/loadbalancer/TrieMap.java:252
↓ 350 callersMethodinfo
(String msg)
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:247
↓ 339 callersMethodequals
()
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/event/RaftEventTest.java:48
↓ 311 callersMethodget
(String tenantId, String inboxId, long incarnation, InboxMetadataProvider provider)
bifromq-inbox/bifromq-inbox-store/src/main/java/org/apache/bifromq/inbox/store/IInboxMetaCache.java:28
↓ 305 callersMethodsize
The number of branches in the table. @return number of branches
bifromq-util/src/main/java/org/apache/bifromq/util/index/BranchTable.java:34
↓ 287 callersMethodcomplete
(Long readIndex)
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/ReadProgressTracker.java:106
↓ 286 callersMethodforEach
Iterate all entries without materializing an intermediate map.
bifromq-util/src/main/java/org/apache/bifromq/util/index/BranchTable.java:48
↓ 277 callersMethodvalue
(Dot dot)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/IDotFunc.java:29
↓ 274 callersMethodbuild
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/service/ILocalSessionServerBuilder.java:23
↓ 273 callersMethodclientInfo
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/session/IMQTTSession.java:31
↓ 273 callersMethodgetLocal
(Class<T> eventClass)
bifromq-plugin/bifromq-plugin-event-collector-helper/src/main/java/org/apache/bifromq/plugin/eventcollector/ThreadLocalEventPool.java:59
↓ 268 callersMethodget
(String sessionId)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/service/ILocalSessionRegistry.java:31
↓ 261 callersMethodcontains
(ByteString element)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/api/IRWORSet.java:35
↓ 256 callersMethodonNext
()
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/IBiDiStream.java:25
↓ 251 callersMethodremove
(String tenantId, String inboxId, long incarnation)
bifromq-inbox/bifromq-inbox-store/src/main/java/org/apache/bifromq/inbox/store/IInboxMetaCache.java:32
↓ 247 callersMethodsize
The current estimated size of the KVRange. @return the size in bytes
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/range/IKVRange.java:165
↓ 241 callersMethodreport
Implement this method to receive various events at runtime. <p> Note: To reduce memory pressure, the argument event object will be reused in later cal
bifromq-plugin/bifromq-plugin-event-collector/src/main/java/org/apache/bifromq/plugin/eventcollector/IEventCollector.java:33
↓ 222 callersMethodnewBuilder
()
base-rpc/base-rpc-server/src/main/java/org/apache/bifromq/baserpc/server/IRPCServer.java:23
↓ 218 callersMethodvalues
()
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/IDotFunc.java:27
↓ 216 callersMethodbuilder
()
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/server/IBaseKVStoreServer.java:26
↓ 215 callersMethodadd
(String sessionId, IMQTTSession session)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/service/ILocalSessionRegistry.java:27
↓ 212 callersMethodstream
(T value)
base-rpc/base-rpc-common/src/main/java/org/apache/bifromq/baserpc/marshaller/HLCStampedMarshaller.java:51
↓ 209 callersMethodverifyEvent
(EventType... types)
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/handler/v3/BaseMQTTTest.java:429
↓ 205 callersMethodget
Get a branch by key or null if absent.
bifromq-util/src/main/java/org/apache/bifromq/util/index/BranchTable.java:37
↓ 203 callersMethodjoin
Join a memberAddrs from specified local address. Some remote memberAddrs will be selected to be the neighbors with which the local replica keeps synch
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/store/ICRDTStore.java:77
↓ 199 callersMethodgetName
()
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:97
↓ 198 callersMethodadvanceTimeBy
(long duration, TimeUnit unit)
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/utils/TestTicker.java:42
↓ 184 callersMethodexecute
Execute an CRDT operation asynchronously. @param op the operation @return a future of the execution
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/api/ICausalCRDT.java:52
↓ 183 callersMethoderror
(String msg)
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:383
↓ 174 callersMethodkvRangeSetting
(KVRangeId kvRangeId)
base-kv/base-kv-store-server/src/test/java/org/apache/bifromq/basekv/store/KVRangeStoreTestCluster.java:183
↓ 168 callersMethodsize
()
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/IReplicaStateLattice.java:38
↓ 163 callersMethodkeySet
()
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/loadbalancer/TrieMap.java:190
↓ 161 callersMethodregister
Register a local agent member. It's allowed to register same member name in same logical agent from different agent hosts @param memberName the membe
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/agent/IAgent.java:60
↓ 158 callersMethoddot
(ByteString replicaId, long ver)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/ProtoUtils.java:40
↓ 155 callersMethodawaitIndexCommitted
(String id, long index)
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/functest/RaftNodeGroup.java:239
↓ 154 callersMethodcurrentLeader
()
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNodeState.java:30
↓ 152 callersMethodprovide
Provide a value of the setting for given tenant. The method will be called by BifroMQ working thread, so it's expected to be performant and non-blocki
bifromq-plugin/bifromq-plugin-setting-provider/src/main/java/org/apache/bifromq/plugin/settingprovider/ISettingProvider.java:35
↓ 147 callersMethodequals
(Object o)
bifromq-util/src/test/java/org/apache/bifromq/util/index/Box.java:29
↓ 145 callersMethodnewBuilder
()
bifromq-retain/bifromq-retain-client/src/main/java/org/apache/bifromq/retain/client/IRetainClient.java:34
↓ 143 callersMethodisDone
()
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/RaftNodeStateLeader.java:995
↓ 143 callersMethodsubscribe
(long lastFetchedIndex, IKVRangeWALSubscriber subscriber, Executor executor)
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/wal/IKVRangeWAL.java:68
↓ 142 callersMethoditerator
Get an iterator for the KVRange sharing same consistent-view. @return the iterator.
base-kv/base-kv-store-coproc-api/src/main/java/org/apache/bifromq/basekv/store/api/IKVRangeReader.java:97
↓ 141 callersMethodget
Get the server group router for the tenant. @param tenantId tenant id @return server group router
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/loadbalancer/ITenantRouter.java:29
↓ 137 callersMethodcontainsKey
(Object key)
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/loadbalancer/TrieMap.java:103
↓ 132 callersMethodapply
(IKVRangeRefreshableReader rangeReader)
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/range/KVRangeQueryRunner.java:210
↓ 131 callersMethodschedule
Schedule a new delayedTask. @param key the key under monitoring @param delayedTask the delayedTask to be triggered @param <TaskT> the typ
bifromq-inbox/bifromq-inbox-store/src/main/java/org/apache/bifromq/inbox/store/delay/IDelayTaskRunner.java:37
↓ 128 callersMethodmockCheckPermission
(boolean allow)
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/handler/BaseSessionHandlerTest.java:276
↓ 127 callersMethodget
()
base-kv/base-kv-local-engine-rocksdb/src/main/java/org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceEpochHandle.java:403
↓ 125 callersMethodgetPhysical
()
base-hlc/src/main/java/org/apache/bifromq/basehlc/HLC.java:141
↓ 123 callersMethodreasonCode
(MQTT5AuthReasonCode reasonCode)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/MQTT5MessageBuilders.java:116
↓ 122 callersMethodgetKey
(T node)
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/loadbalancer/HRWRouter.java:101
↓ 120 callersMethodassertSame
(Iterator<E> a, Iterator<E> b)
base-crdt/base-crdt-store/src/test/java/org/apache/bifromq/basecrdt/core/internal/TestUtil.java:33
↓ 117 callersMethodgenerate
Generate the first KVRangeId in new epoch. @return a new KVRangeId object
base-kv/base-kv-type-proto/src/main/java/org/apache/bifromq/basekv/utils/KVRangeIdUtil.java:34
↓ 116 callersMethodtoString
(KVRangeId kvRangeId)
base-kv/base-kv-type-proto/src/main/java/org/apache/bifromq/basekv/utils/KVRangeIdUtil.java:59
↓ 113 callersMethodresultPromise
the promise of the result of the call. @return the promise of the result
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/ICallTask.java:45
↓ 112 callersMethodpoll
(String voter, boolean vote)
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/QuorumTracker.java:58
↓ 110 callersMethodchannel
()
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/IClientChannel.java:29
↓ 109 callersMethodcall
the call of the task. @return the call to be fulfilled
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/ICallTask.java:38
↓ 107 callersMethodempty
()
bifromq-util/src/main/java/org/apache/bifromq/util/index/EmptyBranchTable.java:35
↓ 107 callersMethodresolve
(HostEndpoint endpoint)
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/IHostAddressResolver.java:26
↓ 106 callersMethodpayload
(ByteString payload)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v3/MQTT3MessageBuilders.java:81
↓ 105 callersMethodtopic
()
bifromq-plugin/bifromq-plugin-event-collector/src/main/java/org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/DistEvent.java:42
↓ 102 callersMethodsingleDot
(ByteString replicaId, long ver)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/ProtoUtils.java:62
↓ 100 callersMethodaccept
(InboxFetched inboxFetched)
bifromq-inbox/bifromq-inbox-client/src/main/java/org/apache/bifromq/inbox/client/InboxFetchPipeline.java:94
↓ 99 callersMethodwarn
(String msg)
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:315
↓ 96 callersMethodconcat
(ByteString... keys)
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/util/KVUtil.java:103
↓ 96 callersMethodcurrent
The current effective setting's value for given tenant. @param tenantId the id of the calling tenant @return The effective value of the setting for t
bifromq-plugin/bifromq-plugin-setting-provider/src/main/java/org/apache/bifromq/plugin/settingprovider/Setting.java:101
↓ 96 callersMethodwhenComplete
(BiConsumer<Void, Throwable> biConsumer)
base-util/src/main/java/org/apache/bifromq/base/util/FutureTracker.java:55
↓ 94 callersMethodnext
()
base-kv/base-kv-store-coproc-api/src/main/java/org/apache/bifromq/basekv/store/api/IKVIterator.java:34
↓ 94 callersMethodread
()
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/api/IMVReg.java:31
↓ 94 callersMethodtoString
()
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/metrics/KVSpaceMeters.java:323
↓ 93 callersMethodget
Get the value of a key. @param key the key @return the value of the key, or empty if the key does not exist
base-kv/base-kv-store-coproc-api/src/main/java/org/apache/bifromq/basekv/store/api/IKVRangeReader.java:90
↓ 92 callersMethodbalance
()
base-kv/base-kv-store-balance-controller/src/main/java/org/apache/bifromq/basekv/balance/impl/RangeLeaderBalancer.java:66
↓ 92 callersMethodnewBuilder
()
bifromq-session-dict/bifromq-session-dict-client/src/main/java/org/apache/bifromq/sessiondict/client/ISessionDictClient.java:41
↓ 89 callersMethodpropose
Propose a app command. The returned future is guaranteed to be completed when the corresponding log entry is COMMITTED or finished with exception indi
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNode.java:69
↓ 85 callersMethodgetType
(ByteString typedKey)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/ORMapUtil.java:34
↓ 84 callersMethodreplacement
(Dot... dots)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/ProtoUtils.java:48
↓ 83 callersMethodallKVRangeIds
()
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/wal/IKVRangeWALStoreEngine.java:35
↓ 82 callersMethodauth
Implement this method to hook authentication logic of mqtt3 client into BifroMQ. @param authData the authentication data
bifromq-plugin/bifromq-plugin-auth-provider/src/main/java/org/apache/bifromq/plugin/authprovider/IAuthProvider.java:46
↓ 82 callersMethodreasonString
(MqttProperties mqttProperties)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/MQTT5MessageUtils.java:136
↓ 80 callersMethodcancel
(String message)
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/IBiDiStream.java:33
↓ 80 callersMethodcheckPermission
Implement this method to hook action permission check logic. @param client the client to check permission @param action the action @return CheckResul
bifromq-plugin/bifromq-plugin-auth-provider/src/main/java/org/apache/bifromq/plugin/authprovider/IAuthProvider.java:131
↓ 80 callersMethodfrom
(String topicFilter)
bifromq-util/src/main/java/org/apache/bifromq/util/TopicUtil.java:252
next →1–100 of 8,818, ranked by callers