Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cpuguy83/drax
/ functions
Functions
162 in github.com/cpuguy83/drax
⨍
Functions
162
◇
Types & classes
31
Method
Close
()
store.go:581
Method
Delete
(conn io.Writer, req *clientRequest)
api.go:165
Method
Delete
Delete deletes the key
api/client/client.go:59
Method
DeleteTree
(conn io.Writer, req *clientRequest)
api.go:157
Method
DeleteTree
DeleteTree deletes the specified dir and all subdirs
api/client/client.go:107
Method
Exists
(conn io.Writer, req *clientRequest)
api.go:173
Method
Exists
Exists checks for the existence of a key
api/client/client.go:70
Method
Get
(conn io.Writer, req *clientRequest)
api.go:80
Method
Get
Get gets the k/v pair for the specified key
api/client/client.go:29
Method
GetLeader
GetLeader loops, waiting for the leader
raft.go:66
Method
GetLeader
()
store_test.go:27
Method
Handoff
Handoff is used by the RPC server hand-off a conn to this StreamLayer
rpc/stream.go:49
Method
IsLeader
()
store_test.go:17
Method
LeaderCh
LeaderCh can be watched for changes in raft node state
raft.go:144
Method
LeaderCh
()
store_test.go:19
Method
List
(conn io.Writer, req *clientRequest)
api.go:142
Method
List
List lists the key/value pairs that have the provided key prefix
api/client/client.go:84
Function
New
New creates a new drax Client
api/client/client.go:23
Function
NewDecoder
NewDecoder returns a Decoder for performing stream decoding from the given reader
api/util.go:29
Function
NewEncoder
NewEncoder returns an Encoder for performing stream encoding from the given reader
api/util.go:34
Method
NewLock
(key string, options *libkvstore.LockOptions)
store.go:231
Method
NewLock
NewLock creates a new lock that can be used to lock access to the given key, like a sync.Mutex
api/client/client.go:202
Method
Peers
()
discovery.go:16
Method
Persist
(sink raft.SnapshotSink)
store.go:434
Method
Publish
(kv []*libkvstore.KVPair)
store.go:501
Method
Put
(conn io.Writer, req *clientRequest)
api.go:92
Method
Put
Put sets the key to the given value
api/client/client.go:44
Method
Release
()
store.go:441
Method
Restore
(r io.ReadCloser)
store.go:428
Method
SetPeers
(peers []string)
discovery.go:9
Method
ShutdownCh
ShutdownCh can be watched to determine if the raft has been shutdown
raft.go:149
Method
ShutdownCh
()
store_test.go:31
Method
ShutdownCh
ShutdownCh returns a channel that can be watched to determine if the cluster has been shut down
cluster.go:147
Method
Snapshot
()
store.go:424
Function
TestKVMultiNode
(t *testing.T)
cluster_test.go:61
Function
TestKVSingleNode
(t *testing.T)
cluster_test.go:41
Function
TestNewCluster
(t *testing.T)
cluster_test.go:17
Function
TestServer
(t *testing.T)
rpc/server_test.go:29
Function
TestSetPeers
(t *testing.T)
discovery_test.go:11
Function
TestStoreDelete
(t *testing.T)
store_test.go:120
Function
TestStoreDeleteTree
(t *testing.T)
store_test.go:198
Function
TestStoreExists
(t *testing.T)
store_test.go:141
Function
TestStoreGet
(t *testing.T)
store_test.go:49
Function
TestStoreGetPutDelete
(t *testing.T)
integration/store_test.go:12
Function
TestStoreList
(t *testing.T)
store_test.go:168
Function
TestStorePut
(t *testing.T)
store_test.go:73
Function
TestStorePutWithTTL
(t *testing.T)
store_test.go:92
Function
TestStoreWatch
(t *testing.T)
integration/store_test.go:81
Function
TestStoreWatchDelete
(t *testing.T)
integration/store_test.go:144
Function
TestStoreWatchKey
(t *testing.T)
store_test.go:223
Function
TestStoreWatchKeyCloseOnDelete
(t *testing.T)
store_test.go:292
Function
TestStoreWatchKeyStop
(t *testing.T)
store_test.go:250
Function
TestStoreWatchTree
(t *testing.T)
store_test.go:332
Function
TestStoreWatchTreeStop
(t *testing.T)
store_test.go:373
Method
Watch
(conn io.Writer, req *clientRequest)
api.go:113
Method
Watch
Watch watches a key for changes and notifies the caller Watch is not implemented
api/client/client.go:119
Method
WatchTree
(conn io.Writer, req *clientRequest)
api.go:125
Method
WatchTree
WatchTree watches a dir and all subdirs for changes and notifies the caller
api/client/client.go:159
Method
addNode
(req *rpc.Request)
api.go:27
Function
main
()
cmd/kv.go:22
Method
removeNode
(req *rpc.Request)
api.go:31
Method
waitLeader
()
store.go:316
← previous
101–162 of 162, ranked by callers