Functions — github.com/apache/kvrocks

CodeHub MCPcopy Create free account

hub / github.com/apache/kvrocks / functions

Functions3,913 in github.com/apache/kvrocks

⨍ Functions 3,913◇ Types & classes 1,048

↓ 1 callersMethod_compare_zset_data

utils/kvrocks2redis/tests/check_consistency.py:53

↓ 1 callersMethod_import_and_compare

utils/kvrocks2redis/tests/check_consistency.py:94

↓ 1 callersFunctionbasicTests

(t *testing.T, rdb *redis.Client, ctx context.Context, enabledRESP3, encoding string, srv *util.KvrocksServer)

tests/gocase/unit/type/zset/zset_test.go:70

↓ 1 callersFunctionbuild

(dir: str, jobs: Optional[int] = None, ninja: bool = False, unittest: bool = False, compiler: str =

↓ 1 callersMethodclean

src/cluster/slot_migrate.cc:461

↓ 1 callersMethodcompare_redis_data

(self, key_file='')

utils/kvrocks2redis/tests/check_consistency.py:81

↓ 1 callersFunctioncreateInteractiveCli

(t *testing.T, srv *util.KvrocksServer)

tests/gocase/integration/cli/cli_test.go:49

↓ 1 callersMethodcron

src/server/server.cc:892

↓ 1 callersFunctiondownload_package

↓ 1 callersMethodgetMetadata

src/types/redis_hash.cc:180

↓ 1 callersFunctionget_gopath

↓ 1 callersFunctionget_source_files

↓ 1 callersFunctionget_syspath

(sys_path: str)

↓ 1 callersFunctionhandshakeWithRESP3

(t *testing.T, c *util.TCPClient)

tests/gocase/unit/protocol/protocol_test.go:247

↓ 1 callersFunctionkMetadataToInt64

(val interface{})

tests/gocase/util/kmetadata.go:46

↓ 1 callersMethodloop

src/cluster/slot_migrate.cc:150

↓ 1 callersMethodloop

src/cluster/replication.cc:178

↓ 1 callersFunctionoptionsWithTimeouts

(options *redis.Options)

tests/gocase/util/server.go:88

↓ 1 callersFunctionparseRESPCommands

(t *testing.T, values []any)

tests/gocase/unit/server/poll_updates_test.go:46

↓ 1 callersFunctionparseStreamEntryID

tests/gocase/unit/type/stream/stream_test.go:2648

↓ 1 callersFunctionparse_args

utils/kvrocks2redis/tests/populate-kvrocks.py:97

↓ 1 callersFunctionpipeline_execute

(client, name, cmds)

utils/kvrocks2redis/tests/populate-kvrocks.py:119

↓ 1 callersMethodreadCallback

for now, the only command that the master receive from the slave on this connection should be ack. the callback find the ack with largest sequence num

src/cluster/replication.cc:129

↓ 1 callersFunctionrequireMigrateSlotRangeState

(t testing.TB, client *redis.Client, slotRange string, state SlotMigrationState)

tests/gocase/integration/slotmigrate/slotmigrate_test.go:1216

↓ 1 callersMethodrun

* Run connect to master, and start the following steps * asynchronously * - CheckDBName * - TryPsync * - - if ok, IncrementBatchLoop * - - no

src/cluster/replication.cc:490

↓ 1 callersMethodsendAuth

src/cluster/replication.cc:1017

↓ 1 callersFunctionstreamNextID

streamNextID returns the ID immediately greater than the specified one. Note that this function does not care to handle 'seq' overflow since it's a 6

tests/gocase/unit/type/stream/stream_test.go:818

↓ 1 callersFunctionstreamSimulateXRANGE

streamSimulateXRANGE simulates Redis XRANGE implementation in Golang.

tests/gocase/unit/type/stream/stream_test.go:773

↓ 1 callersFunctionstressTests

(t *testing.T, rdb *redis.Client, ctx context.Context, encoding string)

tests/gocase/unit/type/zset/zset_test.go:1670

↓ 1 callersMethodsync

utils/kvrocks2redis/redis_writer.cc:88

↓ 1 callersFunctiontdigestTests

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/tdigest/tdigest_test.go:93

↓ 1 callersFunctiontdigestTestsByRankAndByRevRank

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/tdigest/tdigest_test.go:1079

↓ 1 callersFunctiontestBloom

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/bloom/bloom_test.go:47

↓ 1 callersFunctiontestIncr

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/incr/incr_test.go:47

↓ 1 callersFunctiontestJSON

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/json/json_test.go:47

↓ 1 callersFunctiontestLTRIM

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/list/list_test.go:61

↓ 1 callersFunctiontestList

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/list/list_test.go:288

↓ 1 callersFunctiontestPubSub

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/pubsub/pubsub_test.go:59

↓ 1 callersFunctiontestRpoplpush

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/list/list_test.go:1588

↓ 1 callersFunctiontestSint

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/sint/sint_test.go:46

↓ 1 callersFunctiontestString

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/strings/strings_test.go:52

↓ 1 callersFunctiontestTimeSeries

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/timeseries/timeseries_test.go:50

↓ 1 callersFunctiontestZipList

(t *testing.T, configs util.KvrocksServerConfigs)

tests/gocase/unit/type/list/list_test.go:120

↓ 1 callersFunctiontoInt64

(val interface{})

tests/gocase/unit/type/list/list_test.go:1523

↓ 1 callersFunctiontoInt64

(val interface{})

tests/gocase/unit/kmetadata/kmetadata_test.go:48

↓ 1 callersFunctionwaitForMigrateSlotRangeStateInDuration

(t testing.TB, client *redis.Client, slotRange string, state SlotMigrationState, d time.Duration)

tests/gocase/integration/slotmigrate/slotmigrate_test.go:1198

↓ 1 callersFunctionwrite_version

(release_version: str)

tests/cppunit/status_test.cc:123

src/types/redis_stream.cc:88

the max 0 pattern counter of the subset the element belongs to is incremented if needed */

src/types/redis_hyperloglog.cc:110

src/types/redis_zset.cc:39

merge one centroid from a sorted centroid stream

src/types/tdigest.cc:66

src/types/redis_sortedint.cc:35

src/types/redis_tdigest.cc:174

src/types/redis_geo.cc:27

src/types/redis_set.cc:58

src/types/redis_timeseries.cc:1925

src/types/redis_bloom_chain.cc:139

src/search/index_info.h:65

src/server/namespace.cc:168

src/search/hnsw_indexer.cc:230

MethodAddUserKey

src/storage/table_properties_collector.cc:30

MethodAdditionalFlagGen

src/commands/commander.h:189

MethodAlign52Bits

src/types/geohash.cc:439

src/storage/redis_metadata.h:71

src/search/ir.h:317

MethodArrAppend

src/types/json.h:257

src/types/json.h:320

MethodArrInsert

src/types/json.h:277

src/types/json.h:430

src/types/json.h:527

src/types/json.h:554

MethodArrayBitfieldBitmap

byte_offset is the byte offset of view in entire bitmap.

src/common/bitfield_util.h:192

src/search/ir.h:74

MethodAutoGeneratedEntryID

src/types/redis_stream_base.h:89

MethodBatchSender

src/cluster/batch_sender.h:30

FunctionBetweenValues

BetweenValues asserts start <= d <= end

tests/gocase/util/assertions.go:35

FunctionBetweenValuesEx

BetweenValuesEx asserts start < d < end

tests/gocase/util/assertions.go:41

MethodBinary2Vector

src/search/common_transformer.h:129

src/types/redis_bitmap_string.cc:72

src/types/redis_bitmap_string.cc:107

src/types/redis_bitmap_string.cc:208

MethodBitfieldEncoding

src/common/bitfield_util.h:99

MethodBitfieldReadOnly

src/types/redis_bitmap_string.cc:277

MethodBitfieldValue

src/common/bitfield_util.h:142

src/types/redis_bitmap.h:48

MethodBitmapMetadata

src/storage/redis_metadata.h:257

MethodBitmapString

src/types/redis_bitmap_string.h:36

MethodBlockKeys

src/commands/cmd_zset.cc:345

MethodBlockKeys

src/commands/cmd_zset.cc:547

MethodBlockKeys

src/commands/cmd_list.cc:277

MethodBlockKeys

src/commands/cmd_list.cc:437

MethodBlockKeys

src/commands/cmd_list.cc:786

MethodBlockSplitBloomFilter

The constructor of BlockSplitBloomFilter. It uses XXH64 as hash function.

src/types/bloom_filter.h:95

MethodBlockingRead

src/commands/cmd_stream.cc:1298

MethodBlockingRead

src/commands/cmd_stream.cc:1614

MethodBloomChain

src/types/redis_bloom_chain.h:65

MethodBloomChainMetadata

src/storage/redis_metadata.h:326

MethodBoolLiteral

src/search/ir.h:287

MethodBoundingBox

Return the bounding box of the search area centered at latitude,longitude * having a radius of radius_meter. bounds[0] - bounds[2] is the minimum *

src/types/geohash.cc:333

← previous next →1,301–1,400 of 3,913, ranked by callers