README
¶
GRPC pool for groupcache
A replacement for groupcache HTTPPool 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, key string, dest groupcache.Sink) error {
dest.SetString(...)
return nil
})
groupcache.NewGroup("grpcPool", 1<<20, getter)
lis, err := net.Listen("tcp", "127.0.0.1:5000")
if err != 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
Balancerto manage the peer connections - Peer discovery mechanism for Kubernetes
Documentation
¶
Overview ¶
* Copyright 2016 Charith Ellawala * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.
Index ¶
- type GRPCPool
- func (gp *GRPCPool) AddPeers(ctx context.Context, peers *gcgrpc.Peers) (*gcgrpc.Ack, error)
- func (gp *GRPCPool) PickPeer(key string) (groupcache.ProtoGetter, bool)
- func (gp *GRPCPool) RemovePeers(ctx context.Context, peers *gcgrpc.Peers) (*gcgrpc.Ack, error)
- func (gp *GRPCPool) Retrieve(ctx context.Context, req *gcgrpc.RetrieveRequest) (*gcgrpc.RetrieveResponse, error)
- func (gp *GRPCPool) Set(peers ...string)
- func (gp *GRPCPool) SetPeers(ctx context.Context, peers *gcgrpc.Peers) (*gcgrpc.Ack, error)
- type GRPCPoolOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GRPCPool ¶
type GRPCPool struct {
// contains filtered or unexported fields
}
func NewGRPCPoolOptions ¶
func NewGRPCPoolOptions(self string, server *grpc.Server, opts *GRPCPoolOptions) *GRPCPool
func (*GRPCPool) PickPeer ¶
func (gp *GRPCPool) PickPeer(key string) (groupcache.ProtoGetter, bool)
func (*GRPCPool) RemovePeers ¶
func (*GRPCPool) Retrieve ¶
func (gp *GRPCPool) Retrieve(ctx context.Context, req *gcgrpc.RetrieveRequest) (*gcgrpc.RetrieveResponse, error)
type GRPCPoolOptions ¶
type GRPCPoolOptions struct {
Replicas int
HashFn consistenthash.Hash
PeerDialOptions []grpc.DialOption
}
Source Files
Directories