MCPcopy Create free account

hub / github.com/Kirov7/CouloyDB / functions

Functions564 in github.com/Kirov7/CouloyDB

⨍ Functions 564◇ Types & classes 103
↓ 1 callersMethodIncrBy
(key []byte, delta int)
txn.go:514
↓ 1 callersMethodIsEmpty
()
public/ds/timeHeap.go:57
↓ 1 callersMethodIsMatch
IsMatch returns whether the given string matches pattern
public/utils/wildcard/wildcard.go:105
↓ 1 callersMethodListKeys
ListKeys get all the key and return
db.go:241
↓ 1 callersMethodMSet
(args [][]byte)
txn.go:607
↓ 1 callersFunctionMakeClient
MakeClient creates a new client
server/resp/client/client.go:41
↓ 1 callersFunctionMakeOkReply
MakeOkReply returns a ok reply
server/resp/reply/consts.go:26
↓ 1 callersMethodMerge
()
merge.go:15
↓ 1 callersFunctionNewAdaptiveRadixTree
()
meta/art.go:16
↓ 1 callersFunctionNewClusterDB
MakeClusterDatabase creates and starts a node of cluster
server/database/clusterdb.go:32
↓ 1 callersFunctionNewCouloyDict
NewCouloyDict makes a new map
server/database/datastruct/dict/couloyDict.go:14
↓ 1 callersFunctionNewEventQueue
()
public/ds/eventQueue.go:13
↓ 1 callersFunctionNewFileIOManager
(fileName string)
driver/fileIO.go:11
↓ 1 callersFunctionNewHashMap
()
meta/hmap.go:14
↓ 1 callersFunctionNewIOManager
NewIOManager Init IOManager instance attention! the IOManager is only support FileIO
driver/ioManager.go:25
↓ 1 callersFunctionNewMMap
(fileName string)
driver/mmap.go:13
↓ 1 callersFunctionNewMutilDB
NewDatabase creates a redis database,
server/database/mutildb.go:21
↓ 1 callersFunctionNewTimeHeap
()
public/ds/timeHeap.go:12
↓ 1 callersMethodPersist
(key []byte)
db.go:716
↓ 1 callersMethodPop
Pop removes and returns the job with the earliest expiration time from the heap.
public/ds/timeHeap.go:86
↓ 1 callersMethodPush
Push adds a job to the heap.
public/ds/timeHeap.go:79
↓ 1 callersMethodPut
(key, value []byte)
db.go:121
↓ 1 callersMethodPutIfExists
(key string, val []byte)
server/database/datastruct/dict/dict.go:12
↓ 1 callersMethodRemove
(key string)
public/ds/timeHeap.go:43
↓ 1 callersMethodRemove
Remove the given key from db
server/database/mutildb.go:162
↓ 1 callersMethodSCard
(key []byte)
txnSet.go:119
↓ 1 callersMethodSRem
(key []byte, members ...[]byte)
txnSet.go:50
↓ 1 callersMethodSeek
(key []byte)
meta/memTable.go:48
↓ 1 callersMethodSend
Send sends a request to redis server
server/resp/client/client.go:118
↓ 1 callersMethodServe
(l net.Listener)
server/server.go:78
↓ 1 callersMethodSet
(key, val interface{})
server/sliceRouter.go:57
↓ 1 callersMethodSetSelectedDB
(dbNum int)
server/conn.go:76
↓ 1 callersMethodSetSyncWrites
(sync bool)
options.go:75
↓ 1 callersMethodStart
Start starts asynchronous goroutines
server/resp/client/client.go:56
↓ 1 callersMethodStrLen
(key []byte)
txn.go:498
↓ 1 callersMethodWatch
(ctx context.Context, key string)
db.go:720
↓ 1 callersMethodWrite
(buf []byte)
data/dataFile.go:138
↓ 1 callersMethodWriteHintRecord
WriteHintRecord write the index info to the hint file
data/dataFile.go:114
↓ 1 callersMethodaddActiveTxn
(startTs int64)
txn.go:130
↓ 1 callersMethodallocPushSeq
(headSeq, tailSeq *big.Float, left bool)
txnList.go:235
↓ 1 callersFunctionbyteToStringSlice
(input [][]byte)
server/database/datastruct/dict/couloyDict.go:118
↓ 1 callersFunctioncastNumToByte
(num K)
public/utils/consistent/consistent.go:277
↓ 1 callersFunctioncheckOptions
(opt *Options)
db.go:429
↓ 1 callersMethodcleanupCommitTxn
Clears all transactions whose commitTs is less than the minimum startTs in all active transactions
txn.go:113
↓ 1 callersMethodcloseWatcherListener
(watcher *Watcher)
watch.go:39
↓ 1 callersMethodcontains
(c byte)
public/utils/wildcard/wildcard.go:19
↓ 1 callersFunctiondeleteLessThan
(s []T, val T)
db.go:756
↓ 1 callersMethoddoHeartbeat
()
server/resp/client/client.go:138
↓ 1 callersMethoddoRequest
(req *request)
server/resp/client/client.go:151
↓ 1 callersFunctionencodeListKey
(seq, prevSeq, nextSeq *big.Float, key []byte)
txnList.go:296
↓ 1 callersMethodexec
()
ttl.go:71
↓ 1 callersFunctionexecSelect
(c *server.Conn, mdb *MutilDB, args [][]byte)
server/database/mutildb.go:63
↓ 1 callersMethodfinished
()
server/resp/parser/parser.go:35
↓ 1 callersMethodgetAsString
(key string)
server/database/string.go:15
↓ 1 callersMethodgetDoneChan
()
server/server.go:106
↓ 1 callersFunctiongetIP
(addr string)
server/database/clusterdb.go:210
↓ 1 callersFunctiongetIPs
(addrs ...string)
server/database/clusterdb.go:198
↓ 1 callersMethodgetLogPosByLeftOrRight
(key []byte, left, right *big.Float, isLeft bool)
txnList.go:245
↓ 1 callersMethodgetPeerClient
(peer string)
server/database/clusterdb.go:121
↓ 1 callersMethodhandleConnectionError
(err error)
server/resp/client/client.go:82
↓ 1 callersMethodhandleWrite
()
server/resp/client/client.go:111
↓ 1 callersMethodhasConflict
(txn *Txn)
txn.go:48
↓ 1 callersMethodhashKeyCRC32
(key string)
public/utils/consistent/consistent.go:236
↓ 1 callersMethodhashKeyFnv
(key string)
public/utils/consistent/consistent.go:245
↓ 1 callersMethodheartbeat
()
server/resp/client/client.go:105
↓ 1 callersMethodinitLuaInterpreter
()
eval.go:42
↓ 1 callersMethodinitOracle
()
txn.go:35
↓ 1 callersMethodisExpired
(key string)
ttl.go:43
↓ 1 callersFunctionkuloyServerStart
(addr string)
cmd/standalone/standalone.go:105
↓ 1 callersFunctionkuloyServerStart
(addr string)
cmd/cluster/cluster.go:94
↓ 1 callersMethodloadDataFile
()
db.go:442
↓ 1 callersMethodloadIndex
(fids []int)
db.go:487
↓ 1 callersMethodloadIndexFromHintFile
()
merge.go:257
↓ 1 callersMethodloadMergeFiles
()
merge.go:182
↓ 1 callersMethodlock
()
txn.go:622
↓ 1 callersMethodmerge
Merge Clear invalid data and generate the hint file
merge.go:21
↓ 1 callersMethodmergeWorker
()
db.go:334
↓ 1 callersFunctionnewArtIterator
(artree *AdaptiveRadixTree, reverse bool)
meta/art.go:70
↓ 1 callersMethodnewBegin
(txn *Txn)
txn.go:101
↓ 1 callersFunctionnewBtreeIterator
(bt *BTree, reverse bool)
meta/btree.go:84
↓ 1 callersMethodnewCommit
(txn *Txn)
txn.go:87
↓ 1 callersMethodnewConn
(rwc net.Conn)
server/conn.go:20
↓ 1 callersFunctionnewHashMapIterator
(m *HashMap, reverse bool)
meta/hmap.go:69
↓ 1 callersFunctionnewTTL
(deleter func(key string) error)
ttl.go:19
↓ 1 callersFunctionnewTcpSliceRouterContext
(conn net.Conn, r *TcpSliceRouter, ctx context.Context)
server/sliceRouter.go:30
↓ 1 callersFunctionnewWatcherManager
()
watch.go:30
↓ 1 callersFunctionparse0
(reader io.Reader, ch chan<- *Payload)
server/resp/parser/parser.go:39
↓ 1 callersFunctionparseBulkHeader
(msg []byte, state *readState)
server/resp/parser/parser.go:192
↓ 1 callersFunctionparseMultiBulkHeader
(msg []byte, state *readState)
server/resp/parser/parser.go:170
↓ 1 callersFunctionparseSingleLineReply
(msg []byte)
server/resp/parser/parser.go:211
↓ 1 callersMethodpeek
peek returns the job with the earliest expiration time without removing it from the heap.
public/ds/timeHeap.go:99
↓ 1 callersMethodpeekActiveTxn
peek Find the active transaction with the smallest start timestamp
txn.go:136
↓ 1 callersFunctionreadBody
read the non-first lines of multi bulk reply or bulk reply
server/resp/parser/parser.go:238
↓ 1 callersFunctionreadLine
(bufReader *bufio.Reader, state *readState)
server/resp/parser/parser.go:143
↓ 1 callersMethodremoveActiveTxn
remove Removes the specified transaction from the active transaction heap
txn.go:145
↓ 1 callersMethodreturnPeerClient
(peer string, peerClient *client.Client)
server/database/clusterdb.go:141
↓ 1 callersMethodsendResp
(event *watchEvent)
watch.go:138
↓ 1 callersMethodserve
(ctx context.Context)
server/conn.go:48
↓ 1 callersMethodshuttingDown
()
server/server.go:44
↓ 1 callersFunctionsliceContainsMember
(set []string, member string)
public/utils/consistent/consistent.go:264
← previousnext →201–300 of 564, ranked by callers