router

package
v0.0.0-...-447add3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 15, 2015 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source
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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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