Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/DenzelPenzel/nyx
/ functions
Functions
397 in github.com/DenzelPenzel/nyx
⨍
Functions
397
◇
Types & classes
71
Method
Quit
(_ common.QuitRequest)
internal/server/server_test.go:136
Method
Quit
(req common.QuitRequest)
internal/server/server_test.go:280
Method
Release
()
internal/nyx/nyx.go:80
Method
Remove
(addr string)
internal/nyx/nyx.go:182
Method
Remove
(addr string)
internal/server/server_test.go:72
Method
Remove
(_ string)
internal/server/server_test.go:320
Method
Remove
Remove deletes a key from the store
internal/db/store/store.go:255
Method
RemoveNode
(n *Node)
e2e/cluster.go:72
Method
Replace
(opaque uint32, quiet bool)
internal/proto/proto.go:16
Method
Replace
(_ uint32, _ bool)
internal/proto/textprot/respond.go:29
Method
Replace
(req common.SetRequest)
internal/nyx/kvs.go:66
Method
Replace
(_ common.SetRequest)
internal/server/server_test.go:100
Method
Replace
(req common.SetRequest)
internal/server/server_test.go:248
Method
Replace
(cmd common.SetRequest)
internal/db/db.go:99
Method
Restore
Restore restores the node to a previous state
internal/nyx/nyx.go:432
Method
Restore
(name string)
internal/db/db.go:36
Method
Restore
(_ string)
internal/db/db.go:266
Method
Restore
Restore restores the store from a backup TODO: implement restore logic.
internal/db/store/store.go:346
Function
RunFastCache
RunFastCache ... Application entry point
cmd/nyx/main.go:143
Method
Set
(opaque uint32, quiet bool)
internal/proto/proto.go:14
Method
Set
(_ uint32, _ bool)
internal/proto/textprot/respond.go:21
Method
Set
(req common.SetRequest)
internal/nyx/kvs.go:25
Method
Set
(_ common.SetRequest)
internal/server/server_test.go:92
Method
Set
(_ common.SetRequest)
internal/server/server_test.go:300
Method
Set
(cmd common.SetRequest)
internal/db/db.go:75
Method
Set
(key, value []byte, hash, expire uint32)
internal/db/store/shard/shard.go:291
Method
SetResponder
(resp proto.Responder)
internal/nyx/nyx.go:313
Method
SetResponder
(resp proto.Responder)
internal/server/server_test.go:62
Method
SetResponder
(resp proto.Responder)
internal/server/server_test.go:239
Method
Shutdown
Shutdown ... Shutdown each Node in Cluster
e2e/cluster.go:83
Method
Snapshot
Snapshot returns a snapshot of the database. The caller must ensure that no transaction is taking place during this call. Hashicorp Raft guarantees th
internal/nyx/nyx.go:412
Method
Stats
Stats ... Returns info about the storage
internal/nyx/nyx.go:132
Method
Stats
()
internal/nyx/nyx.go:187
Method
Stats
()
internal/server/server_test.go:82
Method
Stats
()
internal/server/server_test.go:304
Method
Stats
()
internal/db/db.go:34
Method
Stats
()
internal/db/db.go:249
Method
Status
()
e2e/node.go:57
Function
TestBackup
(t *testing.T)
internal/db/store/shard/shard_test.go:127
Function
TestBackupStream
(t *testing.T)
internal/db/store/shard/shard_test.go:198
Function
TestConcurrentAccess
(t *testing.T)
internal/db/store/shard/shard_test.go:160
Function
TestCounterOperations
(t *testing.T)
internal/db/store/shard/shard_test.go:87
Function
TestDelete
(t *testing.T)
internal/db/store/shard/shard_test.go:69
Function
TestEncodeDecodeRecordMeta
TestEncodeDecodeRecordMeta verifies that the Encode and Decode functions work as expected. Note that the expiration encoding is lossy: the decoded exp
internal/db/store/record_meta/record_meta_test.go:16
Function
TestExpireKeys
(t *testing.T)
internal/db/store/shard/shard_test.go:107
Function
TestFileSize
(t *testing.T)
internal/db/store/shard/shard_test.go:151
Function
TestNewMarshalUnmarshalRecord
(t *testing.T)
internal/db/store/record_header/record_header_test.go:9
Function
TestOpenAndWriteRead
(t *testing.T)
internal/db/store/shard/shard_test.go:32
Function
TestReadFileVersion
(t *testing.T)
internal/db/store/record_meta/record_meta_test.go:56
Function
TestSync
(t *testing.T)
internal/db/store/shard/shard_test.go:183
Function
TestUpdateExpiry
(t *testing.T)
internal/db/store/shard/shard_test.go:49
Function
Test_Add
(t *testing.T)
internal/db/db_test.go:128
Function
Test_AddExistingKey
(t *testing.T)
internal/db/db_test.go:153
Function
Test_Append
(t *testing.T)
internal/db/db_test.go:216
Function
Test_BucketEmptyKey
(t *testing.T)
internal/db/store/store_test.go:264
Function
Test_BucketOperations
(t *testing.T)
internal/db/store/store_test.go:282
Function
Test_ConcurrentAccess
(t *testing.T)
internal/db/store/store_test.go:324
Function
Test_ExpireKeys
(t *testing.T)
internal/db/store/store_test.go:306
Function
Test_HTTPServer
(t *testing.T)
internal/server/server_test.go:372
Function
Test_HashCollision
(t *testing.T)
internal/db/store/store_test.go:126
Function
Test_ManyKeysOp
(t *testing.T)
internal/db/store/store_test.go:141
Function
Test_MultiBucketStore
(t *testing.T)
internal/db/store/bucket_test.go:87
Function
Test_MultiNodes
(t *testing.T)
e2e/cluster_test.go:9
Function
Test_MultiOp
(t *testing.T)
internal/db/db_test.go:41
Function
Test_Network
(t *testing.T)
internal/network/network_test.go:10
Function
Test_Operations
(t *testing.T)
internal/db/store/store_test.go:31
Function
Test_Prepend
(t *testing.T)
internal/db/db_test.go:256
Function
Test_ReadAfterClose
(t *testing.T)
internal/db/store/store_test.go:96
Function
Test_Replace
(t *testing.T)
internal/db/db_test.go:177
Function
Test_Server
(t *testing.T)
internal/server/server_test.go:161
Function
Test_SingleBucketStore
Test_SingleBucketStore verifies that keys added via BucketPut are stored with a composite key (bucket name + key) and retrievable
internal/db/store/bucket_test.go:16
Function
Test_SingleShard
(t *testing.T)
internal/db/store/store_test.go:240
Method
Touch
(opaque uint32)
internal/proto/proto.go:24
Method
Touch
(_ uint32)
internal/proto/textprot/respond.go:93
Method
Touch
(req common.TouchRequest)
internal/nyx/kvs.go:98
Method
Touch
(_ common.TouchRequest)
internal/server/server_test.go:116
Method
Touch
(req common.TouchRequest)
internal/server/server_test.go:264
Method
Touch
(cmd common.TouchRequest)
internal/db/db.go:232
Method
Touch
Touch updates the expiration time of a key
internal/db/store/store.go:222
Method
Touch
Touch updates the expiration time of an existing record
internal/db/store/shard/shard.go:352
Method
Unknown
(req common.Request)
internal/nyx/nyx.go:117
Method
Unknown
(_ common.Request)
internal/nyx/kvs.go:195
Method
Unknown
(_ common.Request)
internal/server/server_test.go:144
Method
Unknown
(req common.Request)
internal/server/server_test.go:288
Method
Version
(opaque uint32)
internal/proto/proto.go:27
Method
Version
(_ uint32)
internal/proto/textprot/respond.go:108
Method
Version
(req common.VersionRequest)
internal/nyx/kvs.go:191
Method
Version
(_ common.VersionRequest)
internal/server/server_test.go:140
Method
Version
(req common.VersionRequest)
internal/server/server_test.go:284
Method
WaitForNewLeader
(oldLeader *Node)
e2e/cluster.go:30
Function
WithSyncInterval
WithSyncInterval sets up a background interval to fsync shards. If interval > 0, a background task will periodically flush shard data.
internal/db/store/store.go:83
Method
getAPIURL
(suffix string)
e2e/node.go:80
Method
leaderID
()
internal/server/http.go:156
Function
main
()
cmd/client/rand/main.go:46
Function
main
()
cmd/nyx/main.go:14
Method
postRequest
(u *url.URL, j string)
e2e/node.go:89
Function
run
(c *cli.Context)
cmd/client/rand/main.go:83
← previous
301–397 of 397, ranked by callers