groupcache

package module

Go to main page

Versions in this module

v2

v2.5.1

Oct 26, 2023

Changes in this version

type GroupOption

+ func WithPeerPicker(pickerFn PeerPicker) GroupOption

v2.4.0

Sep 27, 2023

Changes in this version

type CacheStats

+ ActiveSingleFlightLoads int64

+ ActiveSingleFlightRemoves int64

+ SingleFlightLoadOldestAge time.Duration

+ SingleFlightRemoveOldestAge time.Duration

v2.3.0

Nov 24, 2021

Changes in this version

type RemoteLoadError

+ func (r RemoteLoadError) Unwrap() error

v2.2.2

Jun 22, 2021

Changes in this version

+ func DefaultPeerErrorHandler(ctx context.Context, group *Group, key string, peerURL string, err error) (tryLocally bool, e error)

+ func DefaultServerErrorHandler(ctx context.Context, w http.ResponseWriter, r *http.Request, err error)

+ func DeregisterGroup(name string)

+ func RegisterNewGroupHook(fn func(*Group))

+ func RegisterPeerPicker(fn func() PeerPicker)

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

+ func RegisterServerStart(fn func())

+ func SetLogger(log *logrus.Entry)

+ 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 BadGroupcacheRequestError struct

+ func (e BadGroupcacheRequestError) Error() 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, opts ...GroupOption) *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 GroupNotFoundError struct

+ func (e GroupNotFoundError) Error() string

+ type GroupOption func(group *Group)

+ func WithPeerErrorHandler(handler PeerErrorHandler) GroupOption

+ 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

+ ServerErrorHandler func(context.Context, http.ResponseWriter, *http.Request, error)

+ Transport func(context.Context) http.RoundTripper

+ type NoPeers struct

+ func (NoPeers) GetAll() []ProtoGetter

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

+ type PeerErrorHandler func(ctx context.Context, group *Group, key string, peerURL string, peerError error) (tryLocally bool, err error)

+ 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

+ type RemoteLoadError struct

+ Body []byte

+ Err error

+ Group string

+ Key string

+ Status string

+ StatusCode int

+ func (r RemoteLoadError) Error() string

+ 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