MCPcopy Create free account

hub / github.com/DenzelPenzel/shrek / functions

Functions150 in github.com/DenzelPenzel/shrek

⨍ Functions 150◇ Types & classes 39
↓ 32 callersMethodRun
()
internal/server/server.go:117
↓ 27 callersMethodExecute
(r *shrek.ExecuteRequest)
internal/server/server.go:84
↓ 19 callersMethodClose
()
internal/shrek/raft_rpc.go:36
↓ 16 callersMethodClose
()
internal/db/db.go:74
↓ 16 callersMethodJoin
Join ... Connects the node, identified by the provided ID and reachable at the specified address, to the current node
internal/server/server.go:90
↓ 14 callersMethodQuery
(query string, args []driver.Value)
internal/db/db.go:15
↓ 10 callersFunctionGetTCPAddr
(addr string)
internal/utils/utils.go:51
↓ 10 callersMethodOpen
(allowSingle bool)
internal/shrek/shrek.go:504
↓ 10 callersMethodShutdown
()
e2e/node.go:34
↓ 10 callersFunctionWithContext
WithContext ... Pass in a context containing values to add to each log message
internal/logging/logging.go:29
↓ 8 callersMethodRemove
Remove ... Remove node from the cluster
internal/server/server.go:93
↓ 8 callersMethodWaitForLeader
(timeout time.Duration)
internal/shrek/shrek.go:681
↓ 7 callersFunctionJoin
Join ... Sequentially processes joinAddr, updating node ID (id) and Raft address (addr) for each joining node. It returns the successfully used endpoi
internal/server/server.go:193
↓ 7 callersMethodPath
Path ... Returns the path to the store's storage directory
internal/shrek/shrek.go:744
↓ 7 callersMethodQuery
(r *shrek.QueryRequest)
internal/server/server.go:86
↓ 7 callersMethodShutdown
()
internal/shrek/shrek.go:646
↓ 7 callersFunctioncreateMockStore
()
internal/shrek/shrek_test.go:292
↓ 6 callersFunctionNew
(ctx context.Context, cfg *config.ServerConfig, s Storage)
internal/server/server.go:105
↓ 5 callersFunctionNewNetwork
()
internal/network/network.go:12
↓ 5 callersFunctionRandomString
(n int)
internal/utils/utils.go:38
↓ 5 callersMethodShutDown
()
internal/server/server.go:169
↓ 5 callersMethodWaitForLeader
()
e2e/node.go:52
↓ 5 callersFunctionopenDB
(t *testing.T)
internal/db/db_test.go:182
↓ 4 callersFunctionCreateLeaderNode
()
e2e/node.go:242
↓ 4 callersFunctionOpen
(path string)
internal/db/db.go:50
↓ 4 callersMethodOpen
(addr string)
internal/network/network.go:16
↓ 4 callersFunctioncreateMockConfig
()
internal/server/server_test.go:318
↓ 3 callersMethodAddr
()
internal/server/server.go:174
↓ 3 callersMethodAddr
Addr ... Returns the address of the store
internal/shrek/shrek.go:735
↓ 3 callersMethodApply
Apply ... Applies a Raft log entry to the database
internal/shrek/shrek.go:104
↓ 3 callersFunctionCreateNewNode
(enableSingle bool)
e2e/node.go:171
↓ 3 callersMethodID
ID ... Returns the raft ID
internal/shrek/shrek.go:730
↓ 3 callersMethodLeader
()
e2e/cluster.go:22
↓ 3 callersMethodLeaderAddr
()
internal/shrek/shrek.go:739
↓ 3 callersMethodLeaderID
LeaderID ... Returns the raft leader
internal/server/server.go:96
↓ 3 callersFunctionNew
New ... Initializer
internal/shrek/shrek.go:484
↓ 3 callersFunctionformatDSNWithFilePath
formatDSNWithFilePath ... Format file path with data source name
internal/db/db.go:325
↓ 3 callersFunctionopen
(path string)
internal/db/db.go:62
↓ 2 callersMethodAddr
()
internal/network/network.go:48
↓ 2 callersFunctionAllocatePorts
(count int)
internal/dyport/dyport.go:25
↓ 2 callersMethodBackup
Backup ... consistent database snapshot
internal/db/db.go:160
↓ 2 callersMethodClose
()
internal/network/network.go:44
↓ 2 callersMethodDial
Dial - makes outgoing connections to other servers in the Raft cluster When we connect to a server, we write the RaftRPC byte to identify the connecti
internal/shrek/raft_rpc.go:15
↓ 2 callersFunctionNewResponse
()
internal/server/server.go:52
↓ 2 callersFunctionNoContext
NoContext ... A log helper to log when there's no context. Rare case usage
internal/logging/logging.go:42
↓ 2 callersMethodStats
()
internal/server/server.go:80
↓ 2 callersFunctionTempDir
(name string)
internal/utils/utils.go:59
↓ 2 callersMethodfindNode
(addr string)
e2e/cluster.go:13
↓ 2 callersMethodgetAPIURL
(suffix string)
e2e/node.go:105
↓ 2 callersMethodleaderID
()
internal/server/server.go:297
↓ 2 callersFunctionlistener
(port int)
internal/dyport/dyport.go:68
↓ 2 callersMethodpostRequest
(u *url.URL, j string)
e2e/node.go:114
↓ 2 callersMethodsetMetadata
(id string, md map[string]string)
internal/shrek/shrek.go:253
↓ 1 callersMethodAccept
Accept ... Awaiting the next incoming connection
internal/network/network.go:36
↓ 1 callersMethodAddr
()
internal/shrek/shrek_test.go:278
↓ 1 callersMethodDatabase
(leader bool)
internal/shrek/shrek.go:143
↓ 1 callersMethodDial
Dial ... Establishes a network connection
internal/network/network.go:26
↓ 1 callersMethodEnd
End ... Returns a channel that will receive an OS signal
internal/app/app.go:149
↓ 1 callersMethodExec
(query string, args []driver.Value)
internal/db/db.go:19
↓ 1 callersMethodGetMetadata
GetMetadata ... Returns metadata for specific node_id and for a given key
internal/server/server.go:102
↓ 1 callersMethodJoinAllowed
JoinAllowed ... Returns whether the config files within raftDir indicate that the node can join a cluster
internal/shrek/peers.go:36
↓ 1 callersMethodLeaderID
LeaderID ... Returns leader ID
internal/shrek/shrek.go:627
↓ 1 callersMethodListenForShutdown
ListenForShutdown ... Handles and listens for shutdown
internal/app/app.go:140
↓ 1 callersFunctionNew
New ... A helper to create a logger based on environment
internal/logging/logging.go:47
↓ 1 callersFunctionNew
New ... Initializer
internal/app/app.go:25
↓ 1 callersFunctionNewApp
(ctx context.Context, cfg *config.Config)
internal/app/app.go:125
↓ 1 callersFunctionNewConfig
NewConfig ... Initializer
internal/config/config.go:73
↓ 1 callersFunctionNewLocal
()
internal/logging/logging.go:60
↓ 1 callersFunctionNewRaftLayer
(ln Listener)
internal/shrek/raft_rpc.go:22
↓ 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/shrek/peers.go:16
↓ 1 callersFunctionPathExists
(path string)
internal/utils/utils.go:11
↓ 1 callersMethodRemoveNode
(n *Node)
e2e/cluster.go:72
↓ 1 callersMethodSetMetadata
(md map[string]string)
internal/shrek/shrek.go:249
↓ 1 callersMethodStatus
()
e2e/node.go:82
↓ 1 callersMethodWaitForApplied
(timeout time.Duration)
internal/shrek/shrek.go:718
↓ 1 callersMethodWaitForAppliedIndex
(idx uint64, timeout time.Duration)
internal/shrek/shrek.go:700
↓ 1 callersMethodWaitForNewLeader
(oldLeader *Node)
e2e/cluster.go:30
↓ 1 callersFunctioncopyDatabase
(source *sqlite3.SQLiteConn, target *sqlite3.SQLiteConn)
internal/db/db.go:270
↓ 1 callersFunctioncreateMockLister
(addr string)
internal/shrek/shrek_test.go:282
↓ 1 callersMethodgetRaftConfig
getRaftConfig ... Return raft config file
internal/shrek/shrek.go:749
↓ 1 callersMethodhandleExecute
()
internal/server/handlers.go:14
↓ 1 callersMethodhandleJoin
()
internal/server/handlers.go:134
↓ 1 callersMethodhandleQuery
()
internal/server/handlers.go:53
↓ 1 callersMethodhandleRemove
()
internal/server/handlers.go:128
↓ 1 callersMethodhandleStats
()
internal/server/handlers.go:93
↓ 1 callersFunctionisTextType
isTextType returns whether the given type has a SQLite text affinity. http://www.sqlite.org/datatype3.html
internal/db/db.go:313
↓ 1 callersFunctionjoin
(joinAddr *url.URL, id string, addr *net.TCPAddr, meta map[string]string)
internal/server/server.go:224
↓ 1 callersFunctionjoinRequest
(nodeAddr, raftID, raftAddr string)
e2e/node.go:146
↓ 1 callersMethodleaderAPIAddr
()
internal/server/server.go:289
↓ 1 callersFunctionnormalizeRowValues
(row []driver.Value, types []string)
internal/db/db.go:294
↓ 1 callersMethodopenDB
()
internal/shrek/shrek.go:603
↓ 1 callersMethodsameAs
(o *Node)
e2e/node.go:48
↓ 1 callersFunctionsetupHTTPServer
(ctx context.Context, cfg *config.Config, s *shrek.Shrek)
internal/app/app.go:120
↓ 1 callersFunctionsetupStore
(ctx context.Context, cfg *config.Config)
internal/app/app.go:33
↓ 1 callersFunctiontempDir
()
internal/server/server_test.go:310
MethodAccept
()
internal/shrek/raft_rpc.go:32
MethodAccept
()
internal/shrek/shrek_test.go:270
MethodAddr
()
internal/shrek/raft_rpc.go:40
MethodClose
()
internal/shrek/shrek_test.go:274
MethodDeregisterObserver
(o *raft.Observer)
internal/shrek/shrek.go:677
next →1–100 of 150, ranked by callers