router

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

type Config 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 Request struct {
	OpStr string
	Start int64

	Resp *redis.Resp

	Coalesce func() error
	Response struct {
		Resp *redis.Resp
		Err  error
	}

	Wait *sync.WaitGroup

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

type Server struct {
	net.Listener
	OnSuicide func() error
	// 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 {
	Id    int
	Info  *models.Slot
	Group *models.ServerGroup
	// contains filtered or unexported fields
}