Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cpuguy83/drax
/ types & classes
Types & classes
31 in github.com/cpuguy83/drax
⨍
Functions
162
◇
Types & classes
31
Struct
Client
Client is used to facilitate communications with a drax cluster
api/client/client.go:16
TypeAlias
ClientAction
ClientAction is used to route client requests to the appropriate handler
api/api.go:13
Struct
Cluster
Cluster is used to manage all the cluster state for a given node
cluster.go:25
Interface
Decoder
Decoder performs stream decoding of the given value
api/util.go:9
FuncType
DialerFn
DialerFn is the function the StreamLayer should use to Dial out to another node
rpc/stream.go:21
Interface
Encoder
Encoder performs stream encoding of the given value
api/util.go:14
Interface
Handler
Handler is an interface for implementing the backends used by RPC Server
rpc/server.go:6
Struct
KVPair
KVPair stores the key,value data for use in the Request/Response
api/api.go:48
TypeAlias
MessageType
MessageType is used for routing connections to the appropriate handler
api/api.go:10
Struct
Raft
Raft wraps the underlying raft.Raft with some extra helpers to expose to other, non-raft components
raft.go:16
Struct
Request
Request is used by kv clients when making requests
api/api.go:38
Struct
Request
Request is the structure used for making RPC requests
rpc/server.go:19
Struct
Response
Response is the response sent to client requests
api/api.go:55
Struct
Response
Response is what's returned from RPC requests
rpc/server.go:25
Struct
Server
Server handles routing from an an incoming conneciton to a specified backend. These backends are determined based on the 1st byte read from the incomi
rpc/server.go:13
Struct
StreamLayer
StreamLayer is used for handling rpc requests between nodes (be it raft, or other custom RPC) When a request comes into an RPC Server, the Server will
rpc/stream.go:26
Struct
clientRPC
clientRPC handles communications with k/v store clients
api.go:22
FuncType
clientRPCHandlerFn
func(io.Writer, *clientRequest)
api.go:218
Struct
clientRequest
api.go:219
Struct
db
store.go:69
Struct
nodeRPC
nodeRPC handles communcations for node-level actions(e.g., addNode, removeNode)
api.go:16
Struct
peerStoreWrapper
discovery.go:5
Interface
raftCluster
store.go:30
FuncType
rpcHandlerFunc
func(request *rpc.Request) error
rpc.go:17
Struct
store
store.go:38
TypeAlias
storeFSM
store.go:379
Struct
testHandler
rpc/server_test.go:14
Struct
testRaft
store_test.go:11
Struct
treeWatch
store.go:56
Struct
ttl
store.go:63
Struct
watch
store.go:49