router

package

v0.0.0-...-90f6a64 Latest Latest Go to latest Published: Aug 16, 2016 License: GPL-3.0, MIT Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/fatedier/studies

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func OpCounts() int64
type BackendConn
- func NewBackendConn(addr, auth string) *BackendConn
- func (bc *BackendConn) Addr() string
- func (bc *BackendConn) Close()
- func (bc *BackendConn) KeepAlive() bool
- func (bc *BackendConn) PushBack(r *Request)
- func (bc *BackendConn) Run()
type Dispatcher
type FlushPolicy
- func (p *FlushPolicy) Encode(resp *redis.Resp, force bool) error
- func (p *FlushPolicy) Flush(force bool) error
type OpStats
- func GetAllOpStats() []*OpStats
- func GetOpStats(opstr string, create bool) *OpStats
- func (s *OpStats) Calls() int64
- func (s *OpStats) MarshalJSON() ([]byte, error)
- func (s *OpStats) OpStr() string
- func (s *OpStats) USecs() int64
type Request
type Router
- func New() *Router
- func NewWithAuth(auth string) *Router
- func (s *Router) Close() error
- func (s *Router) Dispatch(r *Request) error
- func (s *Router) FillSlot(i int, addr, from string, lock bool) error
- func (s *Router) KeepAlive() error
- func (s *Router) ResetSlot(i int) error
type Session
- func NewSession(c net.Conn, auth string) *Session
- func NewSessionSize(c net.Conn, auth string, bufsize int, timeout int) *Session
- func (s *Session) Close() error
- func (s *Session) Serve(d Dispatcher, maxPipeline int)
- func (s *Session) String() string
type SharedBackendConn
- func NewSharedBackendConn(addr, auth string) *SharedBackendConn
- func (s *SharedBackendConn) Close() bool
- func (s *SharedBackendConn) IncrRefcnt()
type Slot

Constants ¶

View Source

const MaxSlotNum = models.DEFAULT_SLOT_NUM

slot数量最大值

Variables ¶

View Source

var (
	ErrBadRespType = errors.New("bad resp type for command")
	ErrBadOpStrLen = errors.New("bad command length, too short or too long")
)

View Source

var ErrFailedRequest = errors.New("discard failed request")

View Source

var ErrRespIsRequired = errors.New("resp is required")

View Source

var ErrSlotIsNotReady = errors.New("slot is not ready, may be offline")

Functions ¶

func OpCounts ¶

func OpCounts() int64

获取总的请求次数

Types ¶

type BackendConn ¶

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

和后端redis的连接

func NewBackendConn ¶

func NewBackendConn(addr, auth string) *BackendConn

建立和后端redis-server的连接，等待请求

func (*BackendConn) Addr ¶

func (bc *BackendConn) Addr() string

func (*BackendConn) Close ¶

func (bc *BackendConn) Close()

关闭连接

func (*BackendConn) KeepAlive ¶

func (bc *BackendConn) KeepAlive() bool

向redis发送心跳包

func (*BackendConn) PushBack ¶

func (bc *BackendConn) PushBack(r *Request)

将redis请求加入等待队列

func (*BackendConn) Run ¶

func (bc *BackendConn) Run()

循环等待对后端的redis请求，执行后返回

type Dispatcher ¶

type Dispatcher interface {
	Dispatch(r *Request) error
}

封装的redis的请求

type FlushPolicy ¶

type FlushPolicy struct {
	*redis.Encoder // 相当于 writer

	MaxBuffered int
	MaxInterval int64
	// contains filtered or unexported fields
}

刷新策略

func (*FlushPolicy) Encode ¶

func (p *FlushPolicy) Encode(resp *redis.Resp, force bool) error

往redis发送命令，并且解析返回内容

func (*FlushPolicy) Flush ¶

func (p *FlushPolicy) Flush(force bool) error

刷新缓冲区，发送到redis

type OpStats ¶

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

操作统计信息

func GetAllOpStats ¶

func GetAllOpStats() []*OpStats

获取全部命令的统计信息

func GetOpStats ¶

func GetOpStats(opstr string, create bool) *OpStats

获取指定命令的统计信息

func (*OpStats) Calls ¶

func (s *OpStats) Calls() int64

func (*OpStats) MarshalJSON ¶

func (s *OpStats) MarshalJSON() ([]byte, error)

func (*OpStats) OpStr ¶

func (s *OpStats) OpStr() string

func (*OpStats) USecs ¶

func (s *OpStats) USecs() int64

type Request ¶

type Request struct {
	OpStr string // redis命令
	Start int64  // 请求时间

	Resp *redis.Resp // client请求对象

	Coalesce func() error // 聚合返回数据的函数
	Response struct {
		Resp *redis.Resp
		Err  error
	}

	Wait *sync.WaitGroup // 请求是否完成

	Failed *atomic2.Bool // 请求是否失败
	// contains filtered or unexported fields
}

type Router ¶

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

func New ¶

func New() *Router

func NewWithAuth ¶

func NewWithAuth(auth string) *Router

创建一个访问redis的路由

func (*Router) Close ¶

func (s *Router) Close() error

func (*Router) Dispatch ¶

func (s *Router) Dispatch(r *Request) error

基于路由规则，将指定的redis-client发过来的请求，转发给这个key所在slot对应的redis-server的连接

func (*Router) FillSlot ¶

func (s *Router) FillSlot(i int, addr, from string, lock bool) error

填充指定slot的信息，建立与所在redis-server的连接

func (*Router) KeepAlive ¶

func (s *Router) KeepAlive() error

对后端所有redis连接发送心跳包

func (*Router) ResetSlot ¶

func (s *Router) ResetSlot(i int) error

type Session ¶

type Session struct {
	*redis.Conn // 和redis客户端之间的连接

	Ops int64

	LastOpUnix int64
	CreateUnix int64
	// contains filtered or unexported fields
}

与redis客户端会话

func NewSession ¶

func NewSession(c net.Conn, auth string) *Session

func NewSessionSize ¶

func NewSessionSize(c net.Conn, auth string, bufsize int, timeout int) *Session

返回一个redis-client的连接对象

func (*Session) Close ¶

func (s *Session) Close() error

func (*Session) Serve ¶

func (s *Session) Serve(d Dispatcher, maxPipeline int)

针对一个redis-client连接的处理函数

func (*Session) String ¶

func (s *Session) String() string

返回string格式session信息

type SharedBackendConn ¶

type SharedBackendConn struct {
	*BackendConn
	// contains filtered or unexported fields
}

连接复用对象

func NewSharedBackendConn ¶

func NewSharedBackendConn(addr, auth string) *SharedBackendConn

创建连接复用对象

func (*SharedBackendConn) Close ¶

func (s *SharedBackendConn) Close() bool

func (*SharedBackendConn) IncrRefcnt ¶

func (s *SharedBackendConn) IncrRefcnt()

type Slot ¶

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

slot相关的连接信息

Source Files ¶

View all Source files

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