Versions in this module Expand all Collapse all v1 v1.2.5 Feb 2, 2022 v1.2.4 May 26, 2020 v1.2.3 May 17, 2020 Changes in this version + var Handshake = plugin.HandshakeConfig + var PluginMap = map[string]plugin.Plugin + type GRPCClient struct + func (m *GRPCClient) Get(key string) ([]byte, error) + func (m *GRPCClient) Put(key string, value []byte) error + type GRPCServer struct + Impl KV + func (m *GRPCServer) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error) + func (m *GRPCServer) Put(ctx context.Context, req *proto.PutRequest) (*proto.Empty, error) + type KV interface + Get func(key string) ([]byte, error) + Put func(key string, value []byte) error + type KVGRPCPlugin struct + Impl KV + func (p *KVGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p *KVGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error + type KVPlugin struct + Impl KV + func (*KVPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error) + func (p *KVPlugin) Server(*plugin.MuxBroker) (interface{}, error) + type RPCClient struct + func (m *RPCClient) Get(key string) ([]byte, error) + func (m *RPCClient) Put(key string, value []byte) error + type RPCServer struct + Impl KV + func (m *RPCServer) Get(key string, resp *[]byte) error + func (m *RPCServer) Put(args map[string]interface{}, resp *interface{}) error