MCPcopy Create free account

hub / github.com/cpuguy83/drax / types & classes

Types & classes31 in github.com/cpuguy83/drax

StructClient
Client is used to facilitate communications with a drax cluster
api/client/client.go:16
TypeAliasClientAction
ClientAction is used to route client requests to the appropriate handler
api/api.go:13
StructCluster
Cluster is used to manage all the cluster state for a given node
cluster.go:25
InterfaceDecoder
Decoder performs stream decoding of the given value
api/util.go:9
FuncTypeDialerFn
DialerFn is the function the StreamLayer should use to Dial out to another node
rpc/stream.go:21
InterfaceEncoder
Encoder performs stream encoding of the given value
api/util.go:14
InterfaceHandler
Handler is an interface for implementing the backends used by RPC Server
rpc/server.go:6
StructKVPair
KVPair stores the key,value data for use in the Request/Response
api/api.go:48
TypeAliasMessageType
MessageType is used for routing connections to the appropriate handler
api/api.go:10
StructRaft
Raft wraps the underlying raft.Raft with some extra helpers to expose to other, non-raft components
raft.go:16
StructRequest
Request is used by kv clients when making requests
api/api.go:38
StructRequest
Request is the structure used for making RPC requests
rpc/server.go:19
StructResponse
Response is the response sent to client requests
api/api.go:55
StructResponse
Response is what's returned from RPC requests
rpc/server.go:25
StructServer
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
StructStreamLayer
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
StructclientRPC
clientRPC handles communications with k/v store clients
api.go:22
FuncTypeclientRPCHandlerFn
func(io.Writer, *clientRequest)
api.go:218
StructclientRequest
api.go:219
Structdb
store.go:69
StructnodeRPC
nodeRPC handles communcations for node-level actions(e.g., addNode, removeNode)
api.go:16
StructpeerStoreWrapper
discovery.go:5
InterfaceraftCluster
store.go:30
FuncTyperpcHandlerFunc
func(request *rpc.Request) error
rpc.go:17
Structstore
store.go:38
TypeAliasstoreFSM
store.go:379
StructtestHandler
rpc/server_test.go:14
StructtestRaft
store_test.go:11
StructtreeWatch
store.go:56
Structttl
store.go:63
Structwatch
store.go:49