MCPcopy Create free account

hub / github.com/DenzelPenzel/nyx / functions

Functions397 in github.com/DenzelPenzel/nyx

↓ 70 callersMethodError
(req common.Request, reqType common.RequestType, err error)
internal/nyx/nyx.go:119
↓ 66 callersMethodString
()
cmd/client/rand/types.go:5
↓ 45 callersMethodClose
()
internal/db/db.go:32
↓ 31 callersMethodGet
(cmd common.GetRequest)
internal/db/db.go:27
↓ 30 callersMethodSet
(cmd common.SetRequest)
internal/db/db.go:22
↓ 18 callersMethodAdd
(cmd common.SetRequest)
internal/db/db.go:23
↓ 18 callersMethodresp
(s string)
internal/proto/textprot/respond.go:137
↓ 16 callersFunctionshutdown
(conn []io.Closer, err error)
internal/server/listen.go:73
↓ 14 callersMethodRemove
Remove node from the cluster
internal/nyx/nyx.go:126
↓ 13 callersFunctionWithContext
WithContext ... Pass in a context containing values to add to each log message
internal/logging/logging.go:34
↓ 11 callersMethodJoin
Join connects the node, identified by the provided ID and reachable at the specified address, to the current node
internal/nyx/nyx.go:123
↓ 10 callersFunctionGetTCPAddr
(addr string)
internal/utils/utils.go:34
↓ 10 callersFunctioncreateTempShard
(t *testing.T)
internal/db/store/shard/shard_test.go:17
↓ 9 callersMethodGet
Get retrieves the value for a given key
internal/db/store/store.go:239
↓ 8 callersFunctionDecode
Decode unpacks the encoded record meta into its components The expiration value is reconstructed by left-shifting the stored 24-bit value by 9 bits an
internal/db/store/record_meta/record_meta.go:24
↓ 8 callersMethodStop
()
internal/interval/interval.go:44
↓ 7 callersFunctionJoin
(joinAddrs []string, id string, addr *net.TCPAddr, meta map[string]string)
internal/server/server.go:110
↓ 7 callersFunctionNewDataStore
(opts ...StoreOption)
internal/db/store/store.go:123
↓ 7 callersFunctionWithDirectory
WithDirectory sets the directory where shard files are stored
internal/db/store/store.go:42
↓ 6 callersMethodCount
()
internal/db/db.go:33
↓ 6 callersMethodDelete
(cmd common.DeleteRequest)
internal/db/db.go:30
↓ 6 callersMethodError
(opaque uint32, reqType common.RequestType, err error, quiet bool)
internal/proto/proto.go:28
↓ 6 callersMethodParse
()
internal/proto/proto.go:10
↓ 6 callersMethodShutdown
()
e2e/node.go:35
↓ 6 callersFunctionmockDB
()
internal/db/store/store_test.go:21
↓ 6 callersFunctionopenDB
()
internal/db/db_test.go:18
↓ 6 callersMethodshardIndex
shardIndex computes the primary shard index for a given key hash
internal/db/store/store.go:199
↓ 5 callersMethodBackup
(name string)
internal/db/db.go:35
↓ 5 callersMethodBucketPut
BucketPut stores a key/value pair under the given bucket.
internal/db/store/bucket.go:52
↓ 5 callersMethodClose
Close shuts down background tasks and closes all shard files
internal/db/store/store.go:284
↓ 5 callersMethodCounter
Counter updates a numeric counter stored as an 8-byte value
internal/db/store/shard/shard.go:454
↓ 5 callersFunctionEncode
Encode packs the given record pointer components into a single uint64 value The encoding layout is as follows: - Upper 32 bits: file address (addr) -
internal/db/store/record_meta/record_meta.go:17
↓ 5 callersFunctionNewNetwork
()
internal/network/network.go:12
↓ 5 callersFunctionNoContext
NoContext ... A log helper to log when there's no context. Rare case usage
internal/logging/logging.go:47
↓ 5 callersFunctionReadFileVersion
ReadFileVersion reads the first two bytes from the given file to determine the shard file version. It returns 0 if the header indicates an old version
internal/db/store/record_meta/record_meta.go:37
↓ 5 callersMethodSet
Set stores the key and value with an expiration time (in seconds), max packet size 2^19, 512kb (524288) packet size = len(key) + len(val) + 8
internal/db/store/store.go:205
↓ 5 callersMethodTouch
(cmd common.TouchRequest)
internal/db/db.go:31
↓ 5 callersFunctionUnmarshal
(b []byte)
internal/db/store/record_header/record_header.go:105
↓ 5 callersMethodWaitForLeader
()
e2e/node.go:53
↓ 5 callersFunctionpercent
(data []int, p float64)
cmd/client/rand/stats.go:52
↓ 5 callersFunctionsetRequest
(r *bufio.Reader, clParts []string, reqType common.RequestType, start int64)
internal/proto/textprot/parser.go:133
↓ 4 callersMethodAccept
()
internal/server/listen.go:24
↓ 4 callersMethodBucket
Bucket returns (or creates) a bucket with the given name.
internal/db/store/bucket.go:31
↓ 4 callersMethodDial
Dial - makes outgoing connections to other servers in the Raft cluster When we connect to a server, we write the RaftRPC byte to identify the connecti
internal/nyx/raft_rpc.go:16
↓ 4 callersMethodOpen
(addr string)
internal/network/network.go:16
↓ 4 callersFunctionWriteRecordHeader
(b []byte, header *RecordHeader)
internal/db/store/record_header/record_header.go:84
↓ 4 callersFunctioncreateTempFileWithContent
(t *testing.T, content []byte)
internal/db/store/record_meta/record_meta_test.go:40
↓ 3 callersMethodAppend
(cmd common.SetRequest)
internal/db/db.go:25
↓ 3 callersMethodApply
(l *raft.Log)
internal/nyx/nyx.go:344
↓ 3 callersFunctionCreateNewNode
(enableSingle bool)
e2e/node.go:146
↓ 3 callersMethodExpireExpiredKeys
ExpireExpiredKeys scans for expired records and removes them from the index
internal/db/store/shard/shard.go:227
↓ 3 callersFunctionGenKeys
(totKeys int)
internal/utils/utils.go:60
↓ 3 callersMethodID
ID returns the raft ID
internal/nyx/nyx.go:558
↓ 3 callersMethodLeader
()
e2e/cluster.go:22
↓ 3 callersMethodListenAndServeHTTP
()
internal/server/http.go:42
↓ 3 callersFunctionNewDB
(ctx context.Context, cfg *config.DBConfig)
internal/db/db.go:53
↓ 3 callersFunctionNewHTTPServer
(ctx context.Context, cfg *config.ServerConfig, storage nyx.DBHandler)
internal/server/http.go:31
↓ 3 callersFunctionRandData
(length int64)
internal/utils/utils.go:50
↓ 3 callersFunctionReadRecordHeader
ReadRecordHeader reads a RecordHeader from the provided reader based on the version If the reader reaches EOF without any data, a nil header and nil e
internal/db/store/record_header/record_header.go:64
↓ 3 callersMethodReplace
(cmd common.SetRequest)
internal/db/db.go:24
↓ 3 callersMethodSync
Sync persists pending changes if needed
internal/db/store/shard/shard.go:216
↓ 3 callersFunctionWithShardCollisionCount
WithShardCollisionCount sets the number of collision shards. The default is 4; if set to zero, a collision will result in an error
internal/db/store/store.go:65
↓ 3 callersFunctionWithTotalShards
WithTotalShards sets the total number of shards. Ensure that totalShards > shardCollisionCount.
internal/db/store/store.go:74
↓ 2 callersMethodAdd
(req common.SetRequest)
internal/nyx/nyx.go:93
↓ 2 callersMethodAddr
Addr returns the address of the store
internal/nyx/nyx.go:563
↓ 2 callersMethodAddr
()
internal/network/network.go:47
↓ 2 callersMethodAppend
(req common.SetRequest)
internal/nyx/nyx.go:97
↓ 2 callersMethodClose
()
internal/network/network.go:43
↓ 2 callersMethodCount
Count returns the total number of keys stored
internal/db/store/store.go:275
↓ 2 callersMethodDecrement
(key []byte, v uint64)
internal/db/store/store.go:318
↓ 2 callersMethodDelete
(req common.DeleteRequest)
internal/nyx/nyx.go:101
↓ 2 callersMethodGAT
(cmd common.GATRequest)
internal/db/db.go:29
↓ 2 callersMethodGet
(req common.GetRequest)
internal/nyx/nyx.go:105
↓ 2 callersMethodGet
(rw *bufio.ReadWriter, key []byte)
cmd/client/textprot/textprot.go:94
↓ 2 callersMethodGetE
(req common.GetRequest)
internal/nyx/nyx.go:107
↓ 2 callersMethodGetEnd
(opaque uint32, noopEnd bool)
internal/proto/proto.go:20
↓ 2 callersMethodIncrement
(key []byte, v uint64)
internal/db/store/store.go:312
↓ 2 callersFunctionIsMiss
(err error)
internal/common/common.go:76
↓ 2 callersMethodLeaderAddr
()
internal/nyx/nyx.go:548
↓ 2 callersMethodLeaderID
LeaderID ... Returns the raft leader
internal/nyx/nyx.go:129
↓ 2 callersMethodLoop
()
internal/server/server.go:28
↓ 2 callersFunctionMarshal
Marshal builds a complete binary record for the given key, value, and expiration The resulting record consists of the fixed header, followed by the va
internal/db/store/record_header/record_header.go:94
↓ 2 callersFunctionNew
(ctx context.Context, cfg *config.Config, raftLayer Listener, res proto.Responder)
internal/nyx/nyx.go:192
↓ 2 callersFunctionNewIntervalRunner
NewIntervalRunner creates and starts an IntervalRunner that calls fn at each tick of the ticker. The function fn receives the tick time as its argumen
internal/interval/interval.go:18
↓ 2 callersMethodNewRequestParser
(r *bufio.Reader)
internal/proto/proto.go:41
↓ 2 callersMethodNewResponder
(w *bufio.Writer)
internal/proto/proto.go:42
↓ 2 callersFunctionNewServer
(conns []io.Closer, rp proto.RequestParser, storage nyx.DBHandler)
internal/server/server.go:37
↓ 2 callersFunctionNextPowerOf2
NextPowerOf2 ... Return next power of 2 for v
internal/utils/utils.go:16
↓ 2 callersMethodOpen
(allowSingle bool)
internal/nyx/nyx.go:212
↓ 2 callersMethodOpenShard
OpenShard opens (or creates) the shard file and initializes the in-memory index
internal/db/store/shard/shard.go:151
↓ 2 callersFunctionParseRecordHeader
(b []byte)
internal/db/store/record_header/record_header.go:52
↓ 2 callersMethodPrepend
(req common.SetRequest)
internal/nyx/nyx.go:99
↓ 2 callersMethodPrepend
(cmd common.SetRequest)
internal/db/db.go:26
↓ 2 callersFunctionRandomString
(n int)
internal/utils/utils.go:117
↓ 2 callersMethodReplace
(req common.SetRequest)
internal/nyx/nyx.go:95
↓ 2 callersMethodSet
(req common.SetRequest)
internal/nyx/nyx.go:91
↓ 2 callersMethodShutDown
()
internal/server/http.go:89
↓ 2 callersFunctionTempDir
(name string)
internal/utils/utils.go:42
↓ 2 callersMethodTouch
(req common.TouchRequest)
internal/nyx/nyx.go:103
↓ 2 callersMethodfindNode
(addr string)
e2e/cluster.go:13
next →1–100 of 397, ranked by callers