server

Documentation

Index

• Variables
• type Proxy
  • func New() *Proxy
  • func (p *Proxy) Close()
  • func (p *Proxy) CollectData()
  • func (p *Proxy) GetPersistCache() types.PersistCache
  • func (p *Proxy) GetServePort(id uint64) int
  • func (p *Proxy) GetStatsProvider() interface{}
  • func (p *Proxy) HandleCallback(w resp.ResponseWriter, r interface{})
  • func (p *Proxy) HandleGetChunk(w resp.ResponseWriter, c *resp.Command)
  • func (p *Proxy) HandleSetChunk(w resp.ResponseWriter, c *resp.CommandStream)
  • func (p *Proxy) PersistCacheLen() int
  • func (p *Proxy) Release()
  • func (p *Proxy) Serve()
  • func (p *Proxy) Wait()
  • func (p *Proxy) WaitReady()
• type RedisAdapter
  • func NewRedisAdapter(srv *redeo.Server, proxy *Proxy, d int, p int) *RedisAdapter
  • func (a *RedisAdapter) Close()

Variables

var (
	ECMaxGoroutine = 32
)

Types

type Proxy

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

func New

func New() *Proxy

initial lambda group

func (*Proxy) Close

func (p *Proxy) Close()

func (*Proxy) CollectData

func (p *Proxy) CollectData()

CollectData Trigger data collection.

func (*Proxy) GetPersistCache

func (p *Proxy) GetPersistCache() types.PersistCache

GetPersistCache implements cluster.ServerProvider interface.

func (*Proxy) GetServePort

func (p *Proxy) GetServePort(id uint64) int

GetServePort implements cluster.ServerProvider interface. It round-robin selects a port to serve

func (*Proxy) GetStatsProvider

func (p *Proxy) GetStatsProvider() interface{}

func (*Proxy) HandleCallback

func (p *Proxy) HandleCallback(w resp.ResponseWriter, r interface{})

HandleCallback callback handler

func (*Proxy) HandleGetChunk

func (p *Proxy) HandleGetChunk(w resp.ResponseWriter, c *resp.Command)

HandleGetChunk is the handler for "get chunk".

func (*Proxy) HandleSetChunk

func (p *Proxy) HandleSetChunk(w resp.ResponseWriter, c *resp.CommandStream)

HandleSetChunk is the handler for "set chunk".

func (*Proxy) PersistCacheLen

func (p *Proxy) PersistCacheLen() int

PersistCacheLen implements types.ServerStats interface.

func (*Proxy) Release

func (p *Proxy) Release()

func (*Proxy) Serve

func (p *Proxy) Serve()

func (*Proxy) Wait

func (p *Proxy) Wait()

func (*Proxy) WaitReady

func (p *Proxy) WaitReady()

type RedisAdapter

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

func NewRedisAdapter

func NewRedisAdapter(srv *redeo.Server, proxy *Proxy, d int, p int) *RedisAdapter

func (*RedisAdapter) Close

func (a *RedisAdapter) Close()