MCPcopy Create free account

hub / github.com/bluesky-social/kvdb / functions

Functions260 in github.com/bluesky-social/kvdb

⨍ Functions 260◇ Types & classes 30
↓ 192 callersFunctionSimpleStringValue
(str string)
pkg/serde/resp/resp.go:464
↓ 132 callersFunctionrecordErr
(span trace.Span, err error)
internal/server/redis/redis.go:485
↓ 130 callersMethodhandleCommand
(ctx context.Context, cmd *resp.Command)
internal/server/redis/redis.go:313
↓ 63 callersFunctionBulkStringValue
(str string)
pkg/serde/resp/resp.go:475
↓ 53 callersFunctionSpanOK
(span trace.Span)
internal/metrics/prometheus.go:37
↓ 47 callersFunctionFormatInt
(n int64)
pkg/serde/resp/resp.go:510
↓ 40 callersFunctionextractStringArg
(val resp.Value)
internal/server/redis/redis.go:430
↓ 33 callersFunctionrequireRESPError
(t *testing.T, str string)
internal/server/redis/redis_test.go:59
↓ 23 callersFunctionvalidateNumArgs
(args []resp.Value, num int)
internal/server/redis/redis.go:473
↓ 21 callersFunctionrequireNoRESPError
(t *testing.T, str string)
internal/server/redis/redis_test.go:63
↓ 20 callersFunctionParseRESP3Value
(reader *bufio.Reader)
pkg/serde/resp/resp.go:83
↓ 18 callersFunctionFormatBulkString
(str string)
pkg/serde/resp/resp.go:471
↓ 16 callersFunctionreadLine
Reads a line and trims any trailing newline characters
pkg/serde/resp/resp.go:126
↓ 15 callersFunctionFormatBoolAsInt
(val bool)
pkg/serde/resp/resp.go:502
↓ 15 callersFunctionRandString
(length int)
internal/testutil/testutil.go:7
↓ 15 callersFunctionrequireArraysEqual
order-independant array comparison
internal/server/redis/redis_test.go:544
↓ 11 callersFunctionFormatSimpleString
(str string)
pkg/serde/resp/resp.go:460
↓ 11 callersMethodString
()
internal/types/redis.pb.go:97
↓ 11 callersFunctionfile_redis_proto_rawDescGZIP
()
internal/types/redis.pb.go:857
↓ 11 callersMethodgetObject
(ctx context.Context, tx fdb.ReadTransaction, kind objectKind, id string)
internal/server/redis/object.go:67
↓ 10 callersFunctionencodeSortedSetScore
Encodes a floating point sorted set score lexicographically so we can store them in sorted order
internal/server/redis/set.go:698
↓ 9 callersFunctionsetProtoItem
(tx fdb.Transaction, key fdb.Key, item proto.Message)
internal/server/redis/redis.go:503
↓ 9 callersFunctiontestSessionWithAuth
(t *testing.T)
internal/server/redis/redis_test.go:43
↓ 8 callersFunctionFormatError
(err error)
pkg/serde/resp/resp.go:525
↓ 7 callersFunctionFormatNil
()
pkg/serde/resp/resp.go:498
↓ 7 callersMethodgetMeta
(ctx context.Context, tx fdb.ReadTransaction, id string)
internal/server/redis/redis.go:577
↓ 6 callersFunctionFormatUint
(n uint64)
pkg/serde/resp/resp.go:514
↓ 6 callersFunctiongetProtoItem
(tx fdb.ReadTransaction, key fdb.Key, item proto.Message)
internal/server/redis/redis.go:526
↓ 6 callersMethodwriteObject
(ctx context.Context, tx fdb.Transaction, id string, kind objectKind, data []byte)
internal/server/redis/object.go:116
↓ 5 callersFunctionrecoverErr
(loc string, r any)
internal/server/redis/redis.go:490
↓ 5 callersMethodsortedSetScoreDir
Returns the FDB directory
internal/server/redis/redis.go:253
↓ 4 callersMethoddeleteObject
(ctx context.Context, tx fdb.Transaction, id string, meta *types.ObjectMeta)
internal/server/redis/object.go:198
↓ 4 callersMethodhandleIncrDecr
(ctx context.Context, args []resp.Value, byStr string)
internal/server/redis/object.go:463
↓ 4 callersMethodlistItemMetaKey
Returns the FDB key of an object in the per-user, per-list item directory
internal/server/redis/redis.go:277
↓ 4 callersMethodobjectKey
Returns the FDB key of an object in the per-user object directory
internal/server/redis/redis.go:217
↓ 3 callersFunctionFormatArrayOfBulkStrings
(strs []string)
pkg/serde/resp/resp.go:482
↓ 3 callersFunctionNewSession
(args *NewSessionArgs)
internal/server/redis/redis.go:176
↓ 3 callersFunctionParseCommand
(reader *bufio.Reader)
pkg/serde/resp/resp.go:48
↓ 3 callersMethodhandleMultiSetOperation
(ctx context.Context, args []resp.Value, fn setOperationFunc)
internal/server/redis/set.go:490
↓ 3 callersMethodmemberFromUID
(ctx context.Context, tx fdb.ReadTransaction, uid uint64)
internal/server/redis/redis.go:790
↓ 3 callersFunctionparseVariadicArguments
(args []resp.Value)
internal/server/redis/redis.go:815
↓ 3 callersMethoduidKey
Returns the FDB key of an object in the per-user uid directory
internal/server/redis/redis.go:241
↓ 2 callersFunctionInitAdminUser
Seeds the database with an admin user on first-time starutp. Once an admin user has been created on the cluster, no others will be created.
internal/server/redis/redis.go:64
↓ 2 callersFunctionInitDirectories
(db fdb.Database)
internal/server/redis/redis.go:41
↓ 2 callersMethodallocateNewUID
Interns, stores, and returns a new UID. The upper 16 bits are a random sequence number, and the lower 48 bits are a sequential number within that spac
internal/server/redis/redis.go:637
↓ 2 callersFunctioncontainsWhitespace
(s string)
internal/server/redis/redis.go:480
↓ 2 callersMethodcreateOrAddToSet
(ctx context.Context, tx fdb.Transaction, kind objectKind, key string, members []string, scores []float32)
internal/server/redis/set.go:56
↓ 2 callersMethodgetListMeta
Returns the associated metadata for an object. Returns nil if the object does not exist.
internal/server/redis/redis.go:609
↓ 2 callersFunctiongetNumChunks
(meta *types.ObjectMeta, kind gt.Option[objectKind])
internal/server/redis/object.go:35
↓ 2 callersMethodgetUser
(username string)
internal/server/redis/redis.go:543
↓ 2 callersMethodhandlePush
(ctx context.Context, args []resp.Value, left bool)
internal/server/redis/list.go:81
↓ 2 callersMethodhandleSetCard
(ctx context.Context, args []resp.Value)
internal/server/redis/set.go:313
↓ 2 callersFunctionhashPassword
(password string)
internal/server/redis/crypt.go:11
↓ 2 callersMethodmetaKey
Returns the FDB key of an object in the per-user meta directory
internal/server/redis/redis.go:229
↓ 2 callersFunctionparseArray
(reader *bufio.Reader)
pkg/serde/resp/resp.go:196
↓ 2 callersFunctionparseAttribute
(reader *bufio.Reader)
pkg/serde/resp/resp.go:371
↓ 2 callersFunctionparseBigNumber
(reader *bufio.Reader)
pkg/serde/resp/resp.go:280
↓ 2 callersFunctionparseBoolean
(reader *bufio.Reader)
pkg/serde/resp/resp.go:240
↓ 2 callersFunctionparseBulkError
(reader *bufio.Reader)
pkg/serde/resp/resp.go:290
↓ 2 callersFunctionparseBulkString
(reader *bufio.Reader)
pkg/serde/resp/resp.go:166
↓ 2 callersFunctionparseDouble
(reader *bufio.Reader)
pkg/serde/resp/resp.go:256
↓ 2 callersFunctionparseInteger
(reader *bufio.Reader)
pkg/serde/resp/resp.go:152
↓ 2 callersFunctionparseMap
(reader *bufio.Reader)
pkg/serde/resp/resp.go:341
↓ 2 callersFunctionparseNull
(reader *bufio.Reader)
pkg/serde/resp/resp.go:230
↓ 2 callersFunctionparsePush
(reader *bufio.Reader)
pkg/serde/resp/resp.go:431
↓ 2 callersFunctionparseSet
(reader *bufio.Reader)
pkg/serde/resp/resp.go:401
↓ 2 callersFunctionparseSimpleError
(reader *bufio.Reader)
pkg/serde/resp/resp.go:144
↓ 2 callersFunctionparseSimpleString
(reader *bufio.Reader)
pkg/serde/resp/resp.go:135
↓ 2 callersFunctionparseVerbatimString
(reader *bufio.Reader)
pkg/serde/resp/resp.go:315
↓ 2 callersMethodpeekUID
Returns the UID for the given member string. It will only look up the UID; it will never create a new one. UIDs start at 1, so 0 is never a valid UID.
internal/server/redis/redis.go:760
↓ 2 callersMethodremoveFromSet
(ctx context.Context, tx fdb.Transaction, kind objectKind, key string, uids []uint64)
internal/server/redis/set.go:178
↓ 2 callersMethodreverseUIDKey
Returns the FDB key of an object in the per-user uid directory
internal/server/redis/redis.go:265
↓ 2 callersMethodsetSessionUser
(user *types.User)
internal/server/redis/auth.go:97
↓ 2 callersFunctiontestSession
(t *testing.T)
internal/server/redis/redis_test.go:23
↓ 2 callersMethoduserKey
Returns the FDB key of an object in the global user directory
internal/server/redis/redis.go:209
↓ 2 callersMethodwrite
(msg string)
internal/server/redis/redis.go:293
↓ 1 callersMethodDescriptor
()
internal/types/redis.pb.go:60
↓ 1 callersMethodDescriptor
Deprecated: Use User.ProtoReflect.Descriptor instead.
internal/types/redis.pb.go:116
↓ 1 callersFunctionInitBackgroundServices
(ctx context.Context, db fdb.Database, dirs *Directories)
internal/server/redis/redis.go:135
↓ 1 callersFunctionIsProd
()
internal/env/env.go:20
↓ 1 callersFunctionRun
(ctx context.Context, args *Args)
internal/server/server.go:122
↓ 1 callersMethodServe
(ctx context.Context)
internal/server/redis/redis.go:188
↓ 1 callersFunctioncomparePasswords
(hashedPassword []byte, password string)
internal/server/redis/crypt.go:15
↓ 1 callersMethoddeleteExpiredObjectsForever
(ctx context.Context)
internal/server/redis/redis.go:828
↓ 1 callersMethoddeleteOneExpiredObjectBatch
(ctx context.Context, limit int)
internal/server/redis/redis.go:861
↓ 1 callersFunctionfile_redis_proto_init
()
internal/types/redis.pb.go:902
↓ 1 callersFunctiongetEnv
(key string)
cmd/kvdb/main.go:151
↓ 1 callersFunctiongetItem
(tx fdb.ReadTransaction, key fdb.Key)
internal/server/redis/redis.go:513
↓ 1 callersMethodgetOrAllocateUID
Returns the UID for the given member string, creating a new one if it does not exist. If peek is true, it will refuse to create a new UID if one does
internal/server/redis/redis.go:707
↓ 1 callersMethodhandleACL
Implements a small subset of the standard redis functionality for creating a new user. Example: `ACL SETUSER newusername on >password123 ~* &* +@all`
internal/server/redis/auth.go:151
↓ 1 callersMethodhandleAuth
(ctx context.Context, args []resp.Value)
internal/server/redis/auth.go:46
↓ 1 callersMethodhandleDecr
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:421
↓ 1 callersMethodhandleDecrBy
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:434
↓ 1 callersMethodhandleDelete
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:331
↓ 1 callersMethodhandleExists
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:269
↓ 1 callersMethodhandleExpire
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:575
↓ 1 callersMethodhandleGet
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:234
↓ 1 callersMethodhandleIncr
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:386
↓ 1 callersMethodhandleIncrBy
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:399
↓ 1 callersMethodhandleIncrByFloat
(ctx context.Context, args []resp.Value)
internal/server/redis/object.go:517
next →1–100 of 260, ranked by callers