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
↓ 2 callers
Method
get
(key []byte, hash uint32)
internal/db/store/shard/shard.go:393
↓ 2 callers
Function
listener
(port int)
internal/dyport/dyport.go:68
↓ 2 callers
Function
renderStats
(t string, op Op, data []int)
cmd/client/rand/main.go:252
↓ 2 callers
Method
setMetadata
(id string, md map[string]string)
internal/nyx/nyx.go:648
↓ 2 callers
Method
writeRecord
writeRecord write data on dist and in memory map
internal/db/store/shard/shard.go:298
↓ 1 callers
Method
Accept
Accept awaiting the next incoming connection
internal/network/network.go:35
↓ 1 callers
Method
Add
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:34
↓ 1 callers
Method
AddKey
AddKey adds a key to the bucket's index
internal/db/store/bucket.go:26
↓ 1 callers
Function
AllocatePorts
(count int)
internal/dyport/dyport.go:25
↓ 1 callers
Method
Append
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:68
↓ 1 callers
Method
Backup
Backup writes a backup of the store data to the provided writer
internal/db/store/store.go:325
↓ 1 callers
Method
CanParse
()
internal/proto/proto.go:36
↓ 1 callers
Method
Close
Close closes the underlying file
internal/db/store/shard/shard.go:545
↓ 1 callers
Method
Configure
(net.Conn)
internal/server/listen.go:25
↓ 1 callers
Function
Connect
(h *net.TCPAddr)
internal/utils/utils.go:97
↓ 1 callers
Function
CreateLeaderNode
()
e2e/node.go:215
↓ 1 callers
Method
Database
(leader bool)
internal/nyx/nyx.go:477
↓ 1 callers
Method
Delete
(rw *bufio.ReadWriter, key []byte)
cmd/client/textprot/textprot.go:173
↓ 1 callers
Method
Dial
(addr string, timeout time.Duration)
internal/network/network.go:25
↓ 1 callers
Method
End
End returns a channel that will receive an OS signal
internal/app/app.go:71
↓ 1 callers
Method
Expire
Expire triggers an immediate expiration check on all shards
internal/db/store/store.go:351
↓ 1 callers
Method
FileSize
FileSize returns the current size of the shard file
internal/db/store/shard/shard.go:553
↓ 1 callers
Method
GAT
(_ *bufio.ReadWriter, _ []byte)
cmd/client/textprot/textprot.go:169
↓ 1 callers
Method
GetAddr
()
internal/server/listen.go:26
↓ 1 callers
Method
GetMetadata
GetMetadata ... Returns metadata for specific node_id and for a given key
internal/nyx/nyx.go:135
↓ 1 callers
Method
GetOpaque
()
internal/common/common.go:127
↓ 1 callers
Function
GetStats
(data []int)
cmd/client/rand/stats.go:24
↓ 1 callers
Function
IdentifyPanic
()
internal/utils/utils.go:74
↓ 1 callers
Function
IsAppError
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 callers
Method
IsQuiet
()
internal/common/common.go:128
↓ 1 callers
Function
IsWrongRequest
(err error)
internal/common/common.go:69
↓ 1 callers
Method
JoinAllowed
(raftDir string)
internal/nyx/peer.go:34
↓ 1 callers
Function
ListenAndServe
(ctx context.Context, l ListenConst, storage nyx.DBHandler)
internal/server/listen.go:84
↓ 1 callers
Method
ListenForShutdown
ListenForShutdown handles and listens for shutdown
internal/app/app.go:62
↓ 1 callers
Function
LoadConfig
(c *cli.Context)
config/config.go:74
↓ 1 callers
Function
New
New ... A helper to create a logger based on environment
internal/logging/logging.go:52
↓ 1 callers
Function
NewDevelopment
NewDevelopment ... A logger for development
internal/logging/logging.go:87
↓ 1 callers
Method
NewDisambiguator
(p Peeker)
internal/proto/proto.go:40
↓ 1 callers
Function
NewFastCacheApp
(ctx context.Context, cfg *config.Config)
internal/app/app.go:27
↓ 1 callers
Function
NewLocal
NewLocal ... A logger for local development
internal/logging/logging.go:104
↓ 1 callers
Function
NewProduction
NewProduction ... A logger for production
internal/logging/logging.go:70
↓ 1 callers
Function
NewRaftLayer
(ln Listener)
internal/nyx/raft_rpc.go:23
↓ 1 callers
Function
NewRecordHeader
(key, val []byte, expire uint32)
internal/db/store/record_header/record_header.go:39
↓ 1 callers
Function
NewTextParser
(reader *bufio.Reader)
internal/proto/textprot/parser.go:19
↓ 1 callers
Function
NewTextResponder
(writer *bufio.Writer)
internal/proto/textprot/respond.go:15
↓ 1 callers
Method
Noop
(req common.NoopRequest)
internal/nyx/nyx.go:111
↓ 1 callers
Function
NumPeers
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 callers
Function
PathExists
(path string)
internal/utils/utils.go:105
↓ 1 callers
Method
Peek
(n int)
internal/proto/proto.go:32
↓ 1 callers
Method
Prepend
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:79
↓ 1 callers
Method
Quit
(req common.QuitRequest)
internal/nyx/nyx.go:113
↓ 1 callers
Method
Replace
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:51
↓ 1 callers
Method
Set
(rw *bufio.ReadWriter, key []byte, value []byte)
cmd/client/textprot/textprot.go:17
↓ 1 callers
Method
SetMetadata
(md map[string]string)
internal/nyx/nyx.go:644
↓ 1 callers
Method
SetResponder
(resp proto.Responder)
internal/nyx/nyx.go:137
↓ 1 callers
Method
Shutdown
()
internal/nyx/nyx.go:317
↓ 1 callers
Method
Start
Start starts the application
internal/app/app.go:50
↓ 1 callers
Function
TCPListener
(addr net.Addr)
internal/server/listen.go:60
↓ 1 callers
Method
Touch
(rw *bufio.ReadWriter, key []byte)
cmd/client/textprot/textprot.go:190
↓ 1 callers
Method
Version
(req common.VersionRequest)
internal/nyx/nyx.go:115
↓ 1 callers
Method
WaitForApplied
(timeout time.Duration)
internal/nyx/nyx.go:537
↓ 1 callers
Method
WaitForAppliedIndex
(idx uint64, timeout time.Duration)
internal/nyx/nyx.go:519
↓ 1 callers
Method
WaitForLeader
(timeout time.Duration)
internal/nyx/nyx.go:500
↓ 1 callers
Function
WithExpireInterval
WithExpireInterval sets up a background interval to expire keys.
internal/db/store/store.go:104
↓ 1 callers
Function
avg
(data []int)
cmd/client/rand/stats.go:44
↓ 1 callers
Function
createMockConfig
()
internal/server/server_test.go:336
↓ 1 callers
Function
execute
(conn net.Conn, connWg *sync.WaitGroup, tasks <-chan *Task, metrics chan<- metric)
cmd/client/rand/main.go:189
↓ 1 callers
Function
genData
(cmd Op)
cmd/client/rand/main.go:244
↓ 1 callers
Method
getRaftConfig
()
internal/nyx/nyx.go:626
↓ 1 callers
Method
handleJoin
()
internal/server/http.go:98
↓ 1 callers
Function
join
(joinAddr *url.URL, id string, addr *net.TCPAddr, meta map[string]string)
internal/server/server.go:142
↓ 1 callers
Function
joinRequest
(nodeAddr, raftID, raftAddr string)
e2e/node.go:121
↓ 1 callers
Method
leaderAPIAddr
()
internal/server/http.go:148
↓ 1 callers
Function
newStringJSONEncoder
(cfg zapcore.EncoderConfig)
internal/logging/logging.go:131
↓ 1 callers
Function
pIdx
(datalen int, p float64)
cmd/client/rand/stats.go:57
↓ 1 callers
Method
processHeaders
(ver int, offset uint32)
internal/db/store/shard/shard.go:108
↓ 1 callers
Method
readKeyData
(keyLen uint16)
internal/db/store/shard/shard.go:203
↓ 1 callers
Method
sameAs
(o *Node)
e2e/node.go:49
↓ 1 callers
Function
setupHTTPServer
(ctx context.Context, cfg *config.Config, s *nyx.Nyx)
internal/app/app.go:77
↓ 1 callers
Function
setupStore
(ctx context.Context, cfg *config.Config)
internal/app/app.go:82
↓ 1 callers
Function
tempDir
()
internal/server/server_test.go:328
↓ 1 callers
Method
upgradeFileFormat
upgradeFileFormat upgrades the file format from an older version to the current one.
internal/db/store/shard/shard.go:30
Method
Accept
()
internal/nyx/raft_rpc.go:33
Method
Accept
()
internal/server/listen.go:34
Method
Add
(opaque uint32, quiet bool)
internal/proto/proto.go:15
Method
Add
(_ uint32, _ bool)
internal/proto/textprot/respond.go:25
Method
Add
(req common.SetRequest)
internal/nyx/kvs.go:58
Method
Add
(_ common.SetRequest)
internal/server/server_test.go:96
Method
Add
(req common.SetRequest)
internal/server/server_test.go:244
Method
Add
(cmd common.SetRequest)
internal/db/db.go:84
Method
Addr
()
internal/nyx/raft_rpc.go:41
Method
Addr
()
internal/server/http.go:94
Method
Append
(opaque uint32, quiet bool)
internal/proto/proto.go:17
Method
Append
(_ uint32, _ bool)
internal/proto/textprot/respond.go:33
Method
Append
(req common.SetRequest)
internal/nyx/kvs.go:74
Method
Append
(_ common.SetRequest)
internal/server/server_test.go:104
Method
Append
(req common.SetRequest)
internal/server/server_test.go:252
Method
Append
(cmd common.SetRequest)
internal/db/db.go:114
Method
Backup
(name string)
internal/db/db.go:254
Method
Backup
Backup writes the shard's data to the provided writer
internal/db/store/shard/shard.go:497
← previous
next →
101–200 of 397, ranked by callers