1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
package shared
import (
"net/rpc"
)
// RPCClient is an implementation of KV that talks over RPC.
type RPCClient struct{ client *rpc.Client }
func (m *RPCClient) Put(key string, value []byte) error {
// We don't expect a response, so we can just use interface{}
var resp interface{}
// The args are just going to be a map. A struct could be better.
return m.client.Call("Plugin.Put", map[string]interface{}{
"key": key,
"value": value,
}, &resp)
}
func (m *RPCClient) Get(key string) ([]byte, error) {
var resp []byte
err := m.client.Call("Plugin.Get", key, &resp)
return resp, err
}
// Here is the RPC server that RPCClient talks to, conforming to
// the requirements of net/rpc
type RPCServer struct {
// This is the real implementation
Impl KV
}
func (m *RPCServer) Put(args map[string]interface{}, resp *interface{}) error {
return m.Impl.Put(args["key"].(string), args["value"].([]byte))
}
func (m *RPCServer) Get(key string, resp *[]byte) error {
v, err := m.Impl.Get(key)
*resp = v
return err
}
|
