router

package

v0.0.0-...-cc90bb5 Latest Latest Go to latest Published: Dec 22, 2014 License: MIT Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

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

View Source

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

func CheckUlimit(min int)

func GetEventPath(evt interface{}) string

func GetOriginError(err *errors.Err) error

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

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

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

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

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

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

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

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

func NewMultiOperator(server string) *MultiOperator

type OnSuicideFun func() error

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

change field not allowed whitout Lock()

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 struct {
	// contains filtered or unexported fields
}

Path	Synopsis
topology