remote

Documentation

Index

• func CreateCache(w http.ResponseWriter, params []string)
• type HttpPool
  • func NewDefaultHttpPool() *HttpPool
  • func NewHttpPool(selfAddr string) *HttpPool
  • func (p *HttpPool) PickNode(key string) (peer node.NodeGetter, ok bool)
  • func (p *HttpPool) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (p *HttpPool) SetClusterAddr(addrs ...string)

Functions

func CreateCache

func CreateCache(w http.ResponseWriter, params []string)

Create a new cache group and set cacheName, capacity, selfAddr, and clusterAddr If cacheName already exists, changing only the capacity, selfAddr and clusterAddr parameters will not work

Types

type HttpPool

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

func NewDefaultHttpPool

func NewDefaultHttpPool() *HttpPool

func NewHttpPool

func NewHttpPool(selfAddr string) *HttpPool

func (*HttpPool) PickNode

func (p *HttpPool) PickNode(key string) (peer node.NodeGetter, ok bool)

The key is passed through the hash ring to find the real host

func (*HttpPool) ServeHTTP

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

func (*HttpPool) SetClusterAddr

func (p *HttpPool) SetClusterAddr(addrs ...string)

Register the cluster in the hash ring