MCPcopy Create free account

hub / github.com/cpuguy83/drax / functions

Functions162 in github.com/cpuguy83/drax

⨍ Functions 162◇ Types & classes 31
↓ 24 callersMethodPut
(key string, value []byte, options *libkvstore.WriteOptions)
store.go:104
↓ 19 callersMethodEncode
(interface{})
api/util.go:15
↓ 15 callersMethodKVStore
KVStore provides access to the underlying KV store
cluster.go:142
↓ 14 callersMethodGet
(key string)
store.go:87
↓ 13 callersFunctionnewStore
()
store.go:83
↓ 12 callersMethodIsLeader
()
store.go:31
↓ 11 callersMethodnewClient
()
store.go:78
↓ 9 callersMethodDecode
(interface{})
api/util.go:10
↓ 8 callersMethoddo
(req *api.Request)
api/client/rpc.go:23
↓ 8 callersFunctionsetError
(res *api.Response, err error)
api.go:287
↓ 6 callersMethodAddr
Addr cluster is available on
cluster.go:189
↓ 6 callersMethodClose
()
store.go:304
↓ 6 callersMethodapply
(ax *api.Request)
store.go:308
↓ 5 callersMethodClose
Close shuts down the stream layer
rpc/stream.go:100
↓ 5 callersMethodWatch
(key string, stopCh <-chan struct{})
store.go:181
↓ 5 callersFunctionkvToLibKV
(kv *api.KVPair)
api/client/rpc.go:55
↓ 5 callersFunctionlibkvToKV
(kv *libkvstore.KVPair)
api.go:265
↓ 4 callersMethodAccept
Accept waits for and returns the next connection
rpc/stream.go:54
↓ 4 callersMethodAddr
Addr returns the address the stremLayer is listening on This is used to satisfy the net.Listener interface
rpc/stream.go:116
↓ 4 callersMethodDelete
(key string)
store.go:122
↓ 4 callersMethodDialWithRetry
DialWithRetry is like `Dial` but uses a retry mechanism
rpc/stream.go:69
↓ 4 callersMethodPeers
Peers returns the currnet list of raft peers
raft.go:134
↓ 4 callersMethodShutdown
Shutdown stops the local cluster node
cluster.go:127
↓ 4 callersMethodget
(key string)
store.go:96
↓ 3 callersMethodApply
([]byte)
store.go:35
↓ 3 callersMethodClose
Close shutsdown the raft for the local node
raft.go:83
↓ 3 callersMethodClose
Close closes the underlying stream layer
api/client/client.go:242
↓ 3 callersMethodDeleteTree
(dir string)
store.go:169
↓ 3 callersMethodLeader
Leader returns the current leader
raft.go:154
↓ 3 callersMethodLeaderCh
()
store.go:32
↓ 3 callersMethodList
(prefix string)
store.go:145
↓ 3 callersMethodPublish
(kv *libkvstore.KVPair)
store.go:540
↓ 3 callersMethodShutdownCh
()
store.go:34
↓ 3 callersFunctioncleanupNodes
(nodes []*Cluster)
cluster_test.go:123
↓ 3 callersFunctioncleanupNodes
(nodes []*drax.Cluster)
integration/utils.go:47
↓ 3 callersFunctionnewTestCluster
(size int, prefixAddr string)
cluster_test.go:93
↓ 3 callersFunctionnewTestCluster
(size int, prefixAddr string)
integration/utils.go:17
↓ 2 callersMethodExists
(key string)
store.go:135
↓ 2 callersMethodGetLeader
()
store.go:33
↓ 2 callersMethodRPC
RPC is a helper function for performing RPC requests between nodes
rpc/stream.go:121
↓ 2 callersMethodSubscribe
()
store.go:493
↓ 2 callersMethodSubscribe
()
store.go:532
↓ 2 callersMethodWatchTree
(dir string, stopCh <-chan struct{})
store.go:206
↓ 2 callersMethodcloseWatches
(key string)
store.go:469
↓ 2 callersMethoddial
()
api/client/rpc.go:19
↓ 2 callersFunctionkvToLibKV
(kv *api.KVPair)
api.go:276
↓ 2 callersFunctionlibkvToKV
(kv *store.KVPair)
api/client/rpc.go:63
↓ 2 callersFunctionnewDB
()
store.go:74
↓ 2 callersFunctionnewPeerStore
(home string, transport raft.Transport)
discovery.go:20
↓ 2 callersFunctionnewTestHandler
(addr net.Addr, msgType byte)
rpc/server_test.go:60
↓ 2 callersMethodstream
(req *api.Request)
api/client/rpc.go:44
↓ 2 callersFunctionwaitClose
(conn io.Reader, chStop chan struct{})
api.go:101
↓ 2 callersMethodwaitLeader
()
raft.go:158
↓ 2 callersMethodwaitLeader
()
cluster.go:156
↓ 1 callersMethodAddPeer
AddPeer adds the given peer to the raft cluster
raft.go:124
↓ 1 callersFunctionDecode
Decode should be used to decode anything sent to or use by the cluster
api/util.go:24
↓ 1 callersMethodDial
Dial is used by Raft for RPC
rpc/stream.go:64
↓ 1 callersFunctionEncode
Encode should be used to encode anything sent to or use by the cluster
api/util.go:19
↓ 1 callersMethodErrors
Errors returns a channel receiver that callers can use to listen for cluster errors
cluster.go:152
↓ 1 callersMethodEvict
(s chan []*libkvstore.KVPair)
store.go:525
↓ 1 callersMethodEvict
(s chan *libkvstore.KVPair)
store.go:564
↓ 1 callersMethodHandoff
(net.Conn)
rpc/server.go:8
↓ 1 callersMethodHome
Home is the home path where the cluster state is stored
cluster.go:194
↓ 1 callersMethodIsLeader
IsLeader returns whether this node is the raft leader
raft.go:119
↓ 1 callersFunctionNew
New creates a new Cluster and starts it
cluster.go:40
↓ 1 callersFunctionNewServer
NewServer creates a new RPC server
rpc/server.go:30
↓ 1 callersFunctionNewStreamLayer
NewStreamLayer creates a new StreamLayer `addr` is used so this can implement the net.Listener interface `rpcType` is the type of Message this StreamL
rpc/stream.go:38
↓ 1 callersMethodProxyRequest
ProxyRequest is a helper function to proxy an rpc request to another node
rpc/stream.go:138
↓ 1 callersMethodRemovePeer
RemovePeer removes the given peer from the raft cluster
raft.go:129
↓ 1 callersMethodSetPeers
SetPeers sets the list of raft peers
raft.go:139
↓ 1 callersFunctionabort
(start time.Time, timeOff, max time.Duration)
rpc/stream.go:176
↓ 1 callersFunctionbackoff
(retries int)
rpc/stream.go:164
↓ 1 callersMethodcheckTreeWatches
(key string, kv []*libkvstore.KVPair)
store.go:457
↓ 1 callersMethodcheckWatches
(key string, kv *libkvstore.KVPair)
store.go:443
↓ 1 callersFunctiongetErr
(e *errcode.Error)
api/client/rpc.go:74
↓ 1 callersMethodhandleConn
(conn net.Conn)
api.go:49
↓ 1 callersMethodhandleConn
(conn net.Conn)
api.go:224
↓ 1 callersMethodhandleConn
(conn net.Conn)
rpc/server.go:47
↓ 1 callersMethodhandleConns
()
api.go:35
↓ 1 callersMethodhandleConns
()
api.go:205
↓ 1 callersMethodhandleConns
()
rpc/server_test.go:19
↓ 1 callersMethodhandleLeader
(leaderCh <-chan interface{})
store.go:337
↓ 1 callersMethodhandleLeader
(leaderCh <-chan interface{})
cluster.go:171
↓ 1 callersMethodlisten
listen tells the RPC server to start handling incoming connections
rpc/server.go:37
↓ 1 callersFunctionnewRaft
(home, addr string, peerStore *peerStoreWrapper, fsm raft.FSM, trans *raft.NetworkTransport, cfg *raft.Config)
raft.go:34
↓ 1 callersMethodreapKeys
(keys []string)
store.go:365
↓ 1 callersMethodstart
()
cluster.go:58
↓ 1 callersFunctionttlDue
(t *ttl)
store.go:374
MethodApply
Apply applies the bytes to the raft log If this is not the leader node, the request is sent to the leader
raft.go:95
MethodApply
(l *raft.Log)
store.go:381
MethodApply
(b []byte)
store_test.go:35
MethodAtomicDelete
(conn io.Writer, req *clientRequest)
api.go:195
MethodAtomicDelete
(key string, previous *libkvstore.KVPair)
store.go:275
MethodAtomicDelete
AtomicDelete is like `Delete`, but makes sure the key is not changed while performing the action.
api/client/client.go:227
MethodAtomicPut
(conn io.Writer, req *clientRequest)
api.go:183
MethodAtomicPut
(key string, value []byte, previous *libkvstore.KVPair, options *libkvstore.WriteOptions)
store.go:238
MethodAtomicPut
AtomicPut is like `Put`, but ensures there are no changes to the key while the action is performed If the key is changed, this returns an error and do
api/client/client.go:208
FunctionBenchmarkDecode
(b *testing.B)
api/api_test.go:24
FunctionBenchmarkEncode
(b *testing.B)
api/api_test.go:9
MethodClose
()
store.go:571
next →1–100 of 162, ranked by callers