router

Documentation

Index

• Constants
• Variables
• func CheckUlimit(min int)
• func GetEventPath(evt interface{}) string
• func GetOriginError(err *errors.Err) error
• func NewTaskRunner(addr string, netTimeout int) (*taskRunner, error)
• func StringsContain(s []string, key string) bool
• func WriteMigrateKeyCmd(w io.Writer, addr string, timeoutMs int, key []byte) error
• type BufioDeadlineReadWriter
• type Conf
  • func LoadConf(configFile string) (*Conf, error)
• type DeadlineReadWriter
• type MulOp
• type MultiOperator
  • func NewMultiOperator(server string) *MultiOperator
• type OnSuicideFun
• type PipelineRequest
  • func (pr *PipelineRequest) String() string
• type PipelineResponse
• type Server
  • func NewServer(addr string, debugVarAddr string, conf *Conf) *Server
  • func (s *Server) FillSlots()
  • func (s *Server) OnGroupChange(groupId int)
  • func (s *Server) OnSlotRangeChange(param *models.SlotMultiSetParam)
  • func (s *Server) RegisterAndWait()
  • func (s *Server) Run()
• type Slot

Constants

const (
	HASHTAG_START = '{'
	HASHTAG_END   = '}'
)

Variables

var (
	OK_BYTES = []byte("+OK\r\n")
)

Functions

func CheckUlimit

func CheckUlimit(min int)

func GetEventPath

func GetEventPath(evt interface{}) string

func GetOriginError

func GetOriginError(err *errors.Err) error

func NewTaskRunner

func NewTaskRunner(addr string, netTimeout int) (*taskRunner, error)

func StringsContain

func StringsContain(s []string, key string) bool

func WriteMigrateKeyCmd

func WriteMigrateKeyCmd(w io.Writer, addr string, timeoutMs int, key []byte) error

Types

type BufioDeadlineReadWriter

type BufioDeadlineReadWriter interface {
	DeadlineReadWriter
	BufioReader() *bufio.Reader
}

type Conf

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

func LoadConf

func LoadConf(configFile string) (*Conf, error)

type DeadlineReadWriter

type DeadlineReadWriter interface {
	io.ReadWriter
	SetWriteDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
}

type MulOp

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

type MultiOperator

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

func NewMultiOperator

func NewMultiOperator(server string) *MultiOperator

type OnSuicideFun

type OnSuicideFun func() error

type PipelineRequest

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

func (*PipelineRequest) String

func (pr *PipelineRequest) String() string

type PipelineResponse

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

type Server

type Server struct {
	OnSuicide OnSuicideFun
	// contains filtered or unexported fields
}

func NewServer

func NewServer(addr string, debugVarAddr string, conf *Conf) *Server

func (*Server) FillSlots

func (s *Server) FillSlots()

func (*Server) OnGroupChange

func (s *Server) OnGroupChange(groupId int)

func (*Server) OnSlotRangeChange

func (s *Server) OnSlotRangeChange(param *models.SlotMultiSetParam)

func (*Server) RegisterAndWait

func (s *Server) RegisterAndWait()

func (*Server) Run

func (s *Server) Run()

type Slot

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