distcache

README

distcache

A simple, distributed in-memory embedded cache

Documentation

Index

• type RPCServer
  • func NewRPCServer(addr string, opts ...grpc.ServerOption) (*RPCServer, error)
  • func (r *RPCServer) Addr() net.Addr
  • func (r *RPCServer) Peers() *peers
  • func (r *RPCServer) Start()
  • func (r *RPCServer) Stop()
  • func (r *RPCServer) Trxn(ctx context.Context, req *pb.Request) (*pb.Response, error)

Types

type RPCServer

type RPCServer struct {
	// contains filtered or unexported fields
}

func NewRPCServer

func NewRPCServer(addr string, opts ...grpc.ServerOption) (*RPCServer, error)

func (*RPCServer) Addr

func (r *RPCServer) Addr() net.Addr

func (*RPCServer) Peers

func (r *RPCServer) Peers() *peers

func (*RPCServer) Start

func (r *RPCServer) Start()

func (*RPCServer) Stop

func (r *RPCServer) Stop()

func (*RPCServer) Trxn

func (r *RPCServer) Trxn(ctx context.Context, req *pb.Request) (*pb.Response, error)

Trxn determines the locality of the cache transaction by performing a consistent hash over the requested key. If the key is not on the local instance a grpc call to the remote server is made.