MCPcopy Create free account

hub / github.com/DenzelPenzel/shrek / functions

Functions150 in github.com/DenzelPenzel/shrek

MethodDial
(addr raft.ServerAddress, timeout time.Duration)
internal/shrek/raft_rpc.go:28
MethodDial
(addr string, timeout time.Duration)
internal/shrek/shrek_test.go:266
MethodExecute
(r *shrek.ExecuteRequest)
internal/server/server_test.go:269
MethodExecute
(r *ExecuteRequest)
internal/shrek/shrek.go:298
MethodExecute
Execute ... TODO improve logic
internal/db/db.go:181
MethodExecute
(body server.QueryRequest)
e2e/node.go:56
FunctionFindDirectory
(currentDir, target string)
internal/utils/utils.go:23
MethodFollowers
()
e2e/cluster.go:52
MethodGetMetadata
(_, _ string)
internal/server/server_test.go:265
MethodGetMetadata
GetMetadata ... Returns metadata for specific node_id and for a given key
internal/shrek/shrek.go:235
MethodIsDevelopment
IsDevelopment ... Returns true if the env is development
internal/config/config.go:150
MethodIsLocal
IsLocal ... Returns true if the env is local
internal/config/config.go:155
MethodIsProduction
IsProduction ... Returns true if the env is production
internal/config/config.go:145
MethodJoin
(_, _ string, _ map[string]string)
internal/server/server_test.go:298
MethodJoin
(id, addr string, metadata map[string]string)
internal/shrek/shrek.go:377
MethodJoin
(leader *Node)
e2e/node.go:134
MethodLeader
()
internal/server/server_test.go:306
MethodLeader
()
internal/shrek/shrek.go:423
MethodLeaderID
()
internal/server/server_test.go:257
FunctionNew
(fileName string)
internal/db/db.go:42
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:24
FunctionOpenInMemoryWithDSN
(dsn string)
internal/db/db.go:58
FunctionOpenWithDSN
(path, dsn string)
internal/db/db.go:54
MethodPersist
Persist writes the snapshot to the given sink
internal/shrek/fsm.go:30
MethodQuery
(r *shrek.QueryRequest)
internal/server/server_test.go:282
MethodQuery
(r *QueryRequest)
internal/shrek/shrek.go:335
MethodQuery
(queries []string, useTx, includeTimings bool)
internal/db/db.go:78
MethodQuery
(body server.QueryRequest)
e2e/node.go:70
MethodRegisterObserver
(o *raft.Observer)
internal/shrek/shrek.go:673
MethodRelease
()
internal/shrek/fsm.go:65
MethodRemove
(_ string)
internal/server/server_test.go:302
MethodRemove
Remove ... Removes a node from the store
internal/shrek/shrek.go:403
MethodRestore
Restore ... Restores the node to a previous state
internal/shrek/shrek.go:187
FunctionRunApp
RunApp ... Application entry point
cmd/main.go:16
MethodSetTime
()
internal/server/server.go:48
MethodShutdown
Shutdown ... Shutdown each Node in Cluster
e2e/cluster.go:83
MethodSnapshot
()
internal/shrek/shrek.go:167
MethodStats
Stats ... Returns info about the storage
internal/server/server.go:99
MethodStats
()
internal/server/server_test.go:261
MethodStats
()
internal/shrek/shrek.go:428
FunctionTestDatabase
(t *testing.T)
internal/db/db_test.go:11
FunctionTestDyPort
(t *testing.T)
internal/dyport/dyport_test.go:9
FunctionTest_APIStatus
(t *testing.T)
e2e/cluster_test.go:224
FunctionTest_HTTPServer
(t *testing.T)
internal/server/server_test.go:26
FunctionTest_MultiNodes
(t *testing.T)
e2e/cluster_test.go:236
FunctionTest_Network
(t *testing.T)
internal/network/network_test.go:9
FunctionTest_Shrek
(t *testing.T)
internal/shrek/shrek_test.go:17
FunctionTest_SingleNodeCRUD
(t *testing.T)
e2e/cluster_test.go:11
FunctionTest_SingleNodeMutilInsert
(t *testing.T)
e2e/cluster_test.go:145
Functionmain
()
cmd/main.go:58
← previous101–150 of 150, ranked by callers