nado

package module

v0.0.0-...-7cd6839 Latest Latest Go to latest Published: Mar 3, 2015 License: MIT Imports: 11 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

Repository

github.com/ablegao/serve-nado

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AddServerHandle(handle ServeHandle)
func GetWait(id uint64) (b chan []byte, c chan bool, t *time.Timer, e error)
func HandFunc(typ uint16, fun Header)
func NewConfig(jsonFile string) *Configure
func NewServer(conf *Configure)
func RunHand(w ResponseWrite, r Request, fun Header)
func ServerListen()
func StopId(id uint64)
func UserAdd(key interface{}, info UserConn) error
func UserDel(key interface{}) error
func UserSet(key interface{}, info UserConn) error
func WaitId(id uint64, callback func()) (b chan []byte, c chan bool, t *time.Timer)
type NadoServer
- func (self *NadoServer) AddServeHandle(s ServeHandle)
- func (self *NadoServer) HandFunc(typ uint16, fun Header)
- func (self *NadoServer) Run()
- func (self *NadoServer) RunHandler(w ResponseWrite, r Request, defaultFun Header)
type UserConn
- func UserGet(key interface{}) (UserConn, error)
type UserList
- func (self *UserList) Add(key interface{}, val UserConn) (err error)
- func (self *UserList) Del(key interface{}) (err error)
- func (self *UserList) Get(key interface{}) (info UserConn, err error)
- func (self *UserList) Set(key interface{}, val UserConn) (err error)
type UserRoute

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	Error = log.New(os.Stderr, "ERROR ", log.Lshortfile|log.LstdFlags)
	Debug = log.New(os.Stderr, "DEBUG ", log.Lshortfile|log.LstdFlags)
)

View Source

var RouterToConsumer Header

View Source

var Stop = make(chan bool)

View Source

var Users = new(UserList)

View Source

var WriteToServer = make(chan RequestResponse)

Functions ¶

func AddServerHandle ¶

func AddServerHandle(handle ServeHandle)

func GetWait ¶

func GetWait(id uint64) (b chan []byte, c chan bool, t *time.Timer, e error)

func HandFunc ¶

func HandFunc(typ uint16, fun Header)

func NewConfig ¶

func NewConfig(jsonFile string) *Configure

func NewServer ¶

func NewServer(conf *Configure)

func RunHand ¶

func RunHand(w ResponseWrite, r Request, fun Header)

func ServerListen ¶

func ServerListen()

func StopId ¶

func StopId(id uint64)

func UserAdd ¶

func UserAdd(key interface{}, info UserConn) error

func UserDel ¶

func UserDel(key interface{}) error

func UserSet ¶

func UserSet(key interface{}, info UserConn) error

func WaitId ¶

func WaitId(id uint64, callback func()) (b chan []byte, c chan bool, t *time.Timer)

Types ¶

type NadoServer ¶

type NadoServer struct {
	sync.RWMutex

	AddRoute chan *UserRoute
	DelRoute chan uint64
	Routes   map[uint64]chan []byte
	// contains filtered or unexported fields
}

var DefaultServer *NadoServer

** 默认处理方式 *

func (*NadoServer) AddServeHandle ¶

func (self *NadoServer) AddServeHandle(s ServeHandle)

func (*NadoServer) HandFunc ¶

func (self *NadoServer) HandFunc(typ uint16, fun Header)

func (*NadoServer) Run ¶

func (self *NadoServer) Run()

启动一个通道服务

func (*NadoServer) RunHandler ¶

func (self *NadoServer) RunHandler(w ResponseWrite, r Request, defaultFun Header)

type UserConn ¶

type UserConn interface {
	Write([]byte) (int, error)
	Close() error
}

func UserGet ¶

func UserGet(key interface{}) (UserConn, error)

type UserList ¶

type UserList struct {
	sync.RWMutex

	L map[interface{}]UserConn
}

func (*UserList) Add ¶

func (self *UserList) Add(key interface{}, val UserConn) (err error)

func (*UserList) Del ¶

func (self *UserList) Del(key interface{}) (err error)

func (*UserList) Get ¶

func (self *UserList) Get(key interface{}) (info UserConn, err error)

func (*UserList) Set ¶

func (self *UserList) Set(key interface{}, val UserConn) (err error)

type UserRoute ¶

type UserRoute struct {
	Uid   uint64
	Route chan []byte
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
http-handler
json_nsq-handler
json_nsq_route-handler
lib

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