groupcache

Dec 30, 2024

Changes in this version

type Group

+ func GetGroups() []*Group

Jun 12, 2023

Changes in this version

+ type ErrNotFound struct

+ Msg string

+ func (e *ErrNotFound) Error() string

+ func (e *ErrNotFound) Is(target error) bool

+ type ErrRemoteCall struct

+ Msg string

+ func (e *ErrRemoteCall) Error() string

+ func (e *ErrRemoteCall) Is(target error) bool

Dec 20, 2022

Changes in this version

+ var NowFunc lru.NowFunc = time.Now

Jul 6, 2022

Changes in this version

+ func SetLoggerFromLogger(log Logger)

+ type Logger interface

+ Debug func() Logger

+ Error func() Logger

+ ErrorField func(label string, err error) Logger

+ Info func() Logger

+ Printf func(format string, args ...interface{})

+ StringField func(label string, val string) Logger

+ Warn func() Logger

+ WithFields func(fields map[string]interface{}) Logger

+ type LogrusLogger struct

+ Entry *logrus.Entry

+ func (l LogrusLogger) Debug() Logger

+ func (l LogrusLogger) Error() Logger

+ func (l LogrusLogger) ErrorField(label string, err error) Logger

+ func (l LogrusLogger) Info() Logger

+ func (l LogrusLogger) Printf(format string, args ...interface{})

+ func (l LogrusLogger) StringField(label string, val string) Logger

+ func (l LogrusLogger) Warn() Logger

+ func (l LogrusLogger) WithFields(fields map[string]interface{}) Logger

Jan 6, 2022

Changes in this version

type Group

+ func (g *Group) Set(ctx context.Context, key string, value []byte, expire time.Time, hotCache bool) error

type ProtoGetter

+ Set func(context context.Context, in *pb.SetRequest) error

Jul 9, 2020

Changes in this version

+ func DeregisterGroup(name string)

+ func SetLogger(log *logrus.Entry)

type AtomicInt

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

type ProtoGetter

+ GetURL func() string

type Stats

+ GetFromPeersLatencyLower AtomicInt

Jun 4, 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 Getter interface

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

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

+ func (f GetterFunc) Get(ctx context.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.Context, key string, dest Sink) error

+ func (g *Group) Name() string

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

+ type HTTPPool struct

+ func NewHTTPPool(self string) *HTTPPool

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

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

+ 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

+ Context func(*http.Request) context.Context

+ HashFn consistenthash.Hash

+ Replicas int

+ Transport func(context.Context) http.RoundTripper

+ type NoPeers struct

+ func (NoPeers) GetAll() []ProtoGetter

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

+ type PeerPicker interface

+ GetAll func() []ProtoGetter

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

+ type ProtoGetter interface

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

+ Remove func(context context.Context, in *pb.GetRequest) 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