MCPcopy Create free account

hub / github.com/apache/kvrocks / functions

Functions3,913 in github.com/apache/kvrocks

↓ 2 callersMethodRadiusByMember
src/types/redis_geo.cc:96
↓ 2 callersFunctionRandomSignedInt
RandomSignedInt returns an integer in (-maxInt, maxInt)
tests/gocase/util/random.go:39
↓ 2 callersMethodRangeByValue
src/types/redis_sortedint.cc:156
↓ 2 callersFunctionRedisGenericCommand
TODO: we do not want to repeat same logic as Connection::ExecuteCommands, so the function need to be refactored
src/storage/scripting.cc:771
↓ 2 callersFunctionRedisReturnSingleFieldTable
Returns a table with a single field 'field' set to the string value * passed as argument. This helper function is handy when returning * a Redis Pro
src/storage/scripting.cc:963
↓ 2 callersFunctionRegexMatch
src/common/string_util.cc:390
↓ 2 callersMethodRelease
src/common/observer_or_unique.h:51
↓ 2 callersMethodRemains
src/commands/command_parser.h:88
↓ 2 callersMethodRemovePausedConn
src/server/server.cc:1076
↓ 2 callersFunctionRemovePidFile
src/cli/pid_util.h:44
↓ 2 callersFunctionReplyToRedisReply
this function does not pop any element on the stack
src/storage/scripting.cc:1275
↓ 2 callersMethodReset
src/search/ir_pass.h:34
↓ 2 callersMethodReset
Only HARD mode is meaningful to the Kvrocks cluster, so it will force clearing all information after resetting.
src/cluster/cluster.cc:962
↓ 2 callersMethodResume
src/cluster/sync_migrate_context.cc:34
↓ 2 callersMethodRevRange
src/types/redis_timeseries.cc:2049
↓ 2 callersMethodSSubscriptionsCount
src/server/redis_connection.cc:358
↓ 2 callersFunctionScanTest
(t *testing.T, rdb *redis.Client, ctx context.Context)
tests/gocase/unit/scan/scan_test.go:140
↓ 2 callersMethodScriptReset
src/server/server.cc:1938
↓ 2 callersFunctionSegmentSubKeyIndexForBit
Constructing sub-key index, see: https://kvrocks.apache.org/community/data-structure-on-rocksdb#bitmap-sub-keys-values The value is also equal to the
src/types/redis_bitmap.cc:94
↓ 2 callersMethodSetAddr
src/server/redis_connection.cc:179
↓ 2 callersFunctionSetBitTo
src/common/bit_util.h:79
↓ 2 callersMethodSetBitfield
src/common/bitfield_util.h:255
↓ 2 callersMethodSetBytesPerSecond
src/cluster/batch_sender.cc:112
↓ 2 callersMethodSetCheckpointAccessTimeSecs
src/storage/storage.h:356
↓ 2 callersMethodSetDBInRetryableIOError
src/storage/storage.h:358
↓ 2 callersMethodSetDumpToLogfileLevel
src/stats/log_collector.cc:98
↓ 2 callersFunctionSetGlobalArray
src/storage/scripting.cc:1484
↓ 2 callersMethodSetName
src/server/redis_connection.h:139
↓ 2 callersFunctionSetRocksdbCompression
src/config/config.cc:112
↓ 2 callersMethodSetSourceKey
src/storage/redis_metadata.cc:616
↓ 2 callersMethodSetXX
src/types/redis_string.cc:365
↓ 2 callersMethodShiftReplId
src/storage/storage.cc:1024
↓ 2 callersMethodSingleDelete
src/storage/batch_indexer.h:62
↓ 2 callersFunctionSizeToString
src/commands/cmd_json.cc:48
↓ 2 callersFunctionSockSetTcpKeepalive
src/common/io_util.cc:75
↓ 2 callersFunctionSockSetTcpNoDelay
src/common/io_util.cc:68
↓ 2 callersFunctionStallConditionType2String
src/storage/event_listener.cc:53
↓ 2 callersMethodStart
src/cluster/slot_import.cc:31
↓ 2 callersMethodStop
utils/kvrocks2redis/sync.cc:74
↓ 2 callersMethodSyncWAL
src/storage/storage.cc:867
↓ 2 callersFunctionT
tests/cppunit/indexer_test.cc:33
↓ 2 callersFunctionTDigestMerge
src/types/tdigest.cc:402
↓ 2 callersMethodTLSPort
()
tests/gocase/util/server.go:66
↓ 2 callersMethodTLSState
()
tests/gocase/util/tcp_client.go:49
↓ 2 callersFunctionThreadDetach
src/common/thread_util.cc:91
↓ 2 callersMethodToString
src/search/interval.h:48
↓ 2 callersMethodToStringForRewrite
src/config/config_type.h:66
↓ 2 callersMethodTokenize
src/server/redis_request.cc:39
↓ 2 callersFunctionTokenizeRedisProtocol
src/common/string_util.cc:434
↓ 2 callersMethodTransform
src/search/plan_executor.cc:49
↓ 2 callersMethodUnblockOnStreams
src/server/server.cc:675
↓ 2 callersMethodUnionStore
src/types/redis_set.cc:428
↓ 2 callersMethodUnpause
src/server/redis_connection.cc:237
↓ 2 callersMethodUnsubscribeAll
src/server/redis_connection.cc:265
↓ 2 callersMethodUpdateWatchedKeysManually
src/server/server.cc:2172
↓ 2 callersMethodValue
src/common/bitfield_util.h:151
↓ 2 callersMethodWALHasNewData
src/storage/storage.h:276
↓ 2 callersMethodWakeupBlockingConns
src/server/server.cc:700
↓ 2 callersMethodWorkConcurrencyGuard
src/server/server.cc:863
↓ 2 callersFunctionWrappedSignedBitfieldPlus
src/common/bitfield_util.cc:25
↓ 2 callersFunctionWrappedUnsignedBitfieldPlus
src/common/bitfield_util.cc:81
↓ 2 callersMethodWrite
(s string)
tests/gocase/integration/cli/cli_test.go:99
↓ 2 callersMethod_compare_data
(self, keys : list, data_type)
utils/kvrocks2redis/tests/check_consistency.py:63
↓ 2 callersMethod_get_redis_client
(self, host, port, password)
utils/kvrocks2redis/tests/check_consistency.py:30
↓ 2 callersMethodcallback
src/common/event_util.h:125
↓ 2 callersFunctionclang_format
(clang_format_path: str, fix: bool = False)
x.py:182
↓ 2 callersFunctioncompareLists
(list1, list2 []string)
tests/gocase/unit/geo/geo_test.go:58
↓ 2 callersFunctioncreateDefaultLexZset
(rdb *redis.Client, ctx context.Context)
tests/gocase/unit/type/zset/zset_test.go:57
↓ 2 callersFunctiondecodeListLibResult
(t *testing.T, v interface{})
tests/gocase/unit/scripting/function_test.go:76
↓ 2 callersMethodfetchFiles
src/cluster/replication.cc:1114
↓ 2 callersFunctiongeoRandomPointWithSeed
(seed int64)
tests/gocase/unit/geo/geo_test.go:41
↓ 2 callersFunctiongetBlockCacheSize
(rdb *redis.Client)
tests/gocase/unit/flushblockcache/flushblockcache_test.go:32
↓ 2 callersFunctiongetInfoLogFilesInDir
(t *testing.T, dir string)
tests/gocase/unit/log/logclean_test.go:59
↓ 2 callersFunctiongetVals
(hash map[string]string)
tests/gocase/unit/type/hash/hash_test.go:47
↓ 2 callersFunctionnewTCPClient
(c net.Conn)
tests/gocase/util/tcp_client.go:41
↓ 2 callersFunctionrun_test
(client, cases : list)
utils/kvrocks2redis/tests/populate-kvrocks.py:140
↓ 2 callersFunctionstreamCompareID
(a, b string)
tests/gocase/unit/type/stream/stream_test.go:783
↓ 2 callersFunctionstreamRandomID
streamRandomID generates a random stream entry ID with the ms part between min and max and a low sequence number (0 - 999 range), in order to stress t
tests/gocase/unit/type/stream/stream_test.go:806
↓ 1 callersMethodAddConnection
src/server/worker.cc:345
↓ 1 callersMethodAddSlave
src/server/server.cc:334
↓ 1 callersMethodAdjustOpenFilesLimit
AdjustOpenFilesLimit only try best to raise the max open files according to the max clients and RocksDB open file configuration. It also reserves a nu
src/server/server.cc:1991
↓ 1 callersMethodAdjustWorkerThreads
src/server/server.cc:2052
↓ 1 callersMethodAggregateMultiBuckets
src/types/redis_timeseries.cc:248
↓ 1 callersFunctionAggregateSamplesByRangeOption
src/types/redis_timeseries.cc:77
↓ 1 callersMethodAllocatorName
src/server/memory_profiler.cc:66
↓ 1 callersFunctionApplyPersistentToDeleted
src/types/redis_hash.cc:103
↓ 1 callersFunctionApplyPersistentToTTL
src/types/redis_hash.cc:88
↓ 1 callersFunctionApplyTTLToTTL
src/types/redis_hash.cc:93
↓ 1 callersMethodApplyWriteBatch
src/storage/storage.cc:862
↓ 1 callersMethodArrInsert
src/types/redis_json.cc:308
↓ 1 callersMethodArrTrim
src/types/redis_json.cc:388
↓ 1 callersMethodAsyncBgSaveDB
src/server/server.cc:1675
↓ 1 callersMethodAsyncCompactDB
src/server/server.cc:1648
↓ 1 callersMethodAsyncPurgeOldBackups
src/server/server.cc:1696
↓ 1 callersMethodAsyncScanDBSize
src/server/server.cc:1702
↓ 1 callersMethodAutoClaim
src/types/redis_stream.cc:528
↓ 1 callersFunctionBackgroundErrorReason2String
src/storage/event_listener.cc:28
↓ 1 callersFunctionBackupEngineOpen
src/common/db_util.h:83
↓ 1 callersMethodBatchForFlush
Add all dirty segments into write batch.
src/types/redis_bitmap.cc:678
↓ 1 callersMethodBecomeMonitorConn
src/server/worker.cc:507
← previousnext →801–900 of 3,913, ranked by callers