kache

Documentation

Index

• type ByteView
  • func (bv ByteView) ByteSlice() []byte
  • func (bv ByteView) Len() int
  • func (bv ByteView) String() string
• type Client
  • func NewClient(service string) *Client
  • func (c *Client) Get(group string, key string) ([]byte, error)
  • func (c *Client) Watch(group string, key string, onUpdated func([]byte))
• type Getter
• type GetterFunc
  • func (f GetterFunc) Get(key string) ([]byte, error)
• type Group
  • func GetGroup(name string) *Group
  • func NewGroup(name string, cacheBytes int64, getter Getter) *Group
  • func (g *Group) Get(key string) (ByteView, error)
  • func (g *Group) RegisterPeers(peers PeerPicker)
  • func (g *Group) Set(key string, value []byte, ttl time.Duration) bool
• type PeerGetter
• type PeerPicker
• type Server
  • func NewServer(self string) *Server
  • func (s *Server) Get(ctx context.Context, in *pb.Request) (*pb.Response, error)
  • func (s *Server) PickPeer(key string) (PeerGetter, bool)
  • func (s *Server) SetPeers(peersAddr ...string)
  • func (s *Server) Start() error
  • func (s *Server) Stop()
  • func (s *Server) Update(group, key string, value []byte) error

Types

type ByteView

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

A ByteView holds an immutable view of bytes

func (ByteView) ByteSlice

func (bv ByteView) ByteSlice() []byte

func (ByteView) Len

func (bv ByteView) Len() int

func (ByteView) String

func (bv ByteView) String() string

type Client

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

func NewClient

func NewClient(service string) *Client

func (*Client) Get

func (c *Client) Get(group string, key string) ([]byte, error)

func (*Client) Watch

func (c *Client) Watch(group string, key string, onUpdated func([]byte))

type Getter

type Getter interface {
	Get(key string) ([]byte, error)
}

type GetterFunc

type GetterFunc func(key string) ([]byte, error)

func (GetterFunc) Get

func (f GetterFunc) Get(key string) ([]byte, error)

type Group

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

func GetGroup

func GetGroup(name string) *Group

func NewGroup

func NewGroup(name string, cacheBytes int64, getter Getter) *Group

func (*Group) Get

func (g *Group) Get(key string) (ByteView, error)

func (*Group) RegisterPeers

func (g *Group) RegisterPeers(peers PeerPicker)

func (*Group) Set

func (g *Group) Set(key string, value []byte, ttl time.Duration) bool

type PeerGetter

type PeerGetter interface {
	Get(group, key string) ([]byte, error)
	Watch(group, key string, fn func([]byte))
}

type PeerPicker

type PeerPicker interface {
	PickPeer(key string) (peer PeerGetter, ok bool)
	Update(group, key string, value []byte) error
}

type Server

type Server struct {
	pb.UnimplementedKacheServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(self string) *Server

func (*Server) Get

func (s *Server) Get(ctx context.Context, in *pb.Request) (*pb.Response, error)

func (*Server) PickPeer

func (s *Server) PickPeer(key string) (PeerGetter, bool)

func (*Server) SetPeers

func (s *Server) SetPeers(peersAddr ...string)

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop()

func (*Server) Update

func (s *Server) Update(group, key string, value []byte) error