hgcache

package

v0.0.0-...-6b5340c Latest Latest Go to latest Published: Oct 15, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

func (v BytesView) ByteSlice() []byte

copy

func (v BytesView) Len() int

func (v BytesView) String() string

type Getter interface {
	Get(key string) ([]byte, error) // 根据key获取值
}

获取缓存数据接口，依赖注入，让用户自行实现获取方式

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

本地获取数据函数

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

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

func GetGroup(name string) *Group

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

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

主要函数

获取缓存
策略：1,2,3
客户端访问-直接从本地缓存中取(本地缓存存在)
		 -(本地缓存不存在)是否从远程节点获取-(是)从远程获取-返回缓存
				                        -(否)回调函数getter，添加缓存-返回缓存

func (g *Group) RegisterPeers(peers PeerPicker)

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

func NewHttpPool(self string) *HttpPool

func (p *HttpPool) Log(format string, args ...interface{})

func (p *HttpPool) PickPeer(key string) (PeerGetter, bool)

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

func (p *HttpPool) Set(peers ...string)

type PeerGetter interface {
	Get(in *pb.Request, out *pb.Response) error
}

type PeerPicker interface {
	PickPeer(key string) (peer PeerGetter, ok bool)
}