MCPcopy Create free account

hub / github.com/YuriyNasretdinov/distribkv / functions

Functions43 in github.com/YuriyNasretdinov/distribkv

⨍ Functions 43◇ Types & classes 7
↓ 5 callersMethodGetKey
GetKey get the value of the requested from a default database.
db/db.go:122
↓ 4 callersMethodSetKey
SetKey sets the key to the requested value into the default database or returns an error.
db/db.go:51
↓ 4 callersFunctioncreateTempDb
(t *testing.T, readOnly bool)
db/db_test.go:12
↓ 3 callersMethodGetNextKeyForReplication
GetNextKeyForReplication returns the key and value for the keys that have changed and have not yet been applied to replicas. If there are no new keys,
db/db.go:86
↓ 3 callersMethodIndex
Index returns the shard number for the corresponding key.
config/config.go:78
↓ 3 callersFunctioncopyByteSlice
(b []byte)
db/db.go:74
↓ 3 callersFunctionsetKey
(t *testing.T, d *db.Database, key, value string)
db/db_test.go:98
↓ 2 callersMethodDeleteExtraKeys
DeleteExtraKeys deletes the keys that do not belong to this shard.
db/db.go:137
↓ 2 callersMethodDeleteReplicationKey
DeleteReplicationKey deletes the key from the replication queue if the value matches the contents or if the key is already absent.
db/db.go:104
↓ 2 callersFunctionbenchmark
(name string, iter int, fn func() string)
cmd/bench/main.go:32
↓ 2 callersFunctionbenchmarkWrite
()
cmd/bench/main.go:91
↓ 2 callersFunctioncreateConfig
(t *testing.T, contents string)
config/config_test.go:12
↓ 2 callersFunctioncreateShardServer
(t *testing.T, idx int, addrs map[int]string)
web/web_test.go:42
↓ 2 callersFunctiongetKey
(t *testing.T, d *db.Database, key string)
db/db_test.go:106
↓ 2 callersMethodredirect
(shard int, w http.ResponseWriter, r *http.Request)
web/web.go:28
↓ 1 callersMethodSetKeyOnReplica
SetKeyOnReplica sets the key to the requested value into the default database and does not write to the replication queue. This method is intended to
db/db.go:68
↓ 1 callersFunctionbenchmarkRead
(allKeys []string)
cmd/bench/main.go:116
↓ 1 callersMethodcreateBuckets
()
db/db.go:38
↓ 1 callersFunctioncreateShardDb
(t *testing.T, idx int)
web/web_test.go:20
↓ 1 callersMethoddeleteFromReplicationQueue
(key, value string)
replication/replication.go:76
↓ 1 callersMethodloop
()
replication/replication.go:45
↓ 1 callersFunctionparseFlags
()
main.go:22
↓ 1 callersFunctionreadRand
(allKeys []string)
cmd/bench/main.go:75
FunctionClientLoop
ClientLoop continuously downloads new keys from the master and applies them.
replication/replication.go:29
MethodDeleteExtraKeysHandler
DeleteExtraKeysHandler deletes keys that don't belong to the current shard.
web/web.go:77
MethodDeleteReplicationKey
DeleteReplicationKey deletes the key from replica queue.
web/web.go:95
MethodGetHandler
GetHandler handles read requests from the database.
web/web.go:44
MethodGetNextKeyForReplication
GetNextKeyForReplication returns the next key for replication.
web/web.go:84
FunctionNewDatabase
NewDatabase returns an instance of a database that we can work with.
db/db.go:21
FunctionNewServer
NewServer creates a new instance with HTTP handlers to be used to get and set values.
web/web.go:21
FunctionParseFile
ParseFile parses the config and returns it upon success.
config/config.go:24
FunctionParseShards
ParseShards converts and verifies the list of shards specified in the config into a form that can be used for routing.
config/config.go:44
MethodSetHandler
SetHandler handles write requests from the database.
web/web.go:61
FunctionTestConfigParse
(t *testing.T)
config/config_test.go:37
FunctionTestDeleteExtraKeys
(t *testing.T)
db/db_test.go:117
FunctionTestDeleteReplicationKey
(t *testing.T)
db/db_test.go:58
FunctionTestGetSet
(t *testing.T)
db/db_test.go:32
FunctionTestParseShards
(t *testing.T)
config/config_test.go:58
FunctionTestSetReadOnly
(t *testing.T)
db/db_test.go:90
FunctionTestWebServer
(t *testing.T)
web/web_test.go:57
Functionmain
()
main.go:34
Functionmain
()
cmd/bench/main.go:138
FunctionwriteRand
()
cmd/bench/main.go:56