MCPcopy Create free account

hub / github.com/DenzelPenzel/nyx / functions

Functions397 in github.com/DenzelPenzel/nyx

↓ 2 callersMethodget
(key []byte, hash uint32)
internal/db/store/shard/shard.go:393
↓ 2 callersFunctionlistener
(port int)
internal/dyport/dyport.go:68
↓ 2 callersFunctionrenderStats
(t string, op Op, data []int)
cmd/client/rand/main.go:252
↓ 2 callersMethodsetMetadata
(id string, md map[string]string)
internal/nyx/nyx.go:648
↓ 2 callersMethodwriteRecord
writeRecord write data on dist and in memory map
internal/db/store/shard/shard.go:298
↓ 1 callersMethodAccept
Accept awaiting the next incoming connection
internal/network/network.go:35
↓ 1 callersMethodAdd
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:34
↓ 1 callersMethodAddKey
AddKey adds a key to the bucket's index
internal/db/store/bucket.go:26
↓ 1 callersFunctionAllocatePorts
(count int)
internal/dyport/dyport.go:25
↓ 1 callersMethodAppend
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:68
↓ 1 callersMethodBackup
Backup writes a backup of the store data to the provided writer
internal/db/store/store.go:325
↓ 1 callersMethodCanParse
()
internal/proto/proto.go:36
↓ 1 callersMethodClose
Close closes the underlying file
internal/db/store/shard/shard.go:545
↓ 1 callersMethodConfigure
(net.Conn)
internal/server/listen.go:25
↓ 1 callersFunctionConnect
(h *net.TCPAddr)
internal/utils/utils.go:97
↓ 1 callersFunctionCreateLeaderNode
()
e2e/node.go:215
↓ 1 callersMethodDatabase
(leader bool)
internal/nyx/nyx.go:477
↓ 1 callersMethodDelete
(rw *bufio.ReadWriter, key []byte)
cmd/client/textprot/textprot.go:173
↓ 1 callersMethodDial
(addr string, timeout time.Duration)
internal/network/network.go:25
↓ 1 callersMethodEnd
End returns a channel that will receive an OS signal
internal/app/app.go:71
↓ 1 callersMethodExpire
Expire triggers an immediate expiration check on all shards
internal/db/store/store.go:351
↓ 1 callersMethodFileSize
FileSize returns the current size of the shard file
internal/db/store/shard/shard.go:553
↓ 1 callersMethodGAT
(_ *bufio.ReadWriter, _ []byte)
cmd/client/textprot/textprot.go:169
↓ 1 callersMethodGetAddr
()
internal/server/listen.go:26
↓ 1 callersMethodGetMetadata
GetMetadata ... Returns metadata for specific node_id and for a given key
internal/nyx/nyx.go:135
↓ 1 callersMethodGetOpaque
()
internal/common/common.go:127
↓ 1 callersFunctionGetStats
(data []int)
cmd/client/rand/stats.go:24
↓ 1 callersFunctionIdentifyPanic
()
internal/utils/utils.go:74
↓ 1 callersFunctionIsAppError
IsAppError differentiates between protocol-defined errors that are relatively benign and other fatal errors like an IO error because of some socket pr
internal/common/common.go:52
↓ 1 callersMethodIsQuiet
()
internal/common/common.go:128
↓ 1 callersFunctionIsWrongRequest
(err error)
internal/common/common.go:69
↓ 1 callersMethodJoinAllowed
(raftDir string)
internal/nyx/peer.go:34
↓ 1 callersFunctionListenAndServe
(ctx context.Context, l ListenConst, storage nyx.DBHandler)
internal/server/listen.go:84
↓ 1 callersMethodListenForShutdown
ListenForShutdown handles and listens for shutdown
internal/app/app.go:62
↓ 1 callersFunctionLoadConfig
(c *cli.Context)
config/config.go:74
↓ 1 callersFunctionNew
New ... A helper to create a logger based on environment
internal/logging/logging.go:52
↓ 1 callersFunctionNewDevelopment
NewDevelopment ... A logger for development
internal/logging/logging.go:87
↓ 1 callersMethodNewDisambiguator
(p Peeker)
internal/proto/proto.go:40
↓ 1 callersFunctionNewFastCacheApp
(ctx context.Context, cfg *config.Config)
internal/app/app.go:27
↓ 1 callersFunctionNewLocal
NewLocal ... A logger for local development
internal/logging/logging.go:104
↓ 1 callersFunctionNewProduction
NewProduction ... A logger for production
internal/logging/logging.go:70
↓ 1 callersFunctionNewRaftLayer
(ln Listener)
internal/nyx/raft_rpc.go:23
↓ 1 callersFunctionNewRecordHeader
(key, val []byte, expire uint32)
internal/db/store/record_header/record_header.go:39
↓ 1 callersFunctionNewTextParser
(reader *bufio.Reader)
internal/proto/textprot/parser.go:19
↓ 1 callersFunctionNewTextResponder
(writer *bufio.Writer)
internal/proto/textprot/respond.go:15
↓ 1 callersMethodNoop
(req common.NoopRequest)
internal/nyx/nyx.go:111
↓ 1 callersFunctionNumPeers
NumPeers returns the number of peers indicated by the config files within raftDir This code makes assumptions about how the Raft module works
internal/nyx/peer.go:16
↓ 1 callersFunctionPathExists
(path string)
internal/utils/utils.go:105
↓ 1 callersMethodPeek
(n int)
internal/proto/proto.go:32
↓ 1 callersMethodPrepend
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:79
↓ 1 callersMethodQuit
(req common.QuitRequest)
internal/nyx/nyx.go:113
↓ 1 callersMethodReplace
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:51
↓ 1 callersMethodSet
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:17
↓ 1 callersMethodSetMetadata
(md map[string]string)
internal/nyx/nyx.go:644
↓ 1 callersMethodSetResponder
(resp proto.Responder)
internal/nyx/nyx.go:137
↓ 1 callersMethodShutdown
()
internal/nyx/nyx.go:317
↓ 1 callersMethodStart
Start starts the application
internal/app/app.go:50
↓ 1 callersFunctionTCPListener
(addr net.Addr)
internal/server/listen.go:60
↓ 1 callersMethodTouch
(rw *bufio.ReadWriter, key []byte)
cmd/client/textprot/textprot.go:190
↓ 1 callersMethodVersion
(req common.VersionRequest)
internal/nyx/nyx.go:115
↓ 1 callersMethodWaitForApplied
(timeout time.Duration)
internal/nyx/nyx.go:537
↓ 1 callersMethodWaitForAppliedIndex
(idx uint64, timeout time.Duration)
internal/nyx/nyx.go:519
↓ 1 callersMethodWaitForLeader
(timeout time.Duration)
internal/nyx/nyx.go:500
↓ 1 callersFunctionWithExpireInterval
WithExpireInterval sets up a background interval to expire keys.
internal/db/store/store.go:104
↓ 1 callersFunctionavg
(data []int)
cmd/client/rand/stats.go:44
↓ 1 callersFunctioncreateMockConfig
()
internal/server/server_test.go:336
↓ 1 callersFunctionexecute
(conn net.Conn, connWg *sync.WaitGroup, tasks <-chan *Task, metrics chan<- metric)
cmd/client/rand/main.go:189
↓ 1 callersFunctiongenData
(cmd Op)
cmd/client/rand/main.go:244
↓ 1 callersMethodgetRaftConfig
()
internal/nyx/nyx.go:626
↓ 1 callersMethodhandleJoin
()
internal/server/http.go:98
↓ 1 callersFunctionjoin
(joinAddr *url.URL, id string, addr *net.TCPAddr, meta map[string]string)
internal/server/server.go:142
↓ 1 callersFunctionjoinRequest
(nodeAddr, raftID, raftAddr string)
e2e/node.go:121
↓ 1 callersMethodleaderAPIAddr
()
internal/server/http.go:148
↓ 1 callersFunctionnewStringJSONEncoder
(cfg zapcore.EncoderConfig)
internal/logging/logging.go:131
↓ 1 callersFunctionpIdx
(datalen int, p float64)
cmd/client/rand/stats.go:57
↓ 1 callersMethodprocessHeaders
(ver int, offset uint32)
internal/db/store/shard/shard.go:108
↓ 1 callersMethodreadKeyData
(keyLen uint16)
internal/db/store/shard/shard.go:203
↓ 1 callersMethodsameAs
(o *Node)
e2e/node.go:49
↓ 1 callersFunctionsetupHTTPServer
(ctx context.Context, cfg *config.Config, s *nyx.Nyx)
internal/app/app.go:77
↓ 1 callersFunctionsetupStore
(ctx context.Context, cfg *config.Config)
internal/app/app.go:82
↓ 1 callersFunctiontempDir
()
internal/server/server_test.go:328
↓ 1 callersMethodupgradeFileFormat
upgradeFileFormat upgrades the file format from an older version to the current one.
internal/db/store/shard/shard.go:30
MethodAccept
()
internal/nyx/raft_rpc.go:33
MethodAccept
()
internal/server/listen.go:34
MethodAdd
(opaque uint32, quiet bool)
internal/proto/proto.go:15
MethodAdd
(_ uint32, _ bool)
internal/proto/textprot/respond.go:25
MethodAdd
(req common.SetRequest)
internal/nyx/kvs.go:58
MethodAdd
(_ common.SetRequest)
internal/server/server_test.go:96
MethodAdd
(req common.SetRequest)
internal/server/server_test.go:244
MethodAdd
(cmd common.SetRequest)
internal/db/db.go:84
MethodAddr
()
internal/nyx/raft_rpc.go:41
MethodAddr
()
internal/server/http.go:94
MethodAppend
(opaque uint32, quiet bool)
internal/proto/proto.go:17
MethodAppend
(_ uint32, _ bool)
internal/proto/textprot/respond.go:33
MethodAppend
(req common.SetRequest)
internal/nyx/kvs.go:74
MethodAppend
(_ common.SetRequest)
internal/server/server_test.go:104
MethodAppend
(req common.SetRequest)
internal/server/server_test.go:252
MethodAppend
(cmd common.SetRequest)
internal/db/db.go:114
MethodBackup
(name string)
internal/db/db.go:254
MethodBackup
Backup writes the shard's data to the provided writer
internal/db/store/shard/shard.go:497
← previousnext →101–200 of 397, ranked by callers