Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Kirov7/CouloyDB
/ functions
Functions
564 in github.com/Kirov7/CouloyDB
⨍
Functions
564
◇
Types & classes
103
↓ 258 callers
Function
GetTestKey
(x int)
public/utils/bytex/bytex.go:13
↓ 56 callers
Method
Get
Get Retrieve the Pos information based on the key
meta/memTable.go:20
↓ 45 callers
Function
NewCouloyDB
(opt Options)
db.go:44
↓ 43 callers
Function
DefaultOptions
()
options.go:29
↓ 39 callers
Method
SerialTransaction
SerialTransaction serializable transaction For now, the commit of a serializable transaction is unlikely to conflict so no retry is required
txn.go:208
↓ 39 callers
Function
destroyCouloyDB
(db *DB)
db_test.go:14
↓ 31 callers
Method
Set
Set writes data to the db, but instead of writing it back to memtable, it writes to pendingWrites first
txn.go:429
↓ 28 callers
Method
Put
Put Stores the Pos information for key pairs in the index
meta/memTable.go:17
↓ 27 callers
Method
Add
Add adds delta, which may be negative, to the WaitGroup counter.
public/utils/wait/wait.go:20
↓ 24 callers
Method
Done
Done decrements the WaitGroup counter by one
public/utils/wait/wait.go:25
↓ 23 callers
Method
HSet
(key, field, value []byte)
txnHash.go:9
↓ 22 callers
Function
MakeErrReply
MakeErrReply creates StandardErrReply
server/resp/reply/reply.go:132
↓ 21 callers
Method
getStrIndex
()
index.go:22
↓ 19 callers
Method
Error
()
server/resp/reply/reply.go:113
↓ 18 callers
Function
BytesSort
(data [][]byte)
public/utils/bytex/bytex.go:25
↓ 18 callers
Method
Del
Del Delete the Pos information based on the key
meta/memTable.go:23
↓ 18 callers
Function
RandomBytes
(length int)
public/utils/bytex/bytex.go:17
↓ 18 callers
Function
encodeKeyWithTxId
(key []byte, txId int64)
batch.go:120
↓ 17 callers
Method
getValueByPos
(pos *data.LogPos)
db.go:697
↓ 14 callers
Method
appendLogRecordWithLock
(log *data.LogRecord)
db.go:362
↓ 14 callers
Method
getIndexLockByType
(typ data.DataType)
db.go:734
↓ 13 callers
Method
Close
()
server/database/database.go:14
↓ 13 callers
Function
RegisterCommand
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 callers
Method
Wait
Wait blocks until the WaitGroup counter is zero.
public/utils/wait/wait.go:30
↓ 13 callers
Method
Write
Write Writing bytes of data to a file
driver/ioManager.go:12
↓ 12 callers
Method
HGetAll
(key []byte)
txnHash.go:109
↓ 12 callers
Method
Key
()
meta/memTable.go:51
↓ 11 callers
Method
Next
()
meta/memTable.go:49
↓ 11 callers
Method
Value
()
meta/memTable.go:52
↓ 11 callers
Method
getHashIndex
(key string)
index.go:26
↓ 10 callers
Method
HGet
(key, field []byte)
txnHash.go:40
↓ 10 callers
Method
Iterator
Iterator Index iterator
meta/memTable.go:26
↓ 10 callers
Function
NewMemTable
(typ MemTableType)
meta/memTable.go:32
↓ 10 callers
Method
Sync
Sync Make data persistent
driver/ioManager.go:15
↓ 9 callers
Method
Close
()
meta/memTable.go:53
↓ 9 callers
Method
HDel
(key, field []byte)
txnHash.go:60
↓ 9 callers
Method
LPop
(key []byte)
txnList.go:18
↓ 9 callers
Function
MakeStatusReply
MakeStatusReply creates StatusReply
server/resp/reply/reply.go:79
↓ 9 callers
Method
Valid
()
meta/memTable.go:50
↓ 9 callers
Method
getSetIndex
(key string)
index.go:52
↓ 8 callers
Method
Get
(key string)
server/database/datastruct/dict/dict.go:8
↓ 8 callers
Function
MakeIntReply
MakeIntReply creates int reply
server/resp/reply/reply.go:98
↓ 8 callers
Method
Rewind
()
meta/memTable.go:47
↓ 7 callers
Method
Get
Get the key first in pendingWrites, if not then in db
txn.go:404
↓ 7 callers
Method
GetString
(key interface{})
server/sliceRouter.go:61
↓ 7 callers
Function
NewJob
(key string, expiration time.Time)
public/ds/timeHeap.go:66
↓ 7 callers
Method
RPush
(key []byte, values [][]byte)
txnList.go:14
↓ 7 callers
Method
Remove
(key string)
server/database/datastruct/dict/dict.go:13
↓ 7 callers
Method
getListDataIndex
(key string)
index.go:41
↓ 6 callers
Method
GetEntity
* ---- data Access ----- */ GetEntity returns DataEntity bind to given key
server/database/mutildb.go:130
↓ 6 callers
Method
HKeys
(key []byte)
txnHash.go:176
↓ 6 callers
Method
LPush
(key []byte, values [][]byte)
txnList.go:10
↓ 6 callers
Method
getListMetaIndex
()
index.go:37
↓ 6 callers
Method
hashKey
(key string)
public/utils/consistent/consistent.go:229
↓ 5 callers
Method
Count
Count get the num of all the data
meta/memTable.go:29
↓ 5 callers
Method
HLen
(key []byte)
txnHash.go:237
↓ 5 callers
Method
HValues
(key []byte)
txnHash.go:199
↓ 5 callers
Function
NewWait
()
public/utils/wait/wait.go:13
↓ 5 callers
Method
Push
(job *Job)
public/ds/timeHeap.go:21
↓ 5 callers
Method
PutWithExpiration
(key, value []byte, duration time.Duration)
db.go:117
↓ 5 callers
Method
ReadLogRecord
(offset int64)
data/dataFile.go:64
↓ 5 callers
Method
Size
()
driver/ioManager.go:20
↓ 5 callers
Method
appendLogRecord
(log *data.LogRecord)
db.go:368
↓ 5 callers
Function
checkKey
(key []byte)
db.go:746
↓ 4 callers
Method
Close
Close Close the driver
driver/ioManager.go:18
↓ 4 callers
Method
Exec
(c *server.Conn, args [][]byte)
server/database/database.go:13
↓ 4 callers
Method
LLen
(key []byte)
txnList.go:26
↓ 4 callers
Method
Len
()
server/database/datastruct/dict/dict.go:9
↓ 4 callers
Function
MakeMultiBulkReply
MakeMultiBulkReply creates MultiBulkReply
server/resp/reply/reply.go:50
↓ 4 callers
Method
Notify
(key string, value []byte, entryType eventType)
db.go:728
↓ 4 callers
Method
Peek
()
public/ds/timeHeap.go:50
↓ 4 callers
Method
PutEntity
PutEntity a DataEntity into DB
server/database/mutildb.go:141
↓ 4 callers
Method
RPop
(key []byte)
txnList.go:22
↓ 4 callers
Method
SAdd
(key []byte, members ...[]byte)
txnSet.go:11
↓ 4 callers
Method
ToBytes
()
server/resp/reply/reply.go:10
↓ 4 callers
Function
hashMemberKey
(key, member []byte)
txnSet.go:149
↓ 4 callers
Method
incrOrDecr
(key []byte, isIncr bool, delta int)
txn.go:522
↓ 4 callers
Method
isEmpty
isEmpty checks if the heap is empty.
public/ds/timeHeap.go:123
↓ 4 callers
Method
relay
relay relays command to peer select db by c.GetDBIndex() cannot call Prepare, Commit, execRollback of self node
server/database/clusterdb.go:152
↓ 3 callers
Method
Abort
()
server/sliceRouter.go:110
↓ 3 callers
Method
Del
(key []byte)
db.go:185
↓ 3 callers
Function
EncodeLogRecord
(log *LogRecord)
data/logRecord.go:57
↓ 3 callers
Method
Fold
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 callers
Method
ForEach
(consumer Consumer)
server/database/datastruct/dict/dict.go:14
↓ 3 callers
Method
ListenAndServe
()
server/server.go:53
↓ 3 callers
Function
MakeArgNumErrReply
MakeArgNumErrReply represents wrong number of arguments for command
server/resp/reply/errors.go:32
↓ 3 callers
Function
MakeBulkReply
MakeBulkReply creates BulkReply
server/resp/reply/reply.go:28
↓ 3 callers
Method
Push
(x interface{})
txn.go:643
↓ 3 callers
Method
RWTransaction
RWTransaction Read/Write transaction if retryOnConflict is true, then the transaction will automatically retry until the transaction commits correctly
txn.go:227
↓ 3 callers
Method
Reset
()
server/sliceRouter.go:118
↓ 3 callers
Function
decodeListKey
(key []byte)
txnList.go:314
↓ 3 callers
Method
del
(key string)
ttl.go:36
↓ 3 callers
Function
encodeMemberKey
(key, member []byte)
txnSet.go:155
↓ 3 callers
Function
newDataFile
(fileName string, fileId uint32)
data/dataFile.go:47
↓ 3 callers
Method
notify
()
ttl.go:113
↓ 3 callers
Function
parseLogRecordKey
prase LogRecord's Key and get the real key with txId
db.go:706
↓ 3 callers
Method
rollback
rollback
txn.go:307
↓ 3 callers
Method
search
(key uint32)
public/utils/consistent/consistent.go:141
↓ 3 callers
Method
setActivityFile
()
db.go:415
↓ 3 callers
Method
setSetIndex
(key string, memTable meta.MemTable)
index.go:59
next →
1–100 of 564, ranked by callers