MCPcopy Create free account

hub / github.com/DenzelPenzel/nyx / functions

Functions397 in github.com/DenzelPenzel/nyx

MethodBackupGZ
BackupGZ writes a gzipped backup of the store
internal/db/store/store.go:338
MethodBatchGet
(rw *bufio.ReadWriter, keys [][]byte)
cmd/client/textprot/textprot.go:128
MethodCanParse
()
internal/proto/textprot/components.go:30
MethodClose
()
internal/nyx/raft_rpc.go:37
MethodClose
()
internal/server/server_test.go:29
MethodClose
()
internal/db/db.go:241
MethodConfigure
(conn net.Conn)
internal/server/listen.go:38
MethodCount
()
internal/db/db.go:245
MethodCount
Count returns the number of active records
internal/db/store/shard/shard.go:490
MethodDelete
(opaque uint32)
internal/proto/proto.go:23
MethodDelete
(_ uint32)
internal/proto/textprot/respond.go:89
MethodDelete
(req common.DeleteRequest)
internal/nyx/kvs.go:90
MethodDelete
(_ common.DeleteRequest)
internal/server/server_test.go:112
MethodDelete
(req common.DeleteRequest)
internal/server/server_test.go:260
MethodDelete
(cmd common.DeleteRequest)
internal/db/db.go:205
MethodDelete
(key []byte, hash uint32)
internal/db/store/shard/shard.go:425
MethodDial
(addr raft.ServerAddress, timeout time.Duration)
internal/nyx/raft_rpc.go:29
MethodEncodeEntry
EncodeEntry ... Encodes the entry and fields, and returns a buffer with the encoded log dict as a string.
internal/logging/logging.go:136
MethodError
(_ uint32, _ common.RequestType, err error, _ bool)
internal/proto/textprot/respond.go:112
MethodError
(req common.Request, reqType common.RequestType, err error)
internal/nyx/kvs.go:199
MethodError
(_ common.Request, _ common.RequestType, _ error)
internal/server/server_test.go:149
MethodError
(req common.Request, reqType common.RequestType, err error)
internal/server/server_test.go:292
MethodFileSize
FileSize returns the total disk storage size used by the shards.
internal/db/store/store.go:300
MethodFollowers
()
e2e/cluster.go:52
MethodGAT
(response common.GetResponse)
internal/proto/proto.go:22
MethodGAT
(_ common.GetResponse)
internal/proto/textprot/respond.go:78
MethodGAT
(_ common.GATRequest)
internal/db/db.go:200
MethodGat
(req common.GATRequest)
internal/nyx/nyx.go:109
MethodGat
(req common.GATRequest)
internal/nyx/kvs.go:175
MethodGat
(_ common.GATRequest)
internal/server/server_test.go:128
MethodGat
(req common.GATRequest)
internal/server/server_test.go:272
MethodGet
(response common.GetResponse)
internal/proto/proto.go:19
MethodGet
(response common.GetResponse)
internal/proto/textprot/respond.go:41
MethodGet
(req common.GetRequest)
internal/nyx/kvs.go:106
MethodGet
(_ common.GetRequest)
internal/server/server_test.go:120
MethodGet
(_ common.GetRequest)
internal/server/server_test.go:296
MethodGet
(cmd common.GetRequest)
internal/db/db.go:134
MethodGet
(key []byte, hash uint32)
internal/db/store/shard/shard.go:387
MethodGetAddr
()
internal/server/listen.go:56
MethodGetE
(response common.GetEResponse)
internal/proto/proto.go:21
MethodGetE
(_ common.GetEResponse)
internal/proto/textprot/respond.go:74
MethodGetE
(req common.GetRequest)
internal/nyx/kvs.go:146
MethodGetE
(_ common.GetRequest)
internal/server/server_test.go:124
MethodGetE
(req common.GetRequest)
internal/server/server_test.go:268
MethodGetE
(cmd common.GetRequest)
internal/db/db.go:28
MethodGetE
(cmd common.GetRequest)
internal/db/db.go:166
MethodGetEnd
(_ uint32, _ bool)
internal/proto/textprot/respond.go:70
MethodGetMetadata
GetMetadata returns metadata for specific node_id and for a given key
internal/nyx/nyx.go:587
MethodGetMetadata
(id, key string)
internal/server/server_test.go:87
MethodGetMetadata
(_, _ string)
internal/server/server_test.go:312
MethodGetOpaque
()
internal/common/common.go:142
MethodGetOpaque
()
internal/common/common.go:161
MethodGetOpaque
()
internal/common/common.go:180
MethodGetOpaque
()
internal/common/common.go:197
MethodGetOpaque
()
internal/common/common.go:214
MethodGetOpaque
()
internal/common/common.go:229
MethodGetOpaque
()
internal/common/common.go:243
MethodGetOpaque
()
internal/common/common.go:257
MethodGetWithOpaque
(rw *bufio.ReadWriter, key []byte, _ int)
cmd/client/textprot/textprot.go:90
MethodIsQuiet
()
internal/common/common.go:146
MethodIsQuiet
()
internal/common/common.go:168
MethodIsQuiet
()
internal/common/common.go:184
MethodIsQuiet
()
internal/common/common.go:201
MethodIsQuiet
()
internal/common/common.go:218
MethodIsQuiet
()
internal/common/common.go:233
MethodIsQuiet
()
internal/common/common.go:247
MethodIsQuiet
()
internal/common/common.go:261
MethodJoin
(id, addr string, metadata map[string]string)
internal/nyx/nyx.go:601
MethodJoin
(id, addr string, metadata map[string]string)
internal/server/server_test.go:67
MethodJoin
(_, _ string, _ map[string]string)
internal/server/server_test.go:316
MethodJoin
(leader *Node)
e2e/node.go:109
MethodLeader
()
internal/server/server_test.go:324
MethodLeaderID
()
internal/nyx/nyx.go:567
MethodLeaderID
()
internal/server/server_test.go:77
MethodLeaderID
()
internal/server/server_test.go:308
MethodLess
(b btree.Item)
internal/db/store/bucket.go:14
MethodLoop
()
internal/server/server.go:45
FunctionNewContext
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
MethodNewDisambiguator
(p proto.Peeker)
internal/proto/textprot/components.go:22
MethodNewRequestParser
(r *bufio.Reader)
internal/proto/textprot/components.go:14
MethodNewResponder
(w *bufio.Writer)
internal/proto/textprot/components.go:18
FunctionNewStringJSONEncoder
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
MethodNoop
(opaque uint32)
internal/proto/proto.go:25
MethodNoop
(_ uint32)
internal/proto/textprot/respond.go:97
MethodNoop
(req common.NoopRequest)
internal/nyx/kvs.go:183
MethodNoop
(_ common.NoopRequest)
internal/server/server_test.go:132
MethodNoop
(req common.NoopRequest)
internal/server/server_test.go:276
MethodParse
()
internal/proto/textprot/parser.go:25
MethodParse
On first call, returns the values in the testReqParser On second call, always returns io.EOF
internal/server/server_test.go:153
MethodPath
Path returns the path to the store's storage directory
internal/nyx/nyx.go:553
MethodPersist
Persist writes the snapshot to the given sink
internal/nyx/nyx.go:44
MethodPrepend
(opaque uint32, quiet bool)
internal/proto/proto.go:18
MethodPrepend
(_ uint32, _ bool)
internal/proto/textprot/respond.go:37
MethodPrepend
(req common.SetRequest)
internal/nyx/kvs.go:82
MethodPrepend
(_ common.SetRequest)
internal/server/server_test.go:108
MethodPrepend
(req common.SetRequest)
internal/server/server_test.go:256
MethodPrepend
(cmd common.SetRequest)
internal/db/db.go:124
MethodQuit
(opaque uint32, quiet bool)
internal/proto/proto.go:26
MethodQuit
(_ uint32, quiet bool)
internal/proto/textprot/respond.go:101
MethodQuit
(req common.QuitRequest)
internal/nyx/kvs.go:187
← previousnext →201–300 of 397, ranked by callers