GRPC pool for groupcache

A replacement for groupcacheHTTPPool that uses GRPC to communicate with peers.

Usage

server:=grpc.NewServer()
p:=NewGRPCPool("127.0.0.1:5000", server)
p.Set(peerAddrs...)
getter:=groupcache.GetterFunc(func(ctx groupcache.Context, keystring, dest groupcache.Sink) error {
dest.SetString(...)
returnnil
})
groupcache.NewGroup("grpcPool", 1<<20, getter)
lis, err:=net.Listen("tcp", "127.0.0.1:5000")
iferr!=nil {
log.Fatalf("Failed to start server")
}
server.Serve(lis)

Use GRPCPoolOptions to set the GRPC client dial options such as using compression, authentication etc.

To Do

• Use GRPC Balancer to manage the peer connections
• Peer discovery mechanism for Kubernetes