groupcache

package module

Go to main page

Versions in this module

v1

v1.3.0

May 23, 2019

v1.2.0

May 15, 2019

Changes in this version

type Group

+ func (g *Group) Remove(ctx Context, key string) error

type HTTPPool

+ func (p *HTTPPool) GetAll() []ProtoGetter

type NoPeers

+ func (NoPeers) GetAll() []ProtoGetter

type PeerPicker

+ GetAll func() []ProtoGetter

type ProtoGetter

+ Remove func(context Context, in *pb.GetRequest) error

v1.1.1

Apr 10, 2019

Changes in this version

+ func RegisterNewGroupHook(fn func(*Group))

+ func RegisterPeerPicker(fn func() PeerPicker)

+ func RegisterPerGroupPeerPicker(fn func(groupName string) PeerPicker)

+ func RegisterServerStart(fn func())

+ type AtomicInt int64

+ func (i *AtomicInt) Add(n int64)

+ func (i *AtomicInt) Get() int64

+ func (i *AtomicInt) String() string

+ type ByteView struct

+ func (v ByteView) At(i int) byte

+ func (v ByteView) ByteSlice() []byte

+ func (v ByteView) Copy(dest []byte) int

+ func (v ByteView) Equal(b2 ByteView) bool

+ func (v ByteView) EqualBytes(b2 []byte) bool

+ func (v ByteView) EqualString(s string) bool

+ func (v ByteView) Expire() time.Time

+ func (v ByteView) Len() int

+ func (v ByteView) ReadAt(p []byte, off int64) (n int, err error)

+ func (v ByteView) Reader() io.ReadSeeker

+ func (v ByteView) Slice(from, to int) ByteView

+ func (v ByteView) SliceFrom(from int) ByteView

+ func (v ByteView) String() string

+ func (v ByteView) WriteTo(w io.Writer) (n int64, err error)

+ type CacheStats struct

+ Bytes int64

+ Evictions int64

+ Gets int64

+ Hits int64

+ Items int64

+ type CacheType int

+ const HotCache

+ const MainCache

+ type Context interface

+ type Getter interface

+ Get func(ctx Context, key string, dest Sink) error

+ type GetterFunc func(ctx Context, key string, dest Sink) error

+ func (f GetterFunc) Get(ctx Context, key string, dest Sink) error

+ type Group struct

+ Stats Stats

+ func GetGroup(name string) *Group

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

+ func (g *Group) CacheStats(which CacheType) CacheStats

+ func (g *Group) Get(ctx Context, key string, dest Sink) error

+ func (g *Group) Name() string

+ type HTTPPool struct

+ Context func(*http.Request) Context

+ Transport func(Context) http.RoundTripper

+ func NewHTTPPool(self string) *HTTPPool

+ func NewHTTPPoolOpts(self string, o *HTTPPoolOptions) *HTTPPool

+ func (p *HTTPPool) PickPeer(key string) (ProtoGetter, bool)

+ func (p *HTTPPool) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (p *HTTPPool) Set(peers ...string)

+ type HTTPPoolOptions struct

+ BasePath string

+ HashFn consistenthash.Hash

+ Replicas int

+ type NoPeers struct

+ func (NoPeers) PickPeer(key string) (peer ProtoGetter, ok bool)

+ type PeerPicker interface

+ PickPeer func(key string) (peer ProtoGetter, ok bool)

+ type ProtoGetter interface

+ Get func(context Context, in *pb.GetRequest, out *pb.GetResponse) error

+ type Sink interface

+ SetBytes func(v []byte, e time.Time) error

+ SetProto func(m proto.Message, e time.Time) error

+ SetString func(s string, e time.Time) error

+ func AllocatingByteSliceSink(dst *[]byte) Sink

+ func ByteViewSink(dst *ByteView) Sink

+ func ProtoSink(m proto.Message) Sink

+ func StringSink(sp *string) Sink

+ func TruncatingByteSliceSink(dst *[]byte) Sink

+ type Stats struct

+ CacheHits AtomicInt

+ Gets AtomicInt

+ Loads AtomicInt

+ LoadsDeduped AtomicInt

+ LocalLoadErrs AtomicInt

+ LocalLoads AtomicInt

+ PeerErrors AtomicInt

+ PeerLoads AtomicInt

+ ServerRequests AtomicInt

Other modules containing this package

github.com/mailgun/groupcache/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL