MCPcopy Create free account

hub / github.com/apache/bifromq / functions

Functions8,818 in github.com/apache/bifromq

⨍ Functions 8,818◇ Types & classes 1,945
↓ 80 callersMethodinvoke
Invoke a request to the desired server. @param tenantId the tenant id @param desiredServerId the desired server id, can be null @param req the reques
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/IRPCClient.java:56
↓ 80 callersMethodpublish
Publish message to the topic filters, and return the topic filters that are not subscribed. @param messagePack The message pack to publish. @
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/session/IMQTTTransientSession.java:39
↓ 80 callersMethodput
Put data into staging.
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/IRestoreSession.java:31
↓ 80 callersMethodupdate
(Set<KVRangeStoreDescriptor> landscape)
base-kv/base-kv-store-balance-controller/src/main/java/org/apache/bifromq/basekv/balance/impl/RangeLeaderBalancer.java:57
↓ 79 callersMethodcollect
()
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/stats/IStatsCollector.java:27
↓ 79 callersMethodlatestClusterConfig
Returns the latest cluster config of the raft cluster. @return the latest cluster config
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNode.java:123
↓ 78 callersMethodcurrentFollowers
()
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/functest/RaftNodeGroup.java:302
↓ 78 callersMethodfail
(Throwable throwable)
base-rpc/base-rpc-server/src/main/java/org/apache/bifromq/baserpc/server/AbstractResponsePipeline.java:128
↓ 76 callersMethodclear
(Boundary boundary)
base-kv/base-kv-store-coproc-api/src/main/java/org/apache/bifromq/basekv/store/api/IKVWriter.java:32
↓ 76 callersMethodclose
()
base-kv/base-kv-local-engine-rocksdb/src/main/java/org/apache/bifromq/basekv/localengine/rocksdb/IRocksDBKVSpaceCheckpoint.java:25
↓ 76 callersMethodstatus
role of the local raft node in current log term. @return the current status
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNode.java:55
↓ 74 callersMethodgetState
()
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNodeState.java:28
↓ 72 callersMethodinRange
Check if key is in range of startKey and endKey of a valid boundary. @param key key @param startKey startKey @param endKey endKey @return true
base-kv/base-kv-type-proto/src/main/java/org/apache/bifromq/basekv/utils/BoundaryUtil.java:241
↓ 71 callersMethodmessageId
(int messageId)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v3/MQTT3MessageBuilders.java:86
↓ 71 callersMethodsend
Send messages to recipient @return
base-cluster/src/main/java/org/apache/bifromq/basecluster/transport/ITransport.java:38
↓ 70 callersMethodcreate
(String name)
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/spi/ICallSchedulerFactory.java:26
↓ 70 callersMethodmockDistMatch
(QoS qos, boolean success)
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/handler/v3/BaseMQTTTest.java:353
↓ 70 callersMethodtype
()
base-kv/base-kv-store-balance-spi/src/main/java/org/apache/bifromq/basekv/balance/BalanceResult.java:24
↓ 69 callersMethodconnect
(MqttConnectionOptions options)
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/integration/v5/client/MqttTestClient.java:67
↓ 69 callersMethoddispose
()
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/util/FastBehaviorSubject.java:206
↓ 69 callersMethodmessage
(QoS qos, String payload)
bifromq-inbox/bifromq-inbox-store/src/test/java/org/apache/bifromq/inbox/store/InboxStoreTest.java:513
↓ 69 callersMethodtype
()
base-rpc/base-rpc-common/src/main/java/org/apache/bifromq/baserpc/BluePrint.java:126
↓ 68 callersMethodmax
()
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/MovingAverage.java:61
↓ 67 callersMethodget
(long ver, ByteString key, boolean linearized)
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/range/IKVRangeFSM.java:92
↓ 66 callersMethodhasNext
()
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/InMemoryStateStore.java:215
↓ 65 callersMethodget
(String tenantId, String delivererKey)
bifromq-inbox/bifromq-inbox-server/src/main/java/org/apache/bifromq/inbox/server/IInboxFetcherRegistry.java:29
↓ 65 callersMethodisRetain
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/RoutedMessage.java:80
↓ 64 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-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/IKVSpaceReader.java:52
↓ 64 callersMethodresponse
(MqttMessage message, Event<?>... reasons)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/record/ProtocolResponse.java:39
↓ 64 callersMethodtopicName
(String topic)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v3/MQTT3MessageBuilders.java:61
↓ 63 callersMethodrecord
The latency spent for accessing this key. @param key the accessed key @param latencyNanos the nanos spent
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/range/IKVLoadRecorder.java:32
↓ 63 callersMethodrequestAttach
(BatchAttachRequest.Params... params)
bifromq-inbox/bifromq-inbox-store/src/test/java/org/apache/bifromq/inbox/store/InboxStoreTest.java:373
↓ 62 callersMethodremove
(String sessionId, IMQTTSession session)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/service/ILocalSessionRegistry.java:29
↓ 61 callersMethodsubscribe
(long reqId, String topicFilter, QoS qos)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/session/IMQTTSession.java:33
↓ 60 callersMethodincrement
(double amount)
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/metrics/KVSpaceMeters.java:270
↓ 60 callersMethodtrace
(String msg)
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:111
↓ 58 callersMethodclose
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/IMQTTBroker.java:29
↓ 58 callersMethodhelper
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/MQTTSessionHandler.java:233
↓ 58 callersMethodtoValue
(Object v)
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/StructUtil.java:34
↓ 57 callersMethodcreateIfMissing
Create a new key range with specified spaceId and boundary or get existing key range. @param spaceId the space id @return the key range created
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/IKVEngine.java:53
↓ 57 callersMethodcurrentTerm
()
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNodeState.java:32
↓ 57 callersMethodisValidTopicFilter
(String topicFilter, int maxLevelLength, int maxLevel, int maxLength)
bifromq-util/src/main/java/org/apache/bifromq/util/TopicUtil.java:74
↓ 57 callersMethodsingleMap
(ByteString key, StateLattice val)
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/internal/ProtoUtils.java:81
↓ 57 callersMethodstate
Get the observable of state. @return the observable
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/range/IKVRange.java:54
↓ 56 callersMethodaddr
()
base-cluster/src/main/java/org/apache/bifromq/basecluster/messenger/IRecipient.java:25
↓ 56 callersMethodclientId
()
bifromq-util/src/test/java/org/apache/bifromq/util/UTF8UtilTest.java:33
↓ 56 callersMethodconnect
(String id)
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/functest/RaftNodeGroup.java:138
↓ 56 callersMethodhasResource
Determine if the tenant has enough resource of given type. @param tenantId the id of the tenant @param type the resource type @return true for th
bifromq-plugin/bifromq-plugin-resource-throttler/src/main/java/org/apache/bifromq/plugin/resourcethrottler/IResourceThrottler.java:32
↓ 56 callersMethodtoByteString
(int i)
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/util/KVUtil.java:31
↓ 56 callersMethodtoList
(Iterator<LogEntry> itr)
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/RaftNodeStateLeaderTest.java:784
↓ 55 callersMethodboundary
(String startKey, String endKey)
base-kv/base-kv-type-proto/src/test/java/org/apache/bifromq/basekv/utils/BoundaryUtilTest.java:525
↓ 55 callersMethodentrySet
()
base-rpc/base-rpc-client/src/main/java/org/apache/bifromq/baserpc/client/loadbalancer/TrieMap.java:229
↓ 55 callersMethodlastIndex
The index of the last entry in the log. It will be 0 when there is no log entry For non-empty logs, invariant firstIndex less than or equal lastIndex
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftStateStore.java:130
↓ 55 callersMethoduserSessionId
(ClientInfo info)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/MQTTSessionIdUtil.java:33
↓ 54 callersMethodcreate
(KVRangeId kvRangeId, Snapshot initSnapshot)
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/wal/IKVRangeWALStoreEngine.java:33
↓ 54 callersMethodhandle
(long reqId, FullHttpRequest req)
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/http/IHTTPRequestHandler.java:33
↓ 54 callersMethodmatch
(long reqId, String topicFilter,
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/service/ILocalDistService.java:48
↓ 54 callersMethodtick
tick from external clock which driving Raft StateMachine to move forward.
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNode.java:60
↓ 53 callersMethodbuilder
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/IMQTTBroker.java:23
↓ 53 callersMethodmetadata
Get an observable stream of metadata key-value pairs. @return the observable stream
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/IKVSpace.java:35
↓ 53 callersMethodput
Put a key value pair, if the key is existed, its value will be overridden. @param key the key to put @param value the value to put
base-kv/base-kv-store-coproc-api/src/main/java/org/apache/bifromq/basekv/store/api/IKVWriter.java:48
↓ 52 callersMethodappend
Append log entries after specified index, if flush is true, registered StableListener must be called immediately after the appended entries has been s
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftStateStore.java:158
↓ 52 callersMethodmockAuthCheck
(boolean allow)
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/handler/v3/BaseMQTTTest.java:291
↓ 52 callersMethodsender
()
bifromq-plugin/bifromq-plugin-event-collector/src/main/java/org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/PushEvent.java:58
↓ 52 callersMethodtoString
()
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/Headers.java:49
↓ 51 callersMethoddone
Atomically publish staging to be visible.
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/IRestoreSession.java:41
↓ 51 callersMethodgetTopic
(MqttPublishMessage message)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/IMQTTProtocolHelper.java:105
↓ 50 callersMethoddescriptor
(KVRangeId id, Boundary boundary, long hlc)
base-kv/base-kv-store-client/src/test/java/org/apache/bifromq/basekv/client/KVRangeRouterUtilTest.java:404
↓ 50 callersMethoddisconnect
()
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/MQTT5MessageBuilders.java:68
↓ 50 callersMethodgenesisKVRangeId
()
base-kv/base-kv-store-server/src/test/java/org/apache/bifromq/basekv/store/KVRangeStoreTestCluster.java:145
↓ 50 callersMethodlastIndex
()
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNodeState.java:36
↓ 50 callersMethodlogWithMDC
(Supplier<Optional<Level>> isEnabled, Marker marker, String msg, Object[] args, Th
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:71
↓ 50 callersMethodmessage
(RoutedMessage message)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/MQTT5MessageBuilders.java:376
↓ 50 callersMethodpacketId
(int packetId)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/v5/MQTT5MessageBuilders.java:356
↓ 49 callersMethodid
The global unique id of the store. @return the id
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/store/ICRDTStore.java:52
↓ 48 callersMethodboundary
(String startKey, String endKey)
base-kv/base-kv-store-balance-spi/src/test/java/org/apache/bifromq/basekv/balance/util/CommandUtilTest.java:428
↓ 48 callersMethodgetLogger
(Class<?> clazz, String... tags)
base-logger/src/main/java/org/apache/bifromq/logger/MDCLogger.java:59
↓ 48 callersMethodid
the id of local raft node. @return the id of the node
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftNode.java:48
↓ 48 callersMethodlatestEffectiveRouter
()
base-kv/base-kv-store-client/src/main/java/org/apache/bifromq/basekv/client/IBaseKVStoreClient.java:60
↓ 48 callersMethodparse
(String value)
bifromq-sysprops/src/main/java/org/apache/bifromq/sysprops/parser/PropParser.java:28
↓ 48 callersMethodpeerAddress
()
bifromq-plugin/bifromq-plugin-event-collector/src/main/java/org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/ChannelClosedEvent.java:39
↓ 47 callersMethodgetHeader
(Headers header, HttpRequest req, boolean required)
bifromq-apiserver/src/main/java/org/apache/bifromq/apiserver/http/handler/utils/HeaderUtils.java:66
↓ 47 callersMethodremember
(Map<ByteString, NavigableMap<Long, Long>> historyMap, ByteString replicaId, l
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/util/LatticeIndexUtil.java:28
↓ 46 callersMethodawaitKVRangeReady
(String storeId, KVRangeId kvRangeId)
base-kv/base-kv-store-server/src/test/java/org/apache/bifromq/basekv/store/KVRangeStoreTestCluster.java:188
↓ 46 callersMethodcompare
Compare two byte arrays lexicographically. @param a byte array a @param b byte array b @return -1 if a < b, 0 if a == b, 1 if a > b
base-kv/base-kv-type-proto/src/main/java/org/apache/bifromq/basekv/utils/BoundaryUtil.java:122
↓ 46 callersMethodfarewell
(MqttMessage farewell, Event<?>... reasons)
bifromq-mqtt/bifromq-mqtt-server/src/main/java/org/apache/bifromq/mqtt/handler/record/ProtocolResponse.java:51
↓ 46 callersMethodget
(String tenantId, String userId, String mqttClientId)
bifromq-session-dict/bifromq-session-dict-server/src/main/java/org/apache/bifromq/sessiondict/server/ISessionRegistry.java:34
↓ 46 callersMethodhashCode
()
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/metrics/KVSpaceMeters.java:318
↓ 46 callersMethodrun
Perform mutation with write lock. @param mutation the mutation to perform @return boolean indicating if generation is bumped after the mutation
base-kv/base-kv-local-engine-spi/src/main/java/org/apache/bifromq/basekv/localengine/ISyncContext.java:81
↓ 46 callersMethodsplit
Split a KVRange into two KVRanges, the new KVRange will be hosted by the current store. @param ver the version of the KVRange @param id the id of the
base-kv/base-kv-store-server/src/main/java/org/apache/bifromq/basekv/store/IKVRangeStore.java:132
↓ 46 callersMethodsubmit
Schedule a call to be called in the future when the returned future completed. The returned future could be completed with DropException @param reque
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/spi/ICallScheduler.java:37
↓ 45 callersMethodconnect
(MqttConnectOptions options)
bifromq-mqtt/bifromq-mqtt-server/src/test/java/org/apache/bifromq/mqtt/integration/v3/client/MqttTestClient.java:58
↓ 44 callersMethodkey
()
base-crdt/base-crdt-store/src/main/java/org/apache/bifromq/basecrdt/core/api/IORMap.java:28
↓ 44 callersMethodlocal
Identifier of the raft node. @return id of raft node
base-kv/base-kv-raft/src/main/java/org/apache/bifromq/basekv/raft/IRaftStateStore.java:51
↓ 44 callersMethodmembership
A hot observable of agent membership. @return an observable that emits the current membership map
base-cluster/src/main/java/org/apache/bifromq/basecluster/memberlist/agent/IAgent.java:52
↓ 44 callersMethodopenMocks
()
base-kv/base-kv-raft/src/test/java/org/apache/bifromq/basekv/raft/QuorumTrackerTest.java:38
↓ 44 callersMethodtoString
()
base-kv/base-kv-store-balance-spi/src/main/java/org/apache/bifromq/basekv/balance/command/QuitCommand.java:37
↓ 44 callersMethodupperBound
Get the least upper bound of a key. @param key key @return least upper bound of the key, or null stands for open end
base-kv/base-kv-type-proto/src/main/java/org/apache/bifromq/basekv/utils/BoundaryUtil.java:299
↓ 43 callersMethodexecute
Execute the async batch call. @return a future which will complete when batch is done
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/IBatchCall.java:51
↓ 43 callersMethodget
The factory method to create an instance of {@link ICapacityEstimator}. @param name the name of scheduler @param batcherKey the key of the batcher @r
base-scheduler/src/main/java/org/apache/bifromq/basescheduler/spi/ICapacityEstimatorFactory.java:33
← previousnext →101–200 of 8,818, ranked by callers