router

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

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

type FlushPolicy struct {
	*redis.Encoder

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

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

type Request struct {
	// 原始的请求串?
	OpStr string
	// 请求开始的时间戳?
	Start int64

	// 解析后的请求?
	Resp *redis.Resp

	Coalesce func() error
	// 处理结果
	Response struct {
		Resp *redis.Resp
		Err  error
	}

	// 这两个的区别?
	// future锁, writer 使用 r.Wait.Wait() 等待处理的结束.
	// 对象构造的时候会初始化, 见session.go handleRequest()
	Wait *sync.WaitGroup

	Failed *atomic2.Bool
	// contains filtered or unexported fields
}

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

type Session struct {
	*redis.Conn

	Ops int64

	// 上一条指令开始处理的时间
	LastOpUnix int64
	// 连接建立的时间
	CreateUnix int64
	// contains filtered or unexported fields
}

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

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