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
BackupGZ
BackupGZ writes a gzipped backup of the store
internal/db/store/store.go:338
Method
BatchGet
(rw *bufio.ReadWriter, keys [][]byte)
cmd/client/textprot/textprot.go:128
Method
CanParse
()
internal/proto/textprot/components.go:30
Method
Close
()
internal/nyx/raft_rpc.go:37
Method
Close
()
internal/server/server_test.go:29
Method
Close
()
internal/db/db.go:241
Method
Configure
(conn net.Conn)
internal/server/listen.go:38
Method
Count
()
internal/db/db.go:245
Method
Count
Count returns the number of active records
internal/db/store/shard/shard.go:490
Method
Delete
(opaque uint32)
internal/proto/proto.go:23
Method
Delete
(_ uint32)
internal/proto/textprot/respond.go:89
Method
Delete
(req common.DeleteRequest)
internal/nyx/kvs.go:90
Method
Delete
(_ common.DeleteRequest)
internal/server/server_test.go:112
Method
Delete
(req common.DeleteRequest)
internal/server/server_test.go:260
Method
Delete
(cmd common.DeleteRequest)
internal/db/db.go:205
Method
Delete
(key []byte, hash uint32)
internal/db/store/shard/shard.go:425
Method
Dial
(addr raft.ServerAddress, timeout time.Duration)
internal/nyx/raft_rpc.go:29
Method
EncodeEntry
EncodeEntry ... Encodes the entry and fields, and returns a buffer with the encoded log dict as a string.
internal/logging/logging.go:136
Method
Error
(_ uint32, _ common.RequestType, err error, _ bool)
internal/proto/textprot/respond.go:112
Method
Error
(req common.Request, reqType common.RequestType, err error)
internal/nyx/kvs.go:199
Method
Error
(_ common.Request, _ common.RequestType, _ error)
internal/server/server_test.go:149
Method
Error
(req common.Request, reqType common.RequestType, err error)
internal/server/server_test.go:292
Method
FileSize
FileSize returns the total disk storage size used by the shards.
internal/db/store/store.go:300
Method
Followers
()
e2e/cluster.go:52
Method
GAT
(response common.GetResponse)
internal/proto/proto.go:22
Method
GAT
(_ common.GetResponse)
internal/proto/textprot/respond.go:78
Method
GAT
(_ common.GATRequest)
internal/db/db.go:200
Method
Gat
(req common.GATRequest)
internal/nyx/nyx.go:109
Method
Gat
(req common.GATRequest)
internal/nyx/kvs.go:175
Method
Gat
(_ common.GATRequest)
internal/server/server_test.go:128
Method
Gat
(req common.GATRequest)
internal/server/server_test.go:272
Method
Get
(response common.GetResponse)
internal/proto/proto.go:19
Method
Get
(response common.GetResponse)
internal/proto/textprot/respond.go:41
Method
Get
(req common.GetRequest)
internal/nyx/kvs.go:106
Method
Get
(_ common.GetRequest)
internal/server/server_test.go:120
Method
Get
(_ common.GetRequest)
internal/server/server_test.go:296
Method
Get
(cmd common.GetRequest)
internal/db/db.go:134
Method
Get
(key []byte, hash uint32)
internal/db/store/shard/shard.go:387
Method
GetAddr
()
internal/server/listen.go:56
Method
GetE
(response common.GetEResponse)
internal/proto/proto.go:21
Method
GetE
(_ common.GetEResponse)
internal/proto/textprot/respond.go:74
Method
GetE
(req common.GetRequest)
internal/nyx/kvs.go:146
Method
GetE
(_ common.GetRequest)
internal/server/server_test.go:124
Method
GetE
(req common.GetRequest)
internal/server/server_test.go:268
Method
GetE
(cmd common.GetRequest)
internal/db/db.go:28
Method
GetE
(cmd common.GetRequest)
internal/db/db.go:166
Method
GetEnd
(_ uint32, _ bool)
internal/proto/textprot/respond.go:70
Method
GetMetadata
GetMetadata returns metadata for specific node_id and for a given key
internal/nyx/nyx.go:587
Method
GetMetadata
(id, key string)
internal/server/server_test.go:87
Method
GetMetadata
(_, _ string)
internal/server/server_test.go:312
Method
GetOpaque
()
internal/common/common.go:142
Method
GetOpaque
()
internal/common/common.go:161
Method
GetOpaque
()
internal/common/common.go:180
Method
GetOpaque
()
internal/common/common.go:197
Method
GetOpaque
()
internal/common/common.go:214
Method
GetOpaque
()
internal/common/common.go:229
Method
GetOpaque
()
internal/common/common.go:243
Method
GetOpaque
()
internal/common/common.go:257
Method
GetWithOpaque
(rw *bufio.ReadWriter, key []byte, _ int)
cmd/client/textprot/textprot.go:90
Method
IsQuiet
()
internal/common/common.go:146
Method
IsQuiet
()
internal/common/common.go:168
Method
IsQuiet
()
internal/common/common.go:184
Method
IsQuiet
()
internal/common/common.go:201
Method
IsQuiet
()
internal/common/common.go:218
Method
IsQuiet
()
internal/common/common.go:233
Method
IsQuiet
()
internal/common/common.go:247
Method
IsQuiet
()
internal/common/common.go:261
Method
Join
(id, addr string, metadata map[string]string)
internal/nyx/nyx.go:601
Method
Join
(id, addr string, metadata map[string]string)
internal/server/server_test.go:67
Method
Join
(_, _ string, _ map[string]string)
internal/server/server_test.go:316
Method
Join
(leader *Node)
e2e/node.go:109
Method
Leader
()
internal/server/server_test.go:324
Method
LeaderID
()
internal/nyx/nyx.go:567
Method
LeaderID
()
internal/server/server_test.go:77
Method
LeaderID
()
internal/server/server_test.go:308
Method
Less
(b btree.Item)
internal/db/store/bucket.go:14
Method
Loop
()
internal/server/server.go:45
Function
NewContext
NewContext ... A helper for middleware to create requestId or other context fields and return a context which logger can understand.
internal/logging/logging.go:29
Method
NewDisambiguator
(p proto.Peeker)
internal/proto/textprot/components.go:22
Method
NewRequestParser
(r *bufio.Reader)
internal/proto/textprot/components.go:14
Method
NewResponder
(w *bufio.Writer)
internal/proto/textprot/components.go:18
Function
NewStringJSONEncoder
NewStringJSONEncoder returns an encoder that encodes the JSON log dict as a string so the log processing path can correctly process logs with nested J
internal/logging/logging.go:127
Method
Noop
(opaque uint32)
internal/proto/proto.go:25
Method
Noop
(_ uint32)
internal/proto/textprot/respond.go:97
Method
Noop
(req common.NoopRequest)
internal/nyx/kvs.go:183
Method
Noop
(_ common.NoopRequest)
internal/server/server_test.go:132
Method
Noop
(req common.NoopRequest)
internal/server/server_test.go:276
Method
Parse
()
internal/proto/textprot/parser.go:25
Method
Parse
On first call, returns the values in the testReqParser On second call, always returns io.EOF
internal/server/server_test.go:153
Method
Path
Path returns the path to the store's storage directory
internal/nyx/nyx.go:553
Method
Persist
Persist writes the snapshot to the given sink
internal/nyx/nyx.go:44
Method
Prepend
(opaque uint32, quiet bool)
internal/proto/proto.go:18
Method
Prepend
(_ uint32, _ bool)
internal/proto/textprot/respond.go:37
Method
Prepend
(req common.SetRequest)
internal/nyx/kvs.go:82
Method
Prepend
(_ common.SetRequest)
internal/server/server_test.go:108
Method
Prepend
(req common.SetRequest)
internal/server/server_test.go:256
Method
Prepend
(cmd common.SetRequest)
internal/db/db.go:124
Method
Quit
(opaque uint32, quiet bool)
internal/proto/proto.go:26
Method
Quit
(_ uint32, quiet bool)
internal/proto/textprot/respond.go:101
Method
Quit
(req common.QuitRequest)
internal/nyx/kvs.go:187
← previous
next →
201–300 of 397, ranked by callers