MCPcopy Create free account

hub / github.com/Kirov7/CouloyDB / functions

Functions564 in github.com/Kirov7/CouloyDB

↓ 258 callersFunctionGetTestKey
(x int)
public/utils/bytex/bytex.go:13
↓ 56 callersMethodGet
Get Retrieve the Pos information based on the key
meta/memTable.go:20
↓ 45 callersFunctionNewCouloyDB
(opt Options)
db.go:44
↓ 43 callersFunctionDefaultOptions
()
options.go:29
↓ 39 callersMethodSerialTransaction
SerialTransaction serializable transaction For now, the commit of a serializable transaction is unlikely to conflict so no retry is required
txn.go:208
↓ 39 callersFunctiondestroyCouloyDB
(db *DB)
db_test.go:14
↓ 31 callersMethodSet
Set writes data to the db, but instead of writing it back to memtable, it writes to pendingWrites first
txn.go:429
↓ 28 callersMethodPut
Put Stores the Pos information for key pairs in the index
meta/memTable.go:17
↓ 27 callersMethodAdd
Add adds delta, which may be negative, to the WaitGroup counter.
public/utils/wait/wait.go:20
↓ 24 callersMethodDone
Done decrements the WaitGroup counter by one
public/utils/wait/wait.go:25
↓ 23 callersMethodHSet
(key, field, value []byte)
txnHash.go:9
↓ 22 callersFunctionMakeErrReply
MakeErrReply creates StandardErrReply
server/resp/reply/reply.go:132
↓ 21 callersMethodgetStrIndex
()
index.go:22
↓ 19 callersMethodError
()
server/resp/reply/reply.go:113
↓ 18 callersFunctionBytesSort
(data [][]byte)
public/utils/bytex/bytex.go:25
↓ 18 callersMethodDel
Del Delete the Pos information based on the key
meta/memTable.go:23
↓ 18 callersFunctionRandomBytes
(length int)
public/utils/bytex/bytex.go:17
↓ 18 callersFunctionencodeKeyWithTxId
(key []byte, txId int64)
batch.go:120
↓ 17 callersMethodgetValueByPos
(pos *data.LogPos)
db.go:697
↓ 14 callersMethodappendLogRecordWithLock
(log *data.LogRecord)
db.go:362
↓ 14 callersMethodgetIndexLockByType
(typ data.DataType)
db.go:734
↓ 13 callersMethodClose
()
server/database/database.go:14
↓ 13 callersFunctionRegisterCommand
RegisterCommand registers a new command arity means allowed number of cmdArgs, arity < 0 means len(args) >= -arity. for example: the arity of `get` is
server/database/command.go:18
↓ 13 callersMethodWait
Wait blocks until the WaitGroup counter is zero.
public/utils/wait/wait.go:30
↓ 13 callersMethodWrite
Write Writing bytes of data to a file
driver/ioManager.go:12
↓ 12 callersMethodHGetAll
(key []byte)
txnHash.go:109
↓ 12 callersMethodKey
()
meta/memTable.go:51
↓ 11 callersMethodNext
()
meta/memTable.go:49
↓ 11 callersMethodValue
()
meta/memTable.go:52
↓ 11 callersMethodgetHashIndex
(key string)
index.go:26
↓ 10 callersMethodHGet
(key, field []byte)
txnHash.go:40
↓ 10 callersMethodIterator
Iterator Index iterator
meta/memTable.go:26
↓ 10 callersFunctionNewMemTable
(typ MemTableType)
meta/memTable.go:32
↓ 10 callersMethodSync
Sync Make data persistent
driver/ioManager.go:15
↓ 9 callersMethodClose
()
meta/memTable.go:53
↓ 9 callersMethodHDel
(key, field []byte)
txnHash.go:60
↓ 9 callersMethodLPop
(key []byte)
txnList.go:18
↓ 9 callersFunctionMakeStatusReply
MakeStatusReply creates StatusReply
server/resp/reply/reply.go:79
↓ 9 callersMethodValid
()
meta/memTable.go:50
↓ 9 callersMethodgetSetIndex
(key string)
index.go:52
↓ 8 callersMethodGet
(key string)
server/database/datastruct/dict/dict.go:8
↓ 8 callersFunctionMakeIntReply
MakeIntReply creates int reply
server/resp/reply/reply.go:98
↓ 8 callersMethodRewind
()
meta/memTable.go:47
↓ 7 callersMethodGet
Get the key first in pendingWrites, if not then in db
txn.go:404
↓ 7 callersMethodGetString
(key interface{})
server/sliceRouter.go:61
↓ 7 callersFunctionNewJob
(key string, expiration time.Time)
public/ds/timeHeap.go:66
↓ 7 callersMethodRPush
(key []byte, values [][]byte)
txnList.go:14
↓ 7 callersMethodRemove
(key string)
server/database/datastruct/dict/dict.go:13
↓ 7 callersMethodgetListDataIndex
(key string)
index.go:41
↓ 6 callersMethodGetEntity
* ---- data Access ----- */ GetEntity returns DataEntity bind to given key
server/database/mutildb.go:130
↓ 6 callersMethodHKeys
(key []byte)
txnHash.go:176
↓ 6 callersMethodLPush
(key []byte, values [][]byte)
txnList.go:10
↓ 6 callersMethodgetListMetaIndex
()
index.go:37
↓ 6 callersMethodhashKey
(key string)
public/utils/consistent/consistent.go:229
↓ 5 callersMethodCount
Count get the num of all the data
meta/memTable.go:29
↓ 5 callersMethodHLen
(key []byte)
txnHash.go:237
↓ 5 callersMethodHValues
(key []byte)
txnHash.go:199
↓ 5 callersFunctionNewWait
()
public/utils/wait/wait.go:13
↓ 5 callersMethodPush
(job *Job)
public/ds/timeHeap.go:21
↓ 5 callersMethodPutWithExpiration
(key, value []byte, duration time.Duration)
db.go:117
↓ 5 callersMethodReadLogRecord
(offset int64)
data/dataFile.go:64
↓ 5 callersMethodSize
()
driver/ioManager.go:20
↓ 5 callersMethodappendLogRecord
(log *data.LogRecord)
db.go:368
↓ 5 callersFunctioncheckKey
(key []byte)
db.go:746
↓ 4 callersMethodClose
Close Close the driver
driver/ioManager.go:18
↓ 4 callersMethodExec
(c *server.Conn, args [][]byte)
server/database/database.go:13
↓ 4 callersMethodLLen
(key []byte)
txnList.go:26
↓ 4 callersMethodLen
()
server/database/datastruct/dict/dict.go:9
↓ 4 callersFunctionMakeMultiBulkReply
MakeMultiBulkReply creates MultiBulkReply
server/resp/reply/reply.go:50
↓ 4 callersMethodNotify
(key string, value []byte, entryType eventType)
db.go:728
↓ 4 callersMethodPeek
()
public/ds/timeHeap.go:50
↓ 4 callersMethodPutEntity
PutEntity a DataEntity into DB
server/database/mutildb.go:141
↓ 4 callersMethodRPop
(key []byte)
txnList.go:22
↓ 4 callersMethodSAdd
(key []byte, members ...[]byte)
txnSet.go:11
↓ 4 callersMethodToBytes
()
server/resp/reply/reply.go:10
↓ 4 callersFunctionhashMemberKey
(key, member []byte)
txnSet.go:149
↓ 4 callersMethodincrOrDecr
(key []byte, isIncr bool, delta int)
txn.go:522
↓ 4 callersMethodisEmpty
isEmpty checks if the heap is empty.
public/ds/timeHeap.go:123
↓ 4 callersMethodrelay
relay relays command to peer select db by c.GetDBIndex() cannot call Prepare, Commit, execRollback of self node
server/database/clusterdb.go:152
↓ 3 callersMethodAbort
()
server/sliceRouter.go:110
↓ 3 callersMethodDel
(key []byte)
db.go:185
↓ 3 callersFunctionEncodeLogRecord
(log *LogRecord)
data/logRecord.go:57
↓ 3 callersMethodFold
Fold gets all the keys and executes the function passed in by the user. Terminates the traversal when the function returns false
db.go:256
↓ 3 callersMethodForEach
(consumer Consumer)
server/database/datastruct/dict/dict.go:14
↓ 3 callersMethodListenAndServe
()
server/server.go:53
↓ 3 callersFunctionMakeArgNumErrReply
MakeArgNumErrReply represents wrong number of arguments for command
server/resp/reply/errors.go:32
↓ 3 callersFunctionMakeBulkReply
MakeBulkReply creates BulkReply
server/resp/reply/reply.go:28
↓ 3 callersMethodPush
(x interface{})
txn.go:643
↓ 3 callersMethodRWTransaction
RWTransaction Read/Write transaction if retryOnConflict is true, then the transaction will automatically retry until the transaction commits correctly
txn.go:227
↓ 3 callersMethodReset
()
server/sliceRouter.go:118
↓ 3 callersFunctiondecodeListKey
(key []byte)
txnList.go:314
↓ 3 callersMethoddel
(key string)
ttl.go:36
↓ 3 callersFunctionencodeMemberKey
(key, member []byte)
txnSet.go:155
↓ 3 callersFunctionnewDataFile
(fileName string, fileId uint32)
data/dataFile.go:47
↓ 3 callersMethodnotify
()
ttl.go:113
↓ 3 callersFunctionparseLogRecordKey
prase LogRecord's Key and get the real key with txId
db.go:706
↓ 3 callersMethodrollback
rollback
txn.go:307
↓ 3 callersMethodsearch
(key uint32)
public/utils/consistent/consistent.go:141
↓ 3 callersMethodsetActivityFile
()
db.go:415
↓ 3 callersMethodsetSetIndex
(key string, memTable meta.MemTable)
index.go:59
next →1–100 of 564, ranked by callers