groupcache

package module

Go to main page

Versions in this module

v0

v0.1.6

Feb 13, 2023

v0.1.5

Feb 13, 2023

v0.1.4

Feb 13, 2023

v0.1.3

Feb 13, 2023

Changes in this version

+ type ApplyFunc func([]byte, time.Time, []byte) ([]byte, time.Time, error)

v0.1.2

Feb 13, 2023

Changes in this version

type Group

+ func (g *Group) Apply(ctx context.Context, key, fnName string, args []byte, dest Sink) error

+ func (g *Group) GetHot(key string, dest Sink) (bool, error)

+ func (g *Group) RegisterApplyFunc(name string, fn applyFunc)

+ type GroupOpts struct

+ CacheBytes int64

+ Getter Getter

+ Name string

+ SkipHotCache bool

type ProtoGetter

+ Apply func(context context.Context, in *pb.ApplyRequest, out *pb.ApplyResponse) error

v0.1.1

Feb 12, 2023

Changes in this version

+ var NowFunc lru.NowFunc = time.Now

+ func DeregisterGroup(name string)

+ func RegisterPeerPicker(fn func() PeerPicker)

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

+ func RegisterServerStart(fn func())

+ func SetLogger(log *logrus.Entry)

+ func SetLoggerFromLogger(log Logger)

+ type AtomicInt int64

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

+ func (i *AtomicInt) Get() int64

+ func (i *AtomicInt) Store(n 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 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) GetStats() *Stats

+ func (g *Group) Name() string

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

+ func (g *Group) Set(ctx context.Context, key string, value []byte, expire time.Time) 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 ICache interface

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

+ GetStats func() *Stats

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

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

+ func GetGroup(name string) ICache

+ 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

+ 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

+ GetURL func() string

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

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

+ type ShardedGroup struct

+ Stats Stats

+ func NewShardedGroup(name string, cacheBytes int64, getter Getter) *ShardedGroup

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

+ func (g *ShardedGroup) GetStats() *Stats

+ func (g *ShardedGroup) Name() string

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

+ func (g *ShardedGroup) Set(ctx context.Context, key string, value []byte, expire time.Time) 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

+ GetFromPeersLatencyLower AtomicInt

+ Gets AtomicInt

+ Loads AtomicInt

+ LoadsDeduped AtomicInt

+ LocalLoadErrs AtomicInt

+ LocalLoads AtomicInt

+ PeerErrors AtomicInt

+ PeerLoads AtomicInt

+ ServerRequests AtomicInt

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